[ 
https://issues.apache.org/jira/browse/NIFI-1378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15092677#comment-15092677
 ] 

Oleg Zhurakousky commented on NIFI-1378:
----------------------------------------

The issue with complex URLs (*failover:(tcp://. . .)*, *broker:(vm://. . .)*) 
is that they can have sub-urls and other arbitrary elements that we can not 
control. 
So, unless there is an objection I'll reopen this JIRA, ensure that the URL as 
it appears gets to the ActiveMqConnectionFactory and any connection-related 
exception gets properly and informatively logged and reported to the bulletin. 

P.S. Unrelated, while playing with various URL configurations, noticed the 
issue related to NIFI-78. Basically if you specify something along the lines of 
*failover(tcp://localhost:22222)?initialReconnectDelay=100*, and nothing is 
running on _localhost:22222_ it will hang indefinitely trying to connect. The 
problem for us is that we can't fully shut down the processor untill we restart 
NiFi.

> GetJMSQueue throws NPE with invalid URL
> ---------------------------------------
>
>                 Key: NIFI-1378
>                 URL: https://issues.apache.org/jira/browse/NIFI-1378
>             Project: Apache NiFi
>          Issue Type: Bug
>          Components: Extensions
>    Affects Versions: 0.4.1
>            Reporter: Joseph Witt
>            Assignee: Joseph Witt
>             Fix For: 0.5.0
>
>         Attachments: 
> 0001-NIFI-1378-added-validator-to-ensure-the-JMS-URI-has-.patch
>
>
> GetJMSQueue throws an NPE.  Easily reproduced even without an actual JMS 
> broker setup.  Use a URL of 'localhost' and some bogus topic.
> {quote}
> 2016-01-10 01:20:23,430 WARN [Timer-Driven Process Thread-3] 
> o.a.n.c.t.ContinuallyRunProcessorTask Administratively Yielding 
> GetJMSQueue[id=e1ce5a1b-818a-4b84-b913-7
> 16e9206c73e] due to uncaught Exception: java.lang.NullPointerException
> 2016-01-10 01:20:23,431 WARN [Timer-Driven Process Thread-3] 
> o.a.n.c.t.ContinuallyRunProcessorTask
> java.lang.NullPointerException: null
>         at 
> org.apache.nifi.processors.standard.util.JmsFactory.createConnectionFactory(JmsFactory.java:366)
>  ~[na:na]
>         at 
> org.apache.nifi.processors.standard.util.JmsFactory.createConnection(JmsFactory.java:111)
>  ~[na:na]
>         at 
> org.apache.nifi.processors.standard.util.JmsFactory.createConnection(JmsFactory.java:104)
>  ~[na:na]
>         at 
> org.apache.nifi.processors.standard.util.JmsFactory.createQueueMessageConsumer(JmsFactory.java:239)
>  ~[na:na]
>         at 
> org.apache.nifi.processors.standard.GetJMSQueue.onTrigger(GetJMSQueue.java:63)
>  ~[na:na]
>         at 
> org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27)
>  ~[nifi-api-1.1.1.0-12.jar:1.1.1.0-12]
>         at 
> org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1146)
>  ~[nifi-framework-core-1.1.1.0-12.jar:1.1.1.0-12]
>         at 
> org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:139)
>  [nifi-framework-core-1.1.1.0-12.jar:1.1.1.0-12]
>         at 
> org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:49)
>  [nifi-framework-core-1.1.1.0-12.jar:1.1.1.0-12]
>         at 
> org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:119)
>  [nifi-framework-core-1.1.1.0-12.jar:1.1.1.0-12]
>         at 
> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) 
> [na:1.7.0_79]
>         at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:304) 
> [na:1.7.0_79]
>         at 
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:178)
>  [na:1.7.0_79]
>         at 
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
>  [na:1.7.0_79]
>         at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
>  [na:1.7.0_79]
>         at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
>  [na:1.7.0_79]
>         at java.lang.Thread.run(Thread.java:745) [na:1.7.0_79]
> {quote}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to