本文整理了Java中org.tinygroup.event.Event.setType()方法的一些代码示例，展示了Event.setType()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Event.setType()方法的具体详情如下：
包路径：org.tinygroup.event.Event
类名称：Event
方法名：setType

Event.setType介绍

暂无

代码示例

代码示例来源：origin: org.tinygroup/org.tinygroup.cepcorenettysc

public void exceptionCaught(ChannelHandlerContext ctx, ExceptionEvent e) {
  logger.errorMessage("发生错误", e.getCause());
  for (String key : channelHandlerContextMap.keySet()) {
    if (channelHandlerContextMap.get(key) == ctx) {
      Event event = eventMap.get(key);
      event.setType(Event.EVENT_TYPE_RESPONSE);
      event.setThrowable(e.getCause());
      ctx.getChannel().write(event);
      clearRequest(key);
    }
  }
}

代码示例来源：origin: org.tinygroup/org.tinygroup.cepcoremutiremoteimpl

public void dealNodeUnregToSc(Event event, ChannelHandlerContext ctx) {
  logger.logMessage(LogLevel.INFO, "开始处理节点向服务中心发起的注销请求");
  Context c = event.getServiceRequest().getContext();
  Node remoteNode = c.get(NODE_KEY);
  String nodeString = remoteNode.toString();
  // 从节点缓存中移出当前节点
  Node currentNode = nodes.remove(nodeString);
  nodeServices.remove(nodeString);
  // 从链接缓存中移出当前链接，避免后续循环会向自己发送自己
  ctxs.remove(nodeString);
  // 将该注销消息推送至其它节点
  scUnregCurrentNodeToNodes(nodeString, currentNode);
  // 返回SC上其它的节点信息
  event.setType(Event.EVENT_TYPE_RESPONSE);
  c.put(NODES_KEY, nodes);
  ctx.writeAndFlush(event);
  ctx.close();
  logger.logMessage(LogLevel.INFO, "处理节点向服务中心发起的注销请求完成");
}

代码示例来源：origin: org.tinygroup/org.tinygroup.cepcorenettysc

private Event getAsynchronousResponseEvent(Event event) {
  Event response = new Event();
  response.setEventId(event.getEventId());
  response.setMode(Event.EVENT_MODE_ASYNCHRONOUS);
  response.setType(Event.EVENT_TYPE_RESPONSE);
  return response;
}

代码示例来源：origin: org.tinygroup/org.tinygroup.cepcoremutiremoteimpl

/**
 * 将SC上已有的Node节点信息返写回当前注册的Node节点
 * 
 * @param c
 * @param event
 * @param ctx
 */
private void scRegNodesToCurrentNode(Context c, Event event,
    ChannelHandlerContext ctx, String nodeString) {
  // 将已有节点列表放入上下文，作为结果集回写回注册节点
  logger.logMessage(LogLevel.INFO, "开始将已有节点列表注册至{0}节点", nodeString);
  c.put(SC_TO_NODE_SERVICE_KEY, copy());
  c.put(SC_TO_NODE_SERVICE_VERSION_KEY, versions);
  event.setType(Event.EVENT_TYPE_RESPONSE);
  ctx.writeAndFlush(event);
  logger.logMessage(LogLevel.INFO, "将已有节点列表注册至{0}节点完成", nodeString);
}

代码示例来源：origin: org.tinygroup/org.tinygroup.cepcorenettysc

if (event.getMode() == Event.EVENT_MODE_ASYNCHRONOUS) {
  event.setType(Event.EVENT_TYPE_RESPONSE);
  channelHandlerContext.getChannel().write(
      getAsynchronousResponseEvent(event));
if (event.getMode() == Event.EVENT_MODE_SYNCHRONOUS) {
  if (channelHandlerContext != null) {
    event.setType(Event.EVENT_TYPE_RESPONSE);
    channelHandlerContext.getChannel().write(event);

代码示例来源：origin: org.tinygroup/org.tinygroup.cepcoremutiremoteimpl

if (event.getMode() == Event.EVENT_MODE_ASYNCHRONOUS) {
  event.setType(Event.EVENT_TYPE_RESPONSE);
  ctx.writeAndFlush(event);
} finally {
  if (ctx != null) {
    event.setType(Event.EVENT_TYPE_RESPONSE);
    ctx.writeAndFlush(event);
    logger.logMessage(LogLevel.INFO, "远程请求已写出{0}:{1}", eventId,

代码示例来源：origin: org.tinygroup/org.tinygroup.cepcorenettysc

event.setType(Event.EVENT_TYPE_RESPONSE);
  ctx.getChannel().write(event);
  event.setType(Event.EVENT_TYPE_RESPONSE);
  ctx.getChannel().write(event);
} else {