本文整理了Java中io.cattle.platform.eventing.annotation.EventHandler
类的一些代码示例,展示了EventHandler
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。EventHandler
类的具体详情如下:
包路径:io.cattle.platform.eventing.annotation.EventHandler
类名称:EventHandler
暂无
代码示例来源:origin: rancher/cattle
@EventHandler
public void stateChange(Event event);
代码示例来源:origin: rancher/cattle
public static String getEventNameNonProvided(EventHandler handler, AnnotatedEventListener listener, Method method) {
String name = handler.name();
if (StringUtils.isEmpty(name)) {
return NamedUtils.toDotSeparated(method.getName());
} else {
return name;
}
}
代码示例来源:origin: rancher/cattle
public MethodInvokingListener(LockManager lockManager, JsonMapper jsonMapper, EventHandler handler, Method method, Object target) {
super();
this.lockManager = lockManager;
this.jsonMapper = jsonMapper;
this.method = method;
this.target = target;
this.handler = handler;
if (method.getParameterTypes().length > 1) {
throw new IllegalArgumentException("Illegal EventHandler method, must have 0 or 1 arguments [" + method + "]");
} else if (method.getParameterTypes().length == 1) {
targetType = method.getParameterTypes()[0];
if (targetType != Event.class) {
marshall = true;
}
}
if (handler.lock() != LockDefinition.class) {
try {
ctor = handler.lock().getConstructor(Event.class);
} catch (SecurityException e) {
throw new IllegalStateException("Failed to get constructor with Event.class for [" + handler.lock() + "]");
} catch (NoSuchMethodException e) {
throw new IllegalStateException("Failed to get constructor with Event.class for [" + handler.lock() + "]");
}
}
}
代码示例来源:origin: rancher/cattle
protected List<String> getEventNames(EventHandler handler, AnnotatedEventListener listener, Method method) {
Class<? extends EventNameProvider> supplierClass = handler.nameProvider();
if (supplierClass == EventNameProvider.class) {
return Arrays.asList(EventUtils.getEventNameNonProvided(handler, listener, method));
} else {
EventNameProvider supplier = null;
try {
supplier = supplierClass.newInstance();
} catch (InstantiationException e) {
throw new IllegalArgumentException("Failed to instantiate [" + supplierClass + "]", e);
} catch (IllegalAccessException e) {
throw new IllegalArgumentException("Failed to instantiate [" + supplierClass + "]", e);
}
return supplier.events(handler, listener, method);
}
}
代码示例来源:origin: rancher/cattle
@EventHandler
void pingReply(Ping ping);
代码示例来源:origin: rancher/cattle
@EventHandler
void apiChange(Event event);
}
代码示例来源:origin: rancher/cattle
@EventHandler
void serviceUpdate(ConfigUpdate update);
代码示例来源:origin: rancher/cattle
@EventHandler
void serviceUpdate(ConfigUpdate update);
代码示例来源:origin: rancher/cattle
@EventHandler
void hostEndpointsUpdate(ConfigUpdate update);
代码示例来源:origin: rancher/cattle
@EventHandler
public void resourceProgress(Event event);
代码示例来源:origin: rancher/cattle
@EventHandler
void computeInstanceActivateReply(Event event);
代码示例来源:origin: rancher/cattle
@EventHandler
public void serviceEvent(Event event);
代码示例来源:origin: rancher/cattle
@EventHandler(name = EngineEvents.PROCESS_EXECUTE)
void processExecute(Event event);
代码示例来源:origin: rancher/cattle
@EventHandler
void executeTask(ExecuteTask event);
代码示例来源:origin: rancher/cattle
@EventHandler
public void apiChange(Event event);
代码示例来源:origin: rancher/cattle
@EventHandler
public void pingReply(Ping ping) {
processPingReply(ping);
}
代码示例来源:origin: rancher/cattle
@EventHandler(name=IaasEvents.CLEAR_CACHE)
public void clearCache(Event event) {
clear();
}
代码示例来源:origin: rancher/cattle
@EventHandler
public void stateChanged(Event event) {
resourceChange(event);
}
代码示例来源:origin: rancher/cattle
@Override
@EventHandler(name=IaasEvents.INVALIDATE_INSTANCE_DATA_CACHE)
public void clearCacheInstanceData(Event event) {
try {
instanceData.invalidate(Long.parseLong(event.getResourceId()));
} catch (NumberFormatException e) {
log.error("Problem parsing instance id [{}]", event.getResourceId(), e);
}
}
代码示例来源:origin: rancher/cattle
@EventHandler
public void resourceChange(Event event) {
String key = key(event.getResourceType(), event.getResourceId());
Object wait = waiters.get(key);
if (wait != null) {
synchronized (wait) {
wait.notifyAll();
}
}
}
内容来源于网络,如有侵权,请联系作者删除!