io.cattle.platform.eventing.annotation.EventHandler类的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(4.0k)|赞(0)|评价(0)|浏览(128)

本文整理了Java中io.cattle.platform.eventing.annotation.EventHandler类的一些代码示例,展示了EventHandler类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。EventHandler类的具体详情如下:
包路径:io.cattle.platform.eventing.annotation.EventHandler
类名称: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();
    }
  }
}

相关文章

EventHandler类方法