javax.management.Notification.getSequenceNumber()方法的使用及代码示例

x33g5p2x  于2022-01-24 转载在 其他  
字(10.8k)|赞(0)|评价(0)|浏览(67)

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

Notification.getSequenceNumber介绍

暂无

代码示例

代码示例来源：origin: groovy/groovy-core

private static Map buildOperationNotificationPacket(Notification note) {
    Map<String, Object> result = new HashMap<String, Object>();
    result.put("event", note.getType());
    result.put("source", note.getSource());
    result.put("sequenceNumber", note.getSequenceNumber());
    result.put("timeStamp", note.getTimeStamp());
    result.put("data", note.getUserData());
    return result;
  }
}

代码示例来源：origin: org.kohsuke.droovy/groovy

private static Map buildOperationNotificationPacket(Notification note) {
    Map<String, Object> result = new HashMap<String, Object>();
    result.put("event", note.getType());
    result.put("source", note.getSource());
    result.put("sequenceNumber", note.getSequenceNumber());
    result.put("timeStamp", note.getTimeStamp());
    result.put("data", note.getUserData());
    return result;
  }
}

代码示例来源：origin: org.codehaus.groovy/groovy-jmx

private static Map buildOperationNotificationPacket(Notification note) {
    Map<String, Object> result = new HashMap<String, Object>();
    result.put("event", note.getType());
    result.put("source", note.getSource());
    result.put("sequenceNumber", note.getSequenceNumber());
    result.put("timeStamp", note.getTimeStamp());
    result.put("data", note.getUserData());
    return result;
  }
}

代码示例来源：origin: org.codehaus.groovy/groovy-jdk14

private static Map buildOperationNotificationPacket(Notification note) {
    Map<String, Object> result = new HashMap<String, Object>();
    result.put("event", note.getType());
    result.put("source", note.getSource());
    result.put("sequenceNumber", note.getSequenceNumber());
    result.put("timeStamp", note.getTimeStamp());
    result.put("data", note.getUserData());
    return result;
  }
}

代码示例来源：origin: com.thinkaurelius.groovy-shaded-asm/groovy-shaded-asm

private static Map buildOperationNotificationPacket(Notification note) {
    Map<String, Object> result = new HashMap<String, Object>();
    result.put("event", note.getType());
    result.put("source", note.getSource());
    result.put("sequenceNumber", note.getSequenceNumber());
    result.put("timeStamp", note.getTimeStamp());
    result.put("data", note.getUserData());
    return result;
  }
}

代码示例来源：origin: io.snappydata/gemfire-hydra-tests

private void printJMXNotification(Notification notification, Object handback) {
 StringBuilder sb = new StringBuilder();
 sb.append("JMXNotificationListener(" + prefix + ") : Notification [ type=").append(notification.getType()).append(", message=")
   .append(notification.getMessage())
   .append(", source=").append(notification.getSource())
   .append(", seqNo=").append(notification.getSequenceNumber())
   .append(", timestamp=").append(notification.getTimeStamp())
   .append(", data=").append(ObjectToString(notification.getUserData()))
   .append(", handbackObject=").append(ObjectToString(handback)).append(" ]");
 logInfo(sb.toString());
}

代码示例来源：origin: org.wso2.es/org.wso2.es.integration.common.utils

public void handleNotification(Notification ntfyObj, Object handback) {
  log.info("***************************************************");
  log.info("* Notification received at " + new Date().toString());
  log.info("* type      = " + ntfyObj.getType());
  log.info("* message   = " + ntfyObj.getMessage());
  if (ntfyObj.getMessage().contains(path)) {
    setSuccess(true);
  }
  log.info("* seqNum    = " + ntfyObj.getSequenceNumber());
  log.info("* source    = " + ntfyObj.getSource());
  log.info("* seqNum    = " + Long.toString(ntfyObj.getSequenceNumber()));
  log.info("* timeStamp = " + new Date(ntfyObj.getTimeStamp()));
  log.info("* userData  = " + ntfyObj.getUserData());
  log.info("***************************************************");
}

代码示例来源：origin: com.technophobia.substeps/substeps-maven-plugin

