Skip to content

Commit bff440a

Browse files
author
Keith R. Gustafson
committed
Fix saving publisher connection ID
1 parent f7b8471 commit bff440a

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

gemini/src/main/java/com/techempower/gemini/cluster/jms/CacheMessageManager.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -123,12 +123,12 @@ public void connect(ConnectionFactory publishConnectionFactory, ConnectionFactor
123123

124124
// Create publish connection
125125
this.publishConnection = publishConnectionFactory.createConnection();
126-
instanceID = publishConnection.getClientID();
127126
publishConnection.start();
127+
instanceID = publishConnection.getClientID();
128128
this.publisher = new GeminiPublisher(publishConnection,
129129
CacheMessageManager.CACHE_TOPIC_DESTINATION, deliveryMode);
130130
publisher.start();
131-
log.info("JMS publish connection established @{}", publishConnection.getClientID());
131+
log.info("JMS publish connection established @{}", instanceID);
132132

133133
// Create subscribe connection
134134
this.subscribeConnection = subscribeConnectionFactory.createConnection();

0 commit comments

Comments
 (0)