summaryrefslogtreecommitdiff
path: root/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/v1_0/ExchangeDestination.java
diff options
context:
space:
mode:
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.java7
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;
+ }
}