我正在构建一个应用程序,它将使用来自多个主题的消息,转换消息,然后将它们发布到多个主题。查找 connectionfactory 对象后,我正在使用此代码
Connection con = cf.createConnection();
String clientId = "APP"+ con.hashCode();
con.setClientId(clientId);
在创建持久订阅时,我正在使用这个 MessageConsumer consumer = session.CreateDurableSubscriber(topic,"DurableSubscribtion"+clientId, topic.getSelector, true);
每个连接都应该有唯一的客户端 ID 和订阅名称。
关闭连接后,我尝试使用新创建的连接的 hashCode 再次访问相同的订阅,这种方法会起作用吗?或者我是否需要指定订阅名称,如 SUBSCRIBER1、SUBSCRIBER3、SUBSCRIBER2 ..