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