in dosgi/src/main/java/org/apache/karaf/cellar/dosgi/RemoteServiceCallHandler.java [58:113]
public void handle(RemoteServiceCall event) {
// check if the handler switch is ON
if (this.getSwitch().getStatus().equals(SwitchStatus.OFF)) {
LOGGER.debug("CELLAR DOSGI: {} switch is OFF, cluster event is not handled", SWITCH_ID);
return;
}
Object targetService = null;
if (event != null) {
ServiceReference[] serviceReferences = null;
try {
serviceReferences = bundleContext.getServiceReferences(event.getServiceClass(), null);
if (serviceReferences != null && serviceReferences.length > 0) {
targetService = bundleContext.getService(serviceReferences[0]);
bundleContext.ungetService(serviceReferences[0]);
}
} catch (InvalidSyntaxException e) {
LOGGER.error("CELLAR DOSGI: failed to lookup service", e);
}
if (targetService != null) {
Class[] classes = new Class[0];
if (event.getArguments() != null && event.getArguments().size() > 0) {
classes = new Class[event.getArguments().size()];
int i = 0;
for (Object obj : event.getArguments()) {
classes[i++] = obj.getClass();
}
}
RemoteServiceResult result = new RemoteServiceResult(event.getId());
EventProducer producer = eventTransportFactory.getEventProducer(Constants.RESULT_PREFIX + Constants.SEPARATOR + event.getSourceNode().getId() + event.getEndpointId(), false);
try {
Method method = getMethod(classes, targetService, event);
Object obj = method.invoke(targetService, event.getArguments().toArray());
result.setResult(obj);
producer.produce(result);
} catch (NoSuchMethodException e) {
LOGGER.error("CELLAR DOSGI: unable to find remote method for service", e);
result.setResult(new RemoteServiceInvocationException(e));
producer.produce(result);
} catch (InvocationTargetException e) {
LOGGER.error("CELLAR DOSGI: unable to invoke remote method for service", e);
result.setResult(new RemoteServiceInvocationException(e.getCause()));
producer.produce(result);
} catch (IllegalAccessException e) {
LOGGER.error("CELLAR DOSGI: unable to access remote method for service", e);
result.setResult(new RemoteServiceInvocationException(e));
producer.produce(result);
}
}
}
}