[jira] [Updated] (NIFI-2701) Can’t consume JMS Messages from remote broker
[ 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) >
[jira] [Updated] (NIFI-2701) Can’t consume JMS Messages from remote broker
[ https://issues.apache.org/jira/browse/NIFI-2701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleg Zhurakousky updated NIFI-2701: --- Fix Version/s: 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 > 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