public void handleNotification(Notification notification, Object handback) {
  if (notification.getType().compareTo("ExNode")==0) {
    byte[] rawBytes = (byte[])notification.getUserData();
    ExecutionNodeResult result = getFromBytes(rawBytes);
    this.log.debug("received a JMX event msg: " + notification.getMessage() + " seq: " + notification.getSequenceNumber() + " exec result node id: " + result.getExecutionNodeId());
//        notificiationHandler.handleNotification(result);
  }
  else if (notification.getType().compareTo("ExecConfigComplete")==0) {
//        notificiationHandler.handleCompleteMessage();
  }
  else {
    log.error("unknown notificaion type");
  }
}

代码示例来源：origin: org.mobicents.tools.snmp.adaptor/core

@Override
public void sendJMXNotification(Notification notification) {
  if(notification.getSequenceNumber() <= 0) {
    notification.setSequenceNumber(getNextNotificationSequenceNumber());
  }
  try {
    this.trapEmitter.send(notification);           
  } catch (Exception e) {
     log.error("Problem occured while Sending trap", e);
  }           
}

代码示例来源：origin: org.jboss.jbossas/jboss-snmp

@Override
public void sendJMXNotification(Notification notification) {
  if(notification.getSequenceNumber() <= 0) {
    notification.setSequenceNumber(getNextNotificationSequenceNumber());
  }
  try {
    this.trapEmitter.send(notification);           
  } catch (Exception e) {
     log.error("Problem occured while Sending trap", e);
  }           
}

代码示例来源：origin: org.mobicents.tools.snmp.adaptor/core

/**
* All notifications are intercepted here and are routed for emission.
*/
public void handleNotification2(Notification n, Object handback)
{
 if (log.isDebugEnabled()) {
   log.debug("Received notification: <" + n + "> Payload " +
        "TS: <" + n.getTimeStamp() + "> " +
        "SN: <" + n.getSequenceNumber() + "> " +
        "T:  <" + n.getType() + ">");
 }
 
 try {
   this.trapEmitter.send(n);           
 }
 catch (Exception e) {
   log.error("Sending trap", e);
 }    
}

代码示例来源：origin: org.jboss.jbossas/jboss-snmp

/**
* All notifications are intercepted here and are routed for emission.
*/
public void handleNotification2(Notification n, Object handback)
{
 if (log.isDebugEnabled()) {
   log.debug("Received notification: <" + n + "> Payload " +
        "TS: <" + n.getTimeStamp() + "> " +
        "SN: <" + n.getSequenceNumber() + "> " +
        "T:  <" + n.getType() + ">");
 }
 
 try {
   this.trapEmitter.send(n);           
 }
 catch (Exception e) {
   log.error("Sending trap", e);
 }    
}

代码示例来源：origin: org.terracotta/terracotta-l1-ee

public void broadcastLogEvent(final String event, final String[] throwableStringRep) {
 Notification notif = new Notification(LOGGING_EVENT_TYPE, this, sequenceNumber.incrementAndGet(),
                       System.currentTimeMillis(), event);
 notif.setUserData(throwableStringRep);
 sendNotification(notif);
 notif = new Notification(notif.getType(), getClass().getName(), notif.getSequenceNumber(), notif.getTimeStamp(),
              notif.getMessage());
 notif.setUserData(throwableStringRep);
 tcLoggingHistoryProvider.push(notif);
}

代码示例来源：origin: org.terracotta/terracotta-l1

public void broadcastLogEvent(final String event, final String[] throwableStringRep) {
 Notification notif = new Notification(LOGGING_EVENT_TYPE, this, sequenceNumber.incrementAndGet(),
                       System.currentTimeMillis(), event);
 notif.setUserData(throwableStringRep);
 sendNotification(notif);
 notif = new Notification(notif.getType(), getClass().getName(), notif.getSequenceNumber(), notif.getTimeStamp(),
              notif.getMessage());
 notif.setUserData(throwableStringRep);
 tcLoggingHistoryProvider.push(notif);
}

代码示例来源：origin: org.terracotta/terracotta-ee

