diff options
Diffstat (limited to 'qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/v1_0/ExchangeDestination.java')
-rw-r--r-- | qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/v1_0/ExchangeDestination.java | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/v1_0/ExchangeDestination.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/v1_0/ExchangeDestination.java index c518ee5cc3..3faf896aae 100644 --- a/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/v1_0/ExchangeDestination.java +++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/v1_0/ExchangeDestination.java @@ -31,7 +31,7 @@ import org.apache.qpid.server.txn.ServerTransaction; import java.util.ArrayList; import java.util.Arrays; -public class ExchangeDestination implements ReceivingDestination +public class ExchangeDestination implements ReceivingDestination, SendingDestination { private static final Accepted ACCEPTED = new Accepted(); private static final Outcome[] OUTCOMES = { ACCEPTED }; @@ -87,4 +87,9 @@ public class ExchangeDestination implements ReceivingDestination // TODO - fix return 20000; } + + public Exchange getExchange() + { + return _exchange; + } } |