You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicemix.apache.org by gn...@apache.org on 2007/06/29 16:00:34 UTC
svn commit: r551900 -
/incubator/servicemix/branches/servicemix-3.1/deployables/bindingcomponents/servicemix-jms/src/main/java/org/apache/servicemix/jms/multiplexing/MultiplexingConsumerProcessor.java
Author: gnodet
Date: Fri Jun 29 07:00:33 2007
New Revision: 551900
URL: http://svn.apache.org/viewvc?view=rev&rev=551900
Log:
SM-963: NullPointerExceptions during JMS component initialization
Patch provided by Piotr Bzdyl, thx !
Modified:
incubator/servicemix/branches/servicemix-3.1/deployables/bindingcomponents/servicemix-jms/src/main/java/org/apache/servicemix/jms/multiplexing/MultiplexingConsumerProcessor.java
Modified: incubator/servicemix/branches/servicemix-3.1/deployables/bindingcomponents/servicemix-jms/src/main/java/org/apache/servicemix/jms/multiplexing/MultiplexingConsumerProcessor.java
URL: http://svn.apache.org/viewvc/incubator/servicemix/branches/servicemix-3.1/deployables/bindingcomponents/servicemix-jms/src/main/java/org/apache/servicemix/jms/multiplexing/MultiplexingConsumerProcessor.java?view=diff&rev=551900&r1=551899&r2=551900
==============================================================================
--- incubator/servicemix/branches/servicemix-3.1/deployables/bindingcomponents/servicemix-jms/src/main/java/org/apache/servicemix/jms/multiplexing/MultiplexingConsumerProcessor.java (original)
+++ incubator/servicemix/branches/servicemix-3.1/deployables/bindingcomponents/servicemix-jms/src/main/java/org/apache/servicemix/jms/multiplexing/MultiplexingConsumerProcessor.java Fri Jun 29 07:00:33 2007
@@ -65,10 +65,10 @@
throw new IllegalStateException("No destination provided");
}
}
- consumer = session.createConsumer(destination);
- consumer.setMessageListener(this);
pendingMessages = new ConcurrentHashMap();
channel = endpoint.getServiceUnit().getComponent().getComponentContext().getDeliveryChannel();
+ consumer = session.createConsumer(destination);
+ consumer.setMessageListener(this);
}
protected void doStop() throws Exception {