1 | try {↵ | | 1 | try {↵
|
2 | ConnectionFactory.getTopicConnectionFactory(ctx,connfactory);↵ | | 2 | ConnectionFactory.getTopicConnectionFactory(ctx,connfactory);↵
|
3 | this.CONN = ConnectionFactory.getTopicConnection();↵ | | 3 | this.CONN = ConnectionFactory.getTopicConnection();↵
|
4 | this.TOPIC = InitialContextFactory.lookupTopic(ctx, topic);↵ | | 4 | this.TOPIC = InitialContextFactory.lookupTopic(ctx, topic);↵
|
5 | this.SESSION = this.CONN.createTopicSession(false, TopicSession.AUTO_ACKNOWLEDGE);↵ | | 5 | this.SESSION = this.CONN.createTopicSession(false, TopicSession.AUTO_ACKNOWLEDGE);↵
|
6 | this.PUBLISHER = this.SESSION.createPublisher(this.TOPIC);↵ | | 6 | this.SUBSCRIBER = this.SESSION.createSubscriber(this.TOPIC);↵
|
7 | log.info("created the topic connection successfully");↵ | | 7 | log.info("created the topic connection successfully");↵
|
8 | } catch (JMSException e) {↵ | | 8 | } catch (JMSException e) {↵
|
9 | log.error("Connection error: " + e.getMessage());↵ | | 9 | log.error("Connection error: " + e.getMessage());↵
|
10 | | | 10 |
|