diff options
Diffstat (limited to 'java/client/example/src/main/java/org/apache/qpid/example/MapSender.java')
| -rw-r--r-- | java/client/example/src/main/java/org/apache/qpid/example/MapSender.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/java/client/example/src/main/java/org/apache/qpid/example/MapSender.java b/java/client/example/src/main/java/org/apache/qpid/example/MapSender.java index 0ce9383add..fa85c00a51 100644 --- a/java/client/example/src/main/java/org/apache/qpid/example/MapSender.java +++ b/java/client/example/src/main/java/org/apache/qpid/example/MapSender.java @@ -33,8 +33,8 @@ import javax.jms.MapMessage; import javax.jms.MessageProducer; import javax.jms.Session; -import org.apache.qpid.client.AMQAnyDestination; import org.apache.qpid.client.AMQConnection; +import org.apache.qpid.client.AddressBasedDestination; public class MapSender { @@ -45,7 +45,7 @@ public class MapSender { new AMQConnection("amqp://guest:guest@test/?brokerlist='tcp://localhost:5672'"); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); - Destination queue = new AMQAnyDestination("ADDR:message_queue; {create: always}"); + Destination queue = new AddressBasedDestination("ADDR:message_queue; {create: always}"); MessageProducer producer = session.createProducer(queue); MapMessage m = session.createMapMessage(); |