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 {
