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

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

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

Notification.getTimeStamp介绍

暂无

代码示例

代码示例来源: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: apache/geode

notificationSequenceNumber.addAndGet(1L), notification.getTimeStamp(),
notification.getMessage());

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

public String toString(){
 StringBuilder sb = new StringBuilder();
 sb.append("Recorded Notif [ Type ").append(jmxNotificaiton.getType())
 .append(" source : ").append(jmxNotificaiton.getSource())
 .append(" message : ").append(jmxNotificaiton.getMessage())
 .append(" userData : ").append(jmxNotificaiton.getUserData())
 .append(" timestamp : ").append(jmxNotificaiton.getTimeStamp())
 .append(" ]");
 return sb.toString();
}

代码示例来源:origin: jiaqi/jmxterm

@Override
 public void handleNotification(Notification notification, Object handback) {
  Session session = getSession();
  StringBuilder sb = new StringBuilder("notification received: ");
  sb.append("timestamp=").append(notification.getTimeStamp());
  sb.append(",class=").append(notification.getClass().getName());
  sb.append(",source=").append(notification.getSource());
  sb.append(",type=").append(notification.getType());
  sb.append(",message=").append(notification.getMessage());
  session.output.println(sb.toString());
 }
}

代码示例来源:origin: org.cyclopsgroup/jmxterm

@Override
  public void handleNotification(Notification notification, Object handback) {
    Session session = getSession();
    StringBuilder sb = new StringBuilder("notification received: ");
    sb.append("timestamp=").append(notification.getTimeStamp());
    sb.append(",class=").append(notification.getClass().getName());
    sb.append(",source=").append(notification.getSource());
    sb.append(",type=").append(notification.getType());
    sb.append(",message=").append(notification.getMessage());
    session.output.println(sb.toString());
  }
}

代码示例来源: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: 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: 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: org.restcomm.protocols.ss7.tools.simulator/simulator-gui

public void sendNotif(Notification notif) {
  Date d1 = new Date(notif.getTimeStamp());
  String s1 = d1.toLocaleString();
  Vector newRow = new Vector();
  newRow.add(s1);
  newRow.add(notif.getType());
  newRow.add(notif.getMessage());
  newRow.add(notif.getUserData());
  model.getDataVector().add(0, newRow);
  model.newRowsAdded(new TableModelEvent(model));
}

代码示例来源:origin: org.mobicents.protocols.ss7.tools.simulator/simulator-gui

public void sendNotif(Notification notif) {
  Date d1 = new Date(notif.getTimeStamp());
  String s1 = d1.toLocaleString();
  Vector newRow = new Vector();
  newRow.add(s1);
  newRow.add(notif.getType());
  newRow.add(notif.getMessage());
  newRow.add(notif.getUserData());
  model.getDataVector().add(0, newRow);
  model.newRowsAdded(new TableModelEvent(model));
}

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

@Override
public String getTimestampFieldValue() {
  if (hasEventBody()) {
    return String.format("%.3f", getEventBody().getTimeStamp() / 1000.0);
  }
  return super.getTimestampFieldValue();
}

代码示例来源: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-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-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.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: 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.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()));
 }
}

相关文章