Im trying to write "Frank was here" into my websphere MQ from camel with Topic and Subscribtions.

[Frankiboy <ma...@gmail.com>]

Im trying to write "Frank was here" into my websphere MQ from camel with
Topic and Subscribtions.

The MQ is defined as Topic: HUB_TOP01

With 3 subscribtions "HUB_SUB01" and "HUB_SUB01" and "HUB_SUB03" here im
trying to write to HUB_SUB01

This bean fails with a exception bean(LogMq.class,
"logStart").to("activemq:topic:HUB_TOP01") and the logMq only returns a
string with "Frank was here"



 My Bean definition in camel.xml

	
  <bean id="activemq" class="org.apache.camel.component.jms.JmsComponent">  
     <property name="connectionFactory">
        <bean class="com.ibm.mq.jms.MQConnectionFactory">  
			 <property name="hostName" value="bdaix416.bdunet.dk"/>     
		   	 <property name="port" value="1414"/>
		   	 <property name="clientId" value="HUB_SUB01"/>  
	    </bean> 
     </property>
 </bean>
	



My route.

  from("cxf:bean:hubws?dataFormat=MESSAGE").streamCaching()
        .onException(Exception.class).process(new LogError()).end()
        .bean(LogMq.class, "logStart").to("activemq:topic:HUB_TOP01")
        .bean(AddIpBean.class).bean(SetRoutingKey.class).choice()
        .when(header(ROUTING_KEY).contains(ROUTING_BD)).to("bdws")
        .when(header(ROUTING_KEY).contains(ROUTING_BEC)).to("becws")
       
.when(header(ROUTING_KEY).contains(ROUTING_SDC)).to("sdcws").otherwise().to("file:/fja/")
    ;   


	

Is the cleintId, i thougt i schould set the durableSubscriptionName , but
this is not in the MQConnectionFactory, is this the right way to set 
the subScriobtions, and can any one tell me if im on the right track ? 


Some of the stack Trace from camel:

Exception occurred during execution on the exchange: Exchange[Message: Frank
was here]
org.apache.camel.util.ObjectHelper.wrapCamelExecutionException(ObjectHelper.java:1368)org.apache.camel.impl.DefaultExchange.setException(DefaultExchange.java:283)

org.apache.camel.component.jms.JmsProducer.process(JmsProducer.java:158)org.apache.camel.processor.SendProcessor.process(SendProcessor.java:110)

org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:72)org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:398)

org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191)org.apache.camel.processor.Pipeline.process(Pipeline.java:118)

org.apache.camel.processor.Pipeline.process(Pipeline.java:80)org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191)

org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:105)org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:87)

org.apache.camel.component.cxf.CxfConsumer$1.syncInvoke(CxfConsumer.java:134)org.apache.camel.component.cxf.CxfConsumer$1.invoke(CxfC



--
View this message in context: http://camel.465427.n5.nabble.com/Im-trying-to-write-Frank-was-here-into-my-websphere-MQ-from-camel-with-Topic-and-Subscribtions-tp5753148.html
Sent from the Camel - Users mailing list archive at Nabble.com.