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:33 UTC
svn commit: r551899 -
/incubator/servicemix/trunk/deployables/bindingcomponents/servicemix-jms/src/main/java/org/apache/servicemix/jms/multiplexing/MultiplexingConsumerProcessor.java
Author: gnodet
Date: Fri Jun 29 07:00:32 2007
New Revision: 551899
URL: http://svn.apache.org/viewvc?view=rev&rev=551899
Log:
SM-963: NullPointerExceptions during JMS component initialization
Patch provided by Piotr Bzdyl, thx !
Modified:
incubator/servicemix/trunk/deployables/bindingcomponents/servicemix-jms/src/main/java/org/apache/servicemix/jms/multiplexing/MultiplexingConsumerProcessor.java
Modified: incubator/servicemix/trunk/deployables/bindingcomponents/servicemix-jms/src/main/java/org/apache/servicemix/jms/multiplexing/MultiplexingConsumerProcessor.java
URL: http://svn.apache.org/viewvc/incubator/servicemix/trunk/deployables/bindingcomponents/servicemix-jms/src/main/java/org/apache/servicemix/jms/multiplexing/MultiplexingConsumerProcessor.java?view=diff&rev=551899&r1=551898&r2=551899
==============================================================================
--- incubator/servicemix/trunk/deployables/bindingcomponents/servicemix-jms/src/main/java/org/apache/servicemix/jms/multiplexing/MultiplexingConsumerProcessor.java (original)
+++ incubator/servicemix/trunk/deployables/bindingcomponents/servicemix-jms/src/main/java/org/apache/servicemix/jms/multiplexing/MultiplexingConsumerProcessor.java Fri Jun 29 07:00:32 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 {