AnsweredAssumed Answered

com.esri.ges.messaging.MessagingException: GeoEvent producer is null

Question asked by raffygim65 on May 10, 2016

hi, all,

 

is there anyone to give me a guide what possibly for me to check to resolve the error the custom Adapter code returns with the following message?

 

In my adapter implemenation,

  public void receive(ByteBuffer buffer, String channelId)

{

       new Thread(new GeoEventProducer(channelId, getMessage(buffer))).start();

}

 

The class of GeoEventProducer is

  private class GeoEventProducer implements Runnable

  {

    private String channelId;

    private byte[] message;

 

 

    public GeoEventProducer(String channelId, byte[] message)

    {

      this.channelId = channelId;

      this.message = message;

    }

 

 

    @Override

    public void run()

    {

  String data;   

  data = new String(message);

  data = "<root>" + data + "</root>";

 

  GeoEvent[] geoEvents = translate(data);

  if (geoEvents != null){

  for (int i=0; i < geoEvents.length; i++){

            geoEventListener.receive(geoEvents[i]);

  }

  } else {

  LOGGER.error("UNS Adapter. No GeoEvent translated.");

  }

    }

   }

 

 

2016-05-10 12:18:47,717 | ERROR |  #13 - Multicast | GeoEventServiceRouteBuilder      | ceRouteBuilder$StreamRefProducer  239 | 245 - com.esri.ges.framework.processing.camel-processing - 10.3.0 | Service '0e121747-1410-4edc-82bf-555d6d97e2e9' failed to send GeoEvent to destination 'c256a35d-2a2c-4127-8c5f-1526b66c8292':

com.esri.ges.messaging.MessagingException: GeoEvent producer is null.

  at com.esri.ges.processing.camel.GeoEventServiceRouteBuilder$StreamRefProducer.send(GeoEventServiceRouteBuilder.java:232)

  at sun.reflect.GeneratedMethodAccessor138.invoke(Unknown Source)

  at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)[:1.7.0_65]

  at java.lang.reflect.Method.invoke(Method.java:606)[:1.7.0_65]

  at org.apache.camel.component.bean.MethodInfo.invoke(MethodInfo.java:407)[165:org.apache.camel.camel-core:2.12.3]

  at org.apache.camel.component.bean.MethodInfo$1.doProceed(MethodInfo.java:278)[165:org.apache.camel.camel-core:2.12.3]

  at org.apache.camel.component.bean.MethodInfo$1.proceed(MethodInfo.java:251)[165:org.apache.camel.camel-core:2.12.3]

  at org.apache.camel.component.bean.BeanProcessor.process(BeanProcessor.java:166)[165:org.apache.camel.camel-core:2.12.3]

  at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:72)[165:org.apache.camel.camel-core:2.12.3]

  at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:398)[165:org.apache.camel.camel-core:2.12.3]

  at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191)[165:org.apache.camel.camel-core:2.12.3]

  at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191)[165:org.apache.camel.camel-core:2.12.3]

  at org.apache.camel.component.direct.DirectProducer.process(DirectProducer.java:51)[165:org.apache.camel.camel-core:2.12.3]

  at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:110)[165:org.apache.camel.camel-core:2.12.3]

  at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:72)[165:org.apache.camel.camel-core:2.12.3]

  at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191)[165:org.apache.camel.camel-core:2.12.3]

  at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:398)[165:org.apache.camel.camel-core:2.12.3]

  at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191)[165:org.apache.camel.camel-core:2.12.3]

  at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:105)[165:org.apache.camel.camel-core:2.12.3]

  at org.apache.camel.processor.MulticastProcessor.doProcessParallel(MulticastProcessor.java:712)[165:org.apache.camel.camel-core:2.12.3]

  at org.apache.camel.processor.MulticastProcessor.access$200(MulticastProcessor.java:83)[165:org.apache.camel.camel-core:2.12.3]

  at org.apache.camel.processor.MulticastProcessor$1.call(MulticastProcessor.java:293)[165:org.apache.camel.camel-core:2.12.3]

  at org.apache.camel.processor.MulticastProcessor$1.call(MulticastProcessor.java:278)[165:org.apache.camel.camel-core:2.12.3]

  at java.util.concurrent.FutureTask.run(FutureTask.java:262)[:1.7.0_65]

  at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)[:1.7.0_65]

  at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)[:1.7.0_65]

  at java.lang.Thread.run(Thread.java:745)[:1.7.0_65]

Outcomes