camel-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Marios Trivizas (JIRA)" <j...@apache.org>
Subject [jira] [Comment Edited] (CAMEL-7151) camel-sjms NullPointerException when adding new route with Sjms as producer.
Date Tue, 04 Feb 2014 10:58:09 GMT

    [ https://issues.apache.org/jira/browse/CAMEL-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13890561#comment-13890561
] 

Marios Trivizas edited comment on CAMEL-7151 at 2/4/14 10:57 AM:
-----------------------------------------------------------------

The issue is not valid as In my code I'm missing the call to start the SjmsComponent. Since
the CamelContext is already started it doesn't start the SjmsComponent automatically and that
is the root cause of the error. So the problem is fixed by adding the call to start() method
on SjmsComponent:
{code}
SjmsComponent sjms = new SjmsComponent();
sjms.setConnectionFactory(dstConnectionFactory);
camelContext.addComponent(dstEndpoint.getName(), sjms);
sjms.start(); // missing call
{code}


was (Author: matriv):
The issue is not valid as In my code I'm missing the call to start the SjmsComponent. Since
the CamelContext is already started it doesn't start the SjmsComponent automatically and that
is the root cause of the error. So the problem is fixed by adding the call to start() method
on SjmsComponent:
{code}
SjmsComponent sjms = new SjmsComponent();
sjms.setConnectionFactory(dstConnectionFactory);
camelContext.addComponent(dstEndpoint.getName(), sjms);
*sjms.start();*
{code}

