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);
}
} 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]
