QPID-3401 Checking the proposed changes into a branch to preserve history & continue working until such time it's accepted into trunk.address-refactor

git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/address-refactor@1183532 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 2 insertions, 3 deletions

diff --git a/java/tools/src/main/java/org/apache/qpid/testkit/Receiver.java b/java/tools/src/main/java/org/apache/qpid/testkit/Receiver.java
index b4294ee4cc..651d401596 100644
--- a/java/tools/src/main/java/org/apache/qpid/testkit/Receiver.java
+++ b/java/tools/src/main/java/org/apache/qpid/testkit/Receiver.java
@@ -25,15 +25,14 @@ import java.util.ArrayList;
 import java.util.List;
 
 import javax.jms.Connection;
-import javax.jms.Destination;
 import javax.jms.Message;
 import javax.jms.MessageConsumer;
 import javax.jms.MessageListener;
 import javax.jms.MessageProducer;
 import javax.jms.TextMessage;
 
-import org.apache.qpid.client.AMQAnyDestination;
 import org.apache.qpid.client.AMQConnection;
+import org.apache.qpid.client.AddressBasedDestination;
 
 /**
  * A generic receiver which consumes messages
@@ -82,7 +81,7 @@ public class Receiver extends Client implements MessageListener
     {
     	super(con);
     	setSsn(con.createSession(isTransacted(), getAck_mode()));
-    	consumer = getSsn().createConsumer(new AMQAnyDestination(addr));
+    	consumer = getSsn().createConsumer(new AddressBasedDestination(addr));
     	if (!syncRcv)
     	{
     		consumer.setMessageListener(this);