These extensions allow bindings to be created or removed.
The following example illustrates the creation of queue binding to topic exchange with JMS client.
Example C.4. Binding a queue using JMS
ConnectionFactory connectionFactory = ... Connection connection = connectionFactory.createConnection(); AMQSession<?, ?> session = (AMQSession<?,?>)connection.createSession(false, Session.AUTO_ACKNOWLEDGE); ... AMQShortString queueName = new AMQShortString("testQueue"); AMQShortString routingKey = new AMQShortString("testRoutingKey"); AMQDestination destination = (AMQDestination) session.createQueue(queueName.asString()); ... // binding arguments Map<String, Object> arguments = new HashMap<String, Object>(); arguments.put("x-filter-jms-selector", "application='app1'"); // create binding session.bindQueue(queueName, routingKey, FieldTable.convertToFieldTable(arguments), new AMQShortString("amq.topic"), destination);
Apache Qpid, Messaging built on AMQP; Copyright © 2015 The Apache Software Foundation; Licensed under the Apache License, Version 2.0; Apache Qpid, Qpid, Qpid Proton, Proton, Apache, the Apache feather logo, and the Apache Qpid project logo are trademarks of The Apache Software Foundation; All other marks mentioned may be trademarks or registered trademarks of their respective owners