[
https://issues.apache.org/jira/browse/NIFI-2701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15700496#comment-15700496
]
Oleg Zhurakousky commented on NIFI-2701:
----------------------------------------
Raymond
Thank you so much for providing that input. I will definitely take a look. In
all fairness while the intention was to be JMS-provider agnostic what was
tested is the likes of IBM, Tibco and ActiveMQ. I've personally never worked of
SonicMQ and based on few google searches was under impression that only JNDI
CFs are supported. But based on your input I am now eager to find what's
missing in current code base to support SonicMQ (thanks to your sample). So
I'll keep the title as is for now and hopefully once it's all figured out it
can be changed.
That said, I believe that there is somethiny minor, so I am going to set target
version of 1.2.
Thanks again!
Oleg
> Can’t consume JMS Messages from remote broker
> ---------------------------------------------
>
> Key: NIFI-2701
> URL: https://issues.apache.org/jira/browse/NIFI-2701
> Project: Apache NiFi
> Issue Type: Bug
> Components: Core Framework
> Affects Versions: 1.0.0, 0.7.0
> Environment: Windows 7
> Reporter: Raymond
> Assignee: Oleg Zhurakousky
> Fix For: 1.2.0
>
>
> I’m using the ConsumeJMS together with JMSConnectionFactoryProvider service
> to consume message from a SonicMQ broker. If I’m using a NiFi instance and
> the broker on the same machine this works. I can consume the messages from
> the queue on the broker (using the broker url: tcp://localhost:2506).
> If the broker is on another machine I get the following error:
> 08:55:48 CEST
> WARNING
> d6d8ec67-0156-1000-006c-054ada0ce528
> ConsumeJMS - JMSConsumer[destination:q.testconnector.inbox; pub-sub:false;]
> Processor Administratively Yielded for 1 sec due to processing failure
> 08:55:51 CEST
> ERROR
> d6d8ec67-0156-1000-006c-054ada0ce528
> ConsumeJMS - JMSConsumer[destination:q.testconnector.inbox; pub-sub:false;]
> ConsumeJMS - JMSConsumer[destination:q.testconnector.inbox; pub-sub:false;]
> failed to process due to org.springframework.jms.UncategorizedJmsException:
> Uncategorized exception occured during JMS processing; nested exception is
> javax.jms.JMSException: java.net.ConnectException: Connection refused:
> connect: ServerA; rolling back session:
> org.springframework.jms.UncategorizedJmsException: Uncategorized exception
> occured during JMS processing; nested exception is javax.jms.JMSException:
> java.net.ConnectException: Connection refused: connect: ServerA
> Server A is the machine where the NiFi instance is running. So the connection
> is not refused by the machine where the broker is running. The broker is
> running correctly and I can connect from the same machine with other JMS
> Clients with same credentials. This problem occurred with a NiFi 0.6.1 and
> 1.0B instance.
> Log:
> org.springframework.jms.UncategorizedJmsException: Uncategorized exception
> occured during JMS processing; nested exception is javax.jms.JMSException:
> java.net.ConnectException: Connection refused: connect: SERVERA
> at
> org.springframework.jms.support.JmsUtils.convertJmsAccessException(JmsUtils.java:316)
> ~[na:na]
> at
> org.springframework.jms.support.JmsAccessor.convertJmsAccessException(JmsAccessor.java:169)
> ~[na:na]
> at
> org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:497)
> ~[na:na]
> at
> org.springframework.jms.core.JmsTemplate.receiveSelected(JmsTemplate.java:764)
> ~[na:na]
> at
> org.springframework.jms.core.JmsTemplate.receive(JmsTemplate.java:738)
> ~[na:na]
> at
> org.springframework.jms.core.JmsTemplate.receive(JmsTemplate.java:727)
> ~[na:na]
> at
> org.apache.nifi.jms.processors.JMSConsumer.consume(JMSConsumer.java:65)
> ~[na:na]
> at
> org.apache.nifi.jms.processors.ConsumeJMS.rendezvousWithJms(ConsumeJMS.java:79)
> ~[na:na]
> at
> org.apache.nifi.jms.processors.AbstractJMSProcessor.onTrigger(AbstractJMSProcessor.java:136)
> ~[na:na]
> at
> org.apache.nifi.jms.processors.ConsumeJMS.onTrigger(ConsumeJMS.java:50)
> ~[na:na]
> at
> org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27)
> ~[nifi-api-1.0.0-BETA.jar:1.0.0-BETA]
> at
> org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1060)
> ~[nifi-framework-core-1.0.0-BETA.jar:1.0.0-BETA]
> at
> org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:136)
> [nifi-framework-core-1.0.0-BETA.jar:1.0.0-BETA]
> at
> org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:47)
> [nifi-framework-core-1.0.0-BETA.jar:1.0.0-BETA]
> at
> org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:127)
> [nifi-framework-core-1.0.0-BETA.jar:1.0.0-BETA]
> at java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
> [na:1.8.0_102]
> at java.util.concurrent.FutureTask.runAndReset(Unknown Source)
> [na:1.8.0_102]
> at
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(Unknown
> Source) [na:1.8.0_102]
> at
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(Unknown
> Source) [na:1.8.0_102]
> at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
> [na:1.8.0_102]
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
> [na:1.8.0_102]
> at java.lang.Thread.run(Unknown Source) [na:1.8.0_102]
> Caused by: javax.jms.JMSException: java.net.ConnectException: Connection
> refused: connect: SERVERA
> at
> progress.message.jimpl.JMSExceptionUtil.createJMSException(JMSExceptionUtil.java:42)
> ~[na:na]
> at progress.message.jimpl.Connection.<init>(Connection.java:964)
> ~[na:na]
> at
> progress.message.jclient.ConnectionFactory.createConnection(ConnectionFactory.java:2305)
> ~[na:na]
> at
> org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter.doCreateConnection(UserCredentialsConnectionFactoryAdapter.java:178)
> ~[na:na]
> at
> org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter.createConnection(UserCredentialsConnectionFactoryAdapter.java:152)
> ~[na:na]
> at
> org.springframework.jms.connection.SingleConnectionFactory.doCreateConnection(SingleConnectionFactory.java:365)
> ~[na:na]
> at
> org.springframework.jms.connection.SingleConnectionFactory.initConnection(SingleConnectionFactory.java:305)
> ~[na:na]
> at
> org.springframework.jms.connection.SingleConnectionFactory.getConnection(SingleConnectionFactory.java:283)
> ~[na:na]
> at
> org.springframework.jms.connection.SingleConnectionFactory.createConnection(SingleConnectionFactory.java:224)
> ~[na:na]
> at
> org.springframework.jms.support.JmsAccessor.createConnection(JmsAccessor.java:180)
> ~[na:na]
> at
> org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:484)
> ~[na:na]
> ... 19 common frames omitted
> Caused by: progress.message.client.ENetworkFailure:
> java.net.ConnectException: Connection refused: connect: SERVERA
> at
> progress.message.zclient.Connection.connectWithRecoveryOpt(Connection.java:1178)
> ~[na:na]
> at
> progress.message.zclient.ReconnectHelper.connectAndChaseSingleFailoverRedirect(ReconnectHelper.java:534)
> ~[na:na]
> at progress.message.zclient.Connection.connect(Connection.java:1600)
> ~[na:na]
> at progress.message.jimpl.Connection.<init>(Connection.java:845)
> ~[na:na]
> ... 28 common frames omitted
> Caused by: java.net.ConnectException: Connection refused: connect
> at java.net.TwoStacksPlainSocketImpl.socketConnect(Native Method)
> ~[na:1.8.0_102]
> at java.net.AbstractPlainSocketImpl.doConnect(Unknown Source)
> ~[na:1.8.0_102]
> at java.net.AbstractPlainSocketImpl.connectToAddress(Unknown Source)
> ~[na:1.8.0_102]
> at java.net.AbstractPlainSocketImpl.connect(Unknown Source)
> ~[na:1.8.0_102]
> at java.net.PlainSocketImpl.connect(Unknown Source) ~[na:1.8.0_102]
> at java.net.SocksSocketImpl.connect(Unknown Source) ~[na:1.8.0_102]
> at java.net.Socket.connect(Unknown Source) ~[na:1.8.0_102]
> at java.net.Socket.connect(Unknown Source) ~[na:1.8.0_102]
> at java.net.Socket.<init>(Unknown Source) ~[na:1.8.0_102]
> at java.net.Socket.<init>(Unknown Source) ~[na:1.8.0_102]
> at
> progress.message.net.tcp.ProgressTcpSocket.openSocket(ProgressTcpSocket.java:87)
> ~[na:na]
> at
> progress.message.net.tcp.AbstractTcpSocket.<init>(AbstractTcpSocket.java:87)
> ~[na:na]
> at
> progress.message.net.tcp.ProgressTcpSocket.<init>(ProgressTcpSocket.java:62)
> ~[na:na]
> at
> progress.message.net.tcp.ProgressTcpSocketFactory.createProgressSocket(ProgressTcpSocketFactory.java:55)
> ~[na:na]
> at
> progress.message.net.ProgressSocketFactory.createProgressSocket(ProgressSocketFactory.java:180)
> ~[na:na]
> at progress.message.zclient.Connection.openSocket(Connection.java:3570)
> ~[na:na]
> at
> progress.message.zclient.Connection.connectWithRecoveryOpt(Connection.java:850)
> ~[na:na]
> ... 31 common frames omitted
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