public void broadcastLogEvent(final String event, final String[] throwableStringRep) {
 Notification notif = new Notification(LOGGING_EVENT_TYPE, this, sequenceNumber.incrementAndGet(),
                       System.currentTimeMillis(), event);
 notif.setUserData(throwableStringRep);
 sendNotification(notif);
 notif = new Notification(notif.getType(), getClass().getName(), notif.getSequenceNumber(), notif.getTimeStamp(),
              notif.getMessage());
 notif.setUserData(throwableStringRep);
 tcLoggingHistoryProvider.push(notif);
}

代码示例来源：origin: mx4j/mx4j-tools

protected void onSerialize(SerializationContext context, Notification notification) throws IOException
{
 context.serialize(CLASS_NAME_QNAME, null, notification.getType());
 context.serialize(SOURCE_QNAME, null, notification.getSource());
 context.serialize(SEQUENCE_NUMBER_QNAME, null, new Long(notification.getSequenceNumber()));
 context.serialize(TIMESTAMP_QNAME, null, new Long(notification.getTimeStamp()));
 context.serialize(MESSAGE_QNAME, null, notification.getMessage());
 context.serialize(USER_DATA_QNAME, null, notification.getUserData());
}

代码示例来源：origin: org.apache.brooklyn/brooklyn-software-base

private void assertNotificationsEqual(Notification n1, Notification n2) {
    assertEquals(n1.getType(), n2.getType());
    assertEquals(n1.getSequenceNumber(), n2.getSequenceNumber());
    assertEquals(n1.getUserData(), n2.getUserData());
    assertEquals(n1.getTimeStamp(), n2.getTimeStamp());
    assertEquals(n1.getMessage(), n2.getMessage());
  }
}

代码示例来源：origin: com.github.hqstevenson.splunk/splunk.jmx

@Override
protected void addAdditionalFieldsToMap(EventCollectorClient client, Map<String, Object> map) {
  super.addAdditionalFieldsToMap(client, map);
  if (includeNotificationType) {
    map.put(NOTIFICATION_TYPE_KEY, getEventBody().getType());
  }
  if (includeNotificationMessage) {
    addField(NOTIFICATION_MESSAGE_KEY, getEventBody().getMessage());
  }
  if (includeNotificationSequenceNumber) {
    addField(NOTIFICATION_SEQUENCE_NUMBER_KEY, Long.toString(getEventBody().getSequenceNumber()));
  }
  if (includeNotificationSource) {
    addField(NOTIFICATION_SOURCE_KEY, getEventBody().getSource().toString());
  }
}

代码示例来源：origin: org.jppf/jppf-server

@Override
 public synchronized void notificationReceived(final ForwardingNotificationEvent event) {
  final Notification notif = event.getNotification();
  if (debugEnabled) log.debug("received notification from node={}, mbean={}, notification={} (sequence={}, timestamp={})",
   event.getNodeUuid(), event.getMBeanName(), notif, notif.getSequenceNumber(), notif.getTimeStamp());
  forwarder.sendNotification(new JPPFNodeForwardingNotification(notif, event.getNodeUuid(), event.getMBeanName()));
 }
}

代码示例来源：origin: io.snamp/json-helpers

@Override
  public void serialize(final Notification src, final JsonGenerator jgen, final SerializerProvider provider) throws IOException {
    final ObjectNode node = ThreadLocalJsonFactory.getFactory().objectNode();
    node.put(SOURCE, ThreadLocalJsonFactory.getFactory().textNode(src.getSource().toString()));
    node.put(NOTIF_TYPE, src.getType());
    node.put(SEQUENCE_NUMBER, src.getSequenceNumber());
    if (timeStampAsString)
      node.put(TIME_STAMP, ThreadLocalJsonFactory.toValueNode(new Date(src.getTimeStamp())));
    else
      node.put(TIME_STAMP, src.getTimeStamp());
    node.put(MESSAGE, src.getMessage());
    node.put(USER_DATA, ThreadLocalJsonFactory.toValueNode(src.getUserData()));
    node.serialize(jgen, provider);
  }
}

内容来源于网络，如有侵权，请联系作者删除！

Notification

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com