AnsweredAssumed Answered

8.1 JMS Consumer/Producer not working

Question asked by Aaron Oldfield on Jul 5, 2018

Hi,

 

I downloaded the EE version for JMS support, but I can never connect. Usual details, ActiveMQ @ tcp://localhost:61616, with a queue.

 

There seem to be no compatible examples for 8.1 available, only 8.0 as the latest.

 

I have placed the MQ broker jar in karat/deploy so it doesn't error, but just times out without connecting.

 

Ive tried sending and receiving with a basic java app which works fine.  The JMS steps keep trying, but after a minute or so will fail with :

 

2018/07/05 21:54:19 - Spoon - Using legacy execution engine

2018/07/05 21:54:19 - class org.pentaho.di.core.injection.bean.BeanInjectionInfo - Collect bean injection info for class org.pentaho.di.trans.step.jms.JmsConsumerMeta

2018/07/05 21:54:19 - class org.pentaho.di.core.injection.bean.BeanInjectionInfo - Collect bean injection info for class org.pentaho.di.trans.step.jms.JmsProducerMeta

2018/07/05 21:54:19 - Spoon - Transformation opened.

2018/07/05 21:54:19 - Spoon - Launching transformation [test-jms]...

2018/07/05 21:54:19 - Spoon - Started the transformation execution.

2018/07/05 21:54:19 - test-jms - Dispatching started for transformation [test-jms]

2018/07/05 21:54:19 - org.pentaho.di.trans.step.jms.JmsConsumerMeta@204b280d - could not get fields, probable AEL

2018/07/05 21:54:49 - JMS Consumer.0 - ERROR (version 8.1.0.0-365, build 8.1.0.0-365 from 2018-04-30 09.42.24 by buildguy) : Unexpected error

2018/07/05 21:54:49 - JMS Consumer.0 - ERROR (version 8.1.0.0-365, build 8.1.0.0-365 from 2018-04-30 09.42.24 by buildguy) : javax.jms.JMSRuntimeException: Failed to create session factory

2018/07/05 21:54:49 - JMS Consumer.0 - at org.apache.activemq.artemis.jms.client.JmsExceptionUtils.convertToRuntimeException(JmsExceptionUtils.java:88)

2018/07/05 21:54:49 - JMS Consumer.0 - at org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory.createContext(ActiveMQConnectionFactory.java:304)

2018/07/05 21:54:49 - JMS Consumer.0 - at org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory.createContext(ActiveMQConnectionFactory.java:292)

2018/07/05 21:54:49 - JMS Consumer.0 - at org.pentaho.di.trans.step.jms.context.ActiveMQProvider.getContext(ActiveMQProvider.java:49)

2018/07/05 21:54:49 - JMS Consumer.0 - at Proxy9d9ded75_8db5_49f8_ad51_aa8c6540ce40.getContext(Unknown Source)

2018/07/05 21:54:49 - JMS Consumer.0 - at Proxy9d9ded75_8db5_49f8_ad51_aa8c6540ce40.getContext(Unknown Source)

2018/07/05 21:54:49 - JMS Consumer.0 - at org.pentaho.di.trans.step.jms.JmsDelegate.getJmsContext(JmsDelegate.java:88)

2018/07/05 21:54:49 - JMS Consumer.0 - at org.pentaho.di.trans.step.jms.JmsStreamSource.open(JmsStreamSource.java:57)

2018/07/05 21:54:49 - JMS Consumer.0 - at org.pentaho.di.trans.streaming.common.BaseStreamStep.processRow(BaseStreamStep.java:116)

2018/07/05 21:54:49 - JMS Consumer.0 - at org.pentaho.di.trans.step.RunThread.run(RunThread.java:62)

2018/07/05 21:54:49 - JMS Consumer.0 - at java.lang.Thread.run(Thread.java:745)

2018/07/05 21:54:49 - JMS Consumer.0 - Caused by: javax.jms.JMSException: Failed to create session factory

2018/07/05 21:54:49 - JMS Consumer.0 - at org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory.createConnectionInternal(ActiveMQConnectionFactory.java:815)

2018/07/05 21:54:49 - JMS Consumer.0 - at org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory.createContext(ActiveMQConnectionFactory.java:299)

2018/07/05 21:54:49 - JMS Consumer.0 - ... 9 more

2018/07/05 21:54:49 - JMS Consumer.0 - Caused by: ActiveMQConnectionTimedOutException[errorType=CONNECTION_TIMEDOUT message=AMQ119013: Timed out waiting to receive cluster topology. Group:null]

2018/07/05 21:54:49 - JMS Consumer.0 - at org.apache.activemq.artemis.core.client.impl.ServerLocatorImpl.createSessionFactory(ServerLocatorImpl.java:816)

2018/07/05 21:54:49 - JMS Consumer.0 - at org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory.createConnectionInternal(ActiveMQConnectionFactory.java:813)

2018/07/05 21:54:49 - JMS Consumer.0 - ... 10 more

2018/07/05 21:54:49 - JMS Consumer.0 - Finished processing (I=0, O=0, R=0, W=0, U=0, E=1)

2018/07/05 21:54:50 - test-jms - Transformation detected one or more steps with errors.

2018/07/05 21:54:50 - test-jms - Transformation is killing the other steps!

2018/07/05 21:54:50 - test-jms - ERROR (version 8.1.0.0-365, build 8.1.0.0-365 from 2018-04-30 09.42.24 by buildguy) : Errors detected!

2018/07/05 21:54:50 - Spoon - The transformation has finished!!

2018/07/05 21:54:50 - test-jms - ERROR (version 8.1.0.0-365, build 8.1.0.0-365 from 2018-04-30 09.42.24 by buildguy) : Errors detected!

2018/07/05 21:54:50 - test-jms - ERROR (version 8.1.0.0-365, build 8.1.0.0-365 from 2018-04-30 09.42.24 by buildguy) : Errors detected!

 

Im still in the trial period and JMS is a core requirement, if I can't get it working it will ve hard to justify

Anybody managed to get this working in 8.1?

 

cheers

A

Outcomes