vpj-cd 2008-10-16 17:38:05 +00:00
parent 5cd7920627
commit 854f35fae9
2 changed files with 9 additions and 1 deletions

View File

@ -151,7 +151,6 @@ public class TopicExportProcessor implements IExportProcessor {
connection = connectionFactory.createConnection();
}
connection.setClientID( clientID );
connection.start();
// Create a Session

View File

@ -31,6 +31,7 @@ package org.adempiere.server.rpl.imp;
import java.util.Properties;
import javax.jms.Connection;
import javax.jms.InvalidClientIDException;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
@ -187,7 +188,15 @@ public class TopicListener implements MessageListener {
log.finest("conn = " + conn );
try {
conn.setClientID( clientID );
} catch (InvalidClientIDException e) {
// TODO find a better way to check whether the connection already
// exists
log.config("Connection with clientID '" + clientID
+ "' already exists");
return;
}
session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE); // TODO - could be parameter
log.finest("session = " + session );