[
https://issues.apache.org/jira/browse/NIFI-2701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joseph Witt updated NIFI-2701:
------------------------------
Fix Version/s: (was: 1.2.0)
> 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
>
> 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.15#6346)
