initial.lookup(qConnFactoryName)
This commit is contained in:
@@ -191,17 +191,15 @@ public class ServiceLocator {
|
||||
System.out.println("=================getQueueConnectionFactory qConnFactoryName["+qConnFactoryName+"]");
|
||||
try {
|
||||
if (cache.containsKey(qConnFactoryName)) {
|
||||
System.out.println("=================getQueueConnectionFactory containsKey");
|
||||
factory = (QueueConnectionFactory) cache.get(qConnFactoryName);
|
||||
} else {
|
||||
//factory = (QueueConnectionFactory) initial.lookup(qConnFactoryName);
|
||||
//cache.put(qConnFactoryName, factory);
|
||||
System.out.println("=================getQueueConnectionFactory not containsKey");
|
||||
factory = getRemoteQueueConnectionFactory(
|
||||
"t3://localhost:8001", // 또는 실제 서버 주소
|
||||
qConnFactoryName
|
||||
);
|
||||
|
||||
factory = (QueueConnectionFactory) initial.lookup(qConnFactoryName);
|
||||
cache.put(qConnFactoryName, factory);
|
||||
// System.out.println("=================getQueueConnectionFactory not containsKey");
|
||||
// factory = getRemoteQueueConnectionFactory(
|
||||
// "t3://192.168.240.176:8003", // 또는 실제 서버 주소
|
||||
// qConnFactoryName
|
||||
// );
|
||||
|
||||
}
|
||||
// } catch (NamingException ne) {
|
||||
|
||||
Reference in New Issue
Block a user