共享的预订

WebSphere® Application Server V 9.0 支持共享持久预订和非持久预订。 在 JMS 2.0 规范中引入的共享预订用于在多个使用者之间共享单个预订，其中只有一个使用者在任何时间点接收发布内容。 共享预订基本上用于在多个使用者之间共享负载，并由名称和客户机标识标识。

以下示例显示了创建共享持久预订和共享非持久预订的代码样本:

ConnectionFactory connectionFactory;
Connection connection;
Session session;
MessageConsumer consumer;
Topic topic;
String sharedDurableSubName;
...
connection = connectionFactory.createConnection();


// Note: client ID is not mandatory for shared durable subscriptions
connection.setClientID("myClient"); 
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
topic = session.createTopic("sharedTopic");
consumer = ((ImaSubscription)session).createSharedDurableConsumer(topic, sharedDurableSubName);

ConnectionFactory connectionFactory;
Connection connection;
Session session;
MessageConsumer consumer;
Topic topic;
String sharedSubName;
...
connection = connectionFactory.createConnection();

connection.setClientID("myClient"); 
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
topic = session.createTopic("sharedTopic");
consumer = ((ImaSubscription)session).createSharedConsumer(topic, sharedSubName);

consumer = session.createSharedConsumer(topic, sharedSubName, selector);
consumer = session.createSharedDurableConsumer(topic, sharedDurableSubName, selector);