Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Apply patch for: https://issues.apache.org/jira/browse/AMQ-4588 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1500885 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Timothy A. Bish 2013-07-08 19:04:09 +00:00
parent d57ebf88f0
commit b3e58a5b33
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
activemq-client/src/main/java/org/apache/activemq/util/IdGenerator.java
View File

@ -35,6 +35,7 @@ public class IdGenerator {
private String seed; private String seed;
private AtomicLong sequence = new AtomicLong(1); private AtomicLong sequence = new AtomicLong(1);
private int length; private int length;
public static final String PROPERTY_IDGENERATOR_PORT ="activemq.idgenerator.port";
static { static {
String stub = ""; String stub = "";
@ -50,13 +51,19 @@ public class IdGenerator {
if (canAccessSystemProps) { if (canAccessSystemProps) {
try { try {
int idGeneratorPort = Integer.parseInt(System.getProperty(PROPERTY_IDGENERATOR_PORT, "0"));
LOG.trace("Using port {}", idGeneratorPort);
hostName = InetAddressUtil.getLocalHostName(); hostName = InetAddressUtil.getLocalHostName();
ServerSocket ss = new ServerSocket(0); ServerSocket ss = new ServerSocket(idGeneratorPort);
stub = "-" + ss.getLocalPort() + "-" + System.currentTimeMillis() + "-"; stub = "-" + ss.getLocalPort() + "-" + System.currentTimeMillis() + "-";
Thread.sleep(100); Thread.sleep(100);
ss.close(); ss.close();
} catch (Exception ioe) { } catch (Exception ioe) {
LOG.warn("could not generate unique stub by using DNS and binding to local port", ioe); if (LOG.isTraceEnabled()) {
LOG.trace("could not generate unique stub by using DNS and binding to local port", ioe);
} else {
LOG.warn("could not generate unique stub by using DNS and binding to local port: {} {}", ioe.getClass().getCanonicalName(), ioe.getMessage());
}
} }
} }
// fallback // fallback