本文整理了Java中javax.management.Notification.getTimeStamp()
方法的一些代码示例,展示了Notification.getTimeStamp()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Notification.getTimeStamp()
方法的具体详情如下:
包路径:javax.management.Notification
类名称: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()));
}
}
内容来源于网络,如有侵权,请联系作者删除!