Author: nbelaevski
Date: 2011-04-18 07:22:46 -0400 (Mon, 18 Apr 2011)
New Revision: 22427
Modified:
trunk/core/impl/src/main/java/org/richfaces/application/push/impl/jms/MessagingContext.java
Log:
https://issues.jboss.org/browse/RF-10883
Modified:
trunk/core/impl/src/main/java/org/richfaces/application/push/impl/jms/MessagingContext.java
===================================================================
---
trunk/core/impl/src/main/java/org/richfaces/application/push/impl/jms/MessagingContext.java 2011-04-15
15:57:33 UTC (rev 22426)
+++
trunk/core/impl/src/main/java/org/richfaces/application/push/impl/jms/MessagingContext.java 2011-04-18
11:22:46 UTC (rev 22427)
@@ -113,6 +113,10 @@
connection.setClientID(UUID.randomUUID().toString());
} catch (IllegalStateException e) {
//ignore - clientId has already been set
+ LOGGER.debug(e.getMessage(), e);
+ } catch (JMSException e) {
+ //ignore - clientId has already been set
+ LOGGER.debug(e.getMessage(), e);
}
connection.start();
@@ -172,7 +176,7 @@
javax.jms.Topic jmsTopic = lookup(rootTopicKey);
- return jmsSession.createDurableSubscriber(jmsTopic, subscriptionClientId,
createMessageSelector(entry.getValue()), true);
+ return jmsSession.createDurableSubscriber(jmsTopic, subscriptionClientId,
createMessageSelector(entry.getValue()), false);
}
/**