You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by cw...@apache.org on 2020/06/10 13:14:53 UTC
[uima-async-scaleout] 09/34: UIMA-5747 made JMS clientID unique
This is an automated email from the ASF dual-hosted git repository.
cwiklik pushed a commit to branch uima-as-3
in repository https://gitbox.apache.org/repos/asf/uima-async-scaleout.git
commit d51d6d6e632df98efebbdf9ad7b52fabe1316a72
Author: cwiklik <cwiklik>
AuthorDate: Tue Mar 20 14:15:54 2018 +0000
UIMA-5747 made JMS clientID unique
---
.../src/main/java/org/apache/uima/aae/UIDGenerator.java | 11 ++++++++++-
.../jms/client/BaseUIMAAsynchronousEngineCommon_impl.java | 2 +-
2 files changed, 11 insertions(+), 2 deletions(-)
diff --git a/uimaj-as-core/src/main/java/org/apache/uima/aae/UIDGenerator.java b/uimaj-as-core/src/main/java/org/apache/uima/aae/UIDGenerator.java
index a3d1c6d..375b0dd 100644
--- a/uimaj-as-core/src/main/java/org/apache/uima/aae/UIDGenerator.java
+++ b/uimaj-as-core/src/main/java/org/apache/uima/aae/UIDGenerator.java
@@ -19,11 +19,20 @@
package org.apache.uima.aae;
+import java.net.InetAddress;
+import java.net.UnknownHostException;
import java.rmi.server.UID;
public class UIDGenerator implements UniqueIdGenerator {
public String nextId() {
return new UID().toString();
}
-
+ public static String getGUID() {
+ String localhost = "unknown_local_host";
+ try {
+ localhost = InetAddress.getLocalHost().getHostName();
+ } catch (UnknownHostException e) {
+ }
+ return localhost +"-" +new UID().toString();
+ }
}
diff --git a/uimaj-as-jms/src/main/java/org/apache/uima/adapter/jms/client/BaseUIMAAsynchronousEngineCommon_impl.java b/uimaj-as-jms/src/main/java/org/apache/uima/adapter/jms/client/BaseUIMAAsynchronousEngineCommon_impl.java
index 4c70258..fd5e181 100644
--- a/uimaj-as-jms/src/main/java/org/apache/uima/adapter/jms/client/BaseUIMAAsynchronousEngineCommon_impl.java
+++ b/uimaj-as-jms/src/main/java/org/apache/uima/adapter/jms/client/BaseUIMAAsynchronousEngineCommon_impl.java
@@ -4034,7 +4034,7 @@ public abstract class BaseUIMAAsynchronousEngineCommon_impl implements UimaAsync
//System.out.println("------------- BaseUIMAAsynchronousEngineCommon_impl.create() - Creating new Connection");
// Create shared jms connection to a broker
connection = connectionFactory.createConnection();
- connection.setClientID("ClientListener");
+ connection.setClientID("ClientListener-"+UIDGenerator.getGUID());
state = ConnectionState.OPEN;
stop = false;
}