search

CenturyLinkCloud / mdw

https://centurylinkcloud.github.io/mdw/
MIT License
46 stars 10 forks source link

Content-based event handler registrations with 'Topic' metaInfo are broken #823

Closed donaldoakes closed 4 years ago

donaldoakes commented 4 years ago

A change made for #250 breaks traditional content-based routing whenever the Topic metaInfo field is populated.

        else if (isTopic) {
            bucket = EventHandlerCache.getPathExternalEvents(metaInfo.get(metaInfo.get(Listener.METAINFO_TOPIC)));
        }

Stack trace:

2020-03-24 23:15:04.110 ERROR [Camel (BusInvoc78) thread #0 - Threads]: Exception in ListenerHelper.processEvent()
java.lang.NullPointerException
        at com.centurylink.mdw.service.data.event.EventHandlerCache.getPathExternalEvents(EventHandlerCache.java:81)
        at com.centurylink.mdw.listener.ListenerHelper.findEventHandler(ListenerHelper.java:117)
        at com.centurylink.mdw.listener.ListenerHelper.processEvent(ListenerHelper.java:393)
        at com.centurylink.mdw.tibco.MDWBusListener.process(MDWBusListener.java:35)
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at java.lang.reflect.Method.invoke(Method.java:498)
        at org.apache.camel.component.bean.MethodInfo.invoke(MethodInfo.java:458)
        at org.apache.camel.component.bean.MethodInfo$1.doProceed(MethodInfo.java:289)
        at org.apache.camel.component.bean.MethodInfo$1.proceed(MethodInfo.java:262)
        at org.apache.camel.component.bean.BeanProcessor.process(BeanProcessor.java:178)
        at org.apache.camel.component.bean.BeanProducer.process(BeanProducer.java:41)
        at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:145)
        at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:77)
        at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:542)
        at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:197)
        at org.apache.camel.processor.Pipeline.process(Pipeline.java:120)
        at org.apache.camel.processor.Pipeline.access$100(Pipeline.java:44)
        at org.apache.camel.processor.Pipeline$1.done(Pipeline.java:138)
        at org.apache.camel.processor.ThreadsProcessor$ProcessCall.run(ThreadsProcessor.java:88)
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
        at java.util.concurrent.FutureTask.run(FutureTask.java:266)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
        at java.lang.Thread.run(Thread.java:748)