Java – severe: unable to schedule event: eventbus com google. common. eventbus. SubscriberExceptionContext
For eventbus, I merged the code in my java spring application and took full control of it, but the result did not change
When I run eventbus in spring STS (javaw), there is no problem, but when I use Java - jar project When jar runs in the server, it gives the same sever: unable to dispatch event: error
There is no work for me below
package edu.uams.event;
import java.awt.EventQueue;
import java.lang.reflect.InvocationTargetException;
import java.util.concurrent.Executor;
import org.apache.log4j.Logger;
import com.google.common.eventbus.AsyncEventBus;
import com.google.common.eventbus.EventHandler;
import com.google.common.eventbus.SubscriberExceptionHandler;
import edu.uams.domain.TirEvent;
import edu.uams.pacs.IncomingFileMonitor;
public class AysncTraumaEventBus extends AsyncEventBus {
private final static Logger logger = Logger.getLogger(AysncTraumaEventBus.class);
private String name = null;
public AysncTraumaEventBus(Executor executor,SubscriberExceptionHandler subscriberExceptionHandler) {
super(executor,subscriberExceptionHandler);
logger.info("AysncTraumaEventBus created.");
}
public AysncTraumaEventBus(String name,Executor executor) {
super(name,executor);
this.name=name;
logger.info("AysncTraumaEventBus created. Name:"+this.name);
}
@Override
public void register(Object object) {
super.register(object);
}
@Override
public void unregister(Object object) {
super.unregister(object);
}
@Override
public void dispatch(Object event,EventHandler wrapper) {
try {
logger.info("Let's dispatch Aysnchroneous Trauma Event:"+ ((TirEvent) event).getResultMessage());
wrapper.handleEvent(event);
} catch (InvocationTargetException e) {
// My logger
logger.error("Could not dispatch event: " + event + " to handler " + wrapper+" e:"+e.getMessage());
logger.info("Lets try to disptach again!");
super.post(new ExceptionEvent(event,e));
}
}
public static final class ExceptionEvent {
public final Object event;
public final InvocationTargetException exception;
public ExceptionEvent(final Object event,final InvocationTargetException exception) {
this.event = event;
this.exception = exception;
}
}
}
Somehow, EventHandler failed to call the target event
wrapper. Handleevent (event);
When you look at the package (EventHandler):
public void handleEvent(Object event) throws InvocationTargetException {
checkNotNull(event);
try {
method.invoke(target,new Object[] { event });
} catch (IllegalArgumentException e) {
throw new Error("Method rejected target/argument: " + event,e);
} catch (illegalaccessexception e) {
throw new Error("Method became inaccessible: " + event,e);
} catch (InvocationTargetException e) {
if (e.getCause() instanceof Error) {
throw (Error) e.getCause();
}
throw e;
}
}
You see that method invoke(target,new Object [] {event}); From method Invocationtargetexception thrown in class
public Object invoke(Object obj,Object... args)
throws illegalaccessexception,IllegalArgumentException,InvocationTargetException
{
if (!override) {
if (!Reflection.quickCheckMemberAccess(clazz,modifiers)) {
Class<?> caller = Reflection.getCallerClass(1);
checkAccess(caller,clazz,obj,modifiers);
}
}
MethodAccessor ma = methodAccessor; // read volatile
if (ma == null) {
ma = acquireMethodAccessor();
}
return ma.invoke(obj,args);
}
Somehow, it can't call But the most interesting part is that the same jar file and eventbus can run well in STS run (javaw), but when I run Java from the command line as Java - jar project Jar, it cannot schedule events
Solution
@Subscribe
@Subscribe
@AllowConcurrentEvents
public void receivedDicomFile(TirEvent event){
try {
} catch (ClassNotFoundException e) {
logger.error(e.getMessage());
} catch (sqlException e) {
logger.error(e.getMessage());
} catch(Exception e){
logger.error(e.getMessage());
}
}
It always needs a try catch Thanks @dwnz for your help