> camel-sjms NullPointerException when adding new route with Sjms as producer.
> ----------------------------------------------------------------------------
>
>                 Key: CAMEL-7151
>                 URL: https://issues.apache.org/jira/browse/CAMEL-7151
>             Project: Camel
>          Issue Type: Bug
>    Affects Versions: 2.13.0
>            Reporter: Marios Trivizas
>            Assignee: Scott England-Sullivan
>
> The following exception is thrown when adding new route programmatically with Sjms as
producer:
> java.lang.NullPointerException
> 	at java.util.concurrent.ArrayBlockingQueue.checkNotNull(ArrayBlockingQueue.java:145)
> 	at java.util.concurrent.ArrayBlockingQueue.offer(ArrayBlockingQueue.java:296)
> 	at java.util.AbstractQueue.add(AbstractQueue.java:95)
> 	at java.util.concurrent.ArrayBlockingQueue.add(ArrayBlockingQueue.java:283)
> 	at org.apache.camel.component.sjms.jms.ObjectPool.fillPool(ObjectPool.java:55)
> 	at org.apache.camel.component.sjms.SjmsProducer.doStart(SjmsProducer.java:139)
> 	at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
> 	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:74)
> 	at org.apache.camel.impl.ProducerCache.doGetProducer(ProducerCache.java:407)
> 	at org.apache.camel.impl.ProducerCache.acquireProducer(ProducerCache.java:123)
> 	at org.apache.camel.processor.SendProcessor.doStart(SendProcessor.java:191)
> 	at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
> 	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:74)
> 	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:59)
> 	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:103)
> 	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:89)
> 	at org.apache.camel.processor.DelegateAsyncProcessor.doStart(DelegateAsyncProcessor.java:79)
> 	at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
> 	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:74)
> 	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:59)
> 	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:103)
> 	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:89)
> 	at org.apache.camel.processor.RedeliveryErrorHandler.doStart(RedeliveryErrorHandler.java:1154)
> 	at org.apache.camel.support.ChildServiceSupport.start(ChildServiceSupport.java:41)
> 	at org.apache.camel.support.ChildServiceSupport.start(ChildServiceSupport.java:28)
> 	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:74)
> 	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:59)
> 	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:103)
> 	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:89)
> 	at org.apache.camel.processor.interceptor.DefaultChannel.doStart(DefaultChannel.java:155)
> 	at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
> 	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:74)
> 	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:59)
> 	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:103)
> 	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:61)
> 	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:103)
> 	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:89)
> 	at org.apache.camel.processor.MulticastProcessor.doStart(MulticastProcessor.java:984)
> 	at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
> 	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:74)
> 	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:59)
> 	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:103)
> 	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:89)
> 	at org.apache.camel.processor.DelegateAsyncProcessor.doStart(DelegateAsyncProcessor.java:79)
> 	at org.apache.camel.processor.FilterProcessor.doStart(FilterProcessor.java:80)
> 	at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
> 	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:74)
> 	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:59)
> 	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:103)
> 	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:61)
> 	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:103)
> 	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:89)
> 	at org.apache.camel.processor.ChoiceProcessor.doStart(ChoiceProcessor.java:171)
> 	at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
> 	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:74)
> 	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:59)
> 	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:103)
> 	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:89)
> 	at org.apache.camel.processor.DelegateAsyncProcessor.doStart(DelegateAsyncProcessor.java:79)
> 	at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
> 	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:74)
> 	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:59)
> 	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:103)
> 	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:89)
> 	at org.apache.camel.processor.RedeliveryErrorHandler.doStart(RedeliveryErrorHandler.java:1154)
> 	at org.apache.camel.support.ChildServiceSupport.start(ChildServiceSupport.java:41)
> 	at org.apache.camel.support.ChildServiceSupport.start(ChildServiceSupport.java:28)
> 	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:74)
> 	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:59)
> 	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:103)
> 	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:89)
> 	at org.apache.camel.processor.interceptor.DefaultChannel.doStart(DefaultChannel.java:155)
> 	at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
> 	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:74)
> 	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:59)
> 	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:103)
> 	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:61)
> 	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:103)
> 	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:89)
> 	at org.apache.camel.processor.MulticastProcessor.doStart(MulticastProcessor.java:984)
> 	at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
> 	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:74)
> 	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:59)
> 	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:103)
> 	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:89)
> 	at org.apache.camel.processor.DelegateAsyncProcessor.doStart(DelegateAsyncProcessor.java:79)
> 	at org.apache.camel.processor.FilterProcessor.doStart(FilterProcessor.java:80)
> 	at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
> 	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:74)
> 	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:59)
> 	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:103)
> 	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:89)
> 	at org.apache.camel.processor.DelegateAsyncProcessor.doStart(DelegateAsyncProcessor.java:79)
> 	at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
> 	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:74)
> 	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:59)
> 	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:103)
> 	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:89)
> 	at org.apache.camel.processor.RedeliveryErrorHandler.doStart(RedeliveryErrorHandler.java:1154)
> 	at org.apache.camel.support.ChildServiceSupport.start(ChildServiceSupport.java:41)
> 	at org.apache.camel.support.ChildServiceSupport.start(ChildServiceSupport.java:28)
> 	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:74)
> 	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:59)
> 	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:103)
> 	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:89)
> 	at org.apache.camel.processor.interceptor.DefaultChannel.doStart(DefaultChannel.java:155)
> 	at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
> 	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:74)
> 	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:59)
> 	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:103)
> 	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:89)
> 	at org.apache.camel.processor.DelegateAsyncProcessor.doStart(DelegateAsyncProcessor.java:79)
> 	at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
> 	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:74)
> 	at org.apache.camel.impl.RouteService.startChildService(RouteService.java:329)
> 	at org.apache.camel.impl.RouteService.warmUp(RouteService.java:158)
> 	at org.apache.camel.impl.DefaultCamelContext.doWarmUpRoutes(DefaultCamelContext.java:2109)
> 	at org.apache.camel.impl.DefaultCamelContext.safelyStartRouteServices(DefaultCamelContext.java:2039)
> 	at org.apache.camel.impl.DefaultCamelContext.safelyStartRouteServices(DefaultCamelContext.java:2061)
> 	at org.apache.camel.impl.DefaultCamelContext.startRouteService(DefaultCamelContext.java:1938)
> 	at org.apache.camel.impl.DefaultCamelContext.startRoute(DefaultCamelContext.java:772)
> 	at org.apache.camel.impl.DefaultCamelContext.startRouteDefinitions(DefaultCamelContext.java:1914)
> 	at org.apache.camel.impl.DefaultCamelContext.addRouteDefinitions(DefaultCamelContext.java:707)
> 	at org.apache.camel.builder.RouteBuilder.populateRoutes(RouteBuilder.java:337)
> 	at org.apache.camel.builder.RouteBuilder.addRoutesToCamelContext(RouteBuilder.java:264)
> 	at org.apache.camel.impl.DefaultCamelContext.addRoutes(DefaultCamelContext.java:669)
> 	at de.groupon.jms.DynamicRoutesManager.addRoute(DynamicRoutesManager.java:178)
> Here is my code:
> {code}
> public static RouteBuilder buildRoute(final DynamicRoute route, final CamelContext camelContext,
final boolean autoStartup) throws Exception {
> 		InitialContext ic = getInitialContext(route.getSourceEndpoint().getHost(), route.getSourceEndpoint().getJndiPort());
> 		ConnectionFactory srcConnectionFactory = (ConnectionFactory)ic.lookup("/connectionFactory/local/"
+ route.getSourceEndpoint().getJndiConnectionFactoryName());
> 		((HornetQJMSConnectionFactory)srcConnectionFactory).setReconnectAttempts(-1);
> 		((HornetQJMSConnectionFactory)srcConnectionFactory).setRetryInterval(1000);
> 		((HornetQJMSConnectionFactory)srcConnectionFactory).setConnectionTTL(120000);
> 		((HornetQJMSConnectionFactory)srcConnectionFactory).setClientFailureCheckPeriod(2000);
> 		((HornetQJMSConnectionFactory)srcConnectionFactory).setCallTimeout(60000);
> 		((HornetQJMSConnectionFactory)srcConnectionFactory).setConsumerWindowSize(4194304);
> 		((HornetQJMSConnectionFactory)srcConnectionFactory).setInitialConnectAttempts(-1);
> 		((HornetQJMSConnectionFactory)srcConnectionFactory).setUseGlobalPools(false);
> 		((HornetQJMSConnectionFactory)srcConnectionFactory).setScheduledThreadPoolMaxSize(5);
> 		((HornetQJMSConnectionFactory)srcConnectionFactory).setThreadPoolMaxSize(5);
> 		camelContext.addComponent(route.getSourceEndpoint().getName(), JmsComponent.jmsComponentAutoAcknowledge(srcConnectionFactory));
> 		ic.close();
> 		RouteBuilder newRouteBuilder;
> 		JmsEndpoint dstEndpoint = (JmsEndpoint) route.getDestinationEndpoint();
> 		ic = getInitialContext(dstEndpoint.getHost(), dstEndpoint.getJndiPort());
> 		ConnectionFactory dstConnectionFactory = (ConnectionFactory)ic.lookup("/connectionFactory/local/"
+ dstEndpoint.getJndiConnectionFactoryName());
> 		((HornetQJMSConnectionFactory)dstConnectionFactory).setReconnectAttempts(-1);
> 		((HornetQJMSConnectionFactory)dstConnectionFactory).setRetryInterval(1000);
> 		((HornetQJMSConnectionFactory)dstConnectionFactory).setConnectionTTL(120000);
> 		((HornetQJMSConnectionFactory)dstConnectionFactory).setClientFailureCheckPeriod(2000);
> 		((HornetQJMSConnectionFactory)dstConnectionFactory).setCallTimeout(60000);
> 		((HornetQJMSConnectionFactory)dstConnectionFactory).setConsumerWindowSize(4194304);
> 		((HornetQJMSConnectionFactory)dstConnectionFactory).setInitialConnectAttempts(-1);
> 		((HornetQJMSConnectionFactory)dstConnectionFactory).setUseGlobalPools(false);
> 		((HornetQJMSConnectionFactory)dstConnectionFactory).setScheduledThreadPoolMaxSize(5);
> 		((HornetQJMSConnectionFactory)dstConnectionFactory).setThreadPoolMaxSize(5);
> 		SjmsComponent sjms = new SjmsComponent();
> 		sjms.setConnectionFactory(dstConnectionFactory);
> 		camelContext.addComponent(dstEndpoint.getName(), sjms);
> 		ic.close();
> 		newRouteBuilder = new RouteBuilder() {
> 			@Override
> 			public void configure() {
> 				errorHandler(deadLetterChannel("log:de.groupon.jms.route.deadletter." + route.getName()
+ "?level=ERROR&showBody=true&showHeaders=true&showExchangePattern=false&showBodyType=false").maximumRedeliveries(3).redeliveryDelay(500)
> 						.retryAttemptedLogLevel(LoggingLevel.WARN).retriesExhaustedLogLevel(LoggingLevel.ERROR)
> 						.log("de.groupon.jms.route.error." + route.getName()));
> 				from(route.getSourceEndpoint().getCamelUri()).routeId(route.getName()).autoStartup(autoStartup)
> 					.filter().method(route.getFilterChain(), "filterMessage")
> 					.process(route.getTransformer())
> 					.choice().when(body().isNotNull())
> 						.to(ExchangePattern.InOnly, route.getDestinationEndpoint().getCamelUri())
> 						.to("log:de.groupon.jms.route." + route.getName() + "?level=INFO&showBody=true&showHeaders=true&showExchangePattern=false&showBodyType=false")
> 						.stop()
> 					.otherwise()
> 						.stop();
> 			}
> 		};
> 	}
> 	return newRouteBuilder;
> }
> {code}



--
This message was sent by Atlassian JIRA
(v6.1.5#6160)

Mime
View raw message