org.apache.qpid.proton.message.Message.getCreationTime()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(6.0k)|赞(0)|评价(0)|浏览(165)

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

Message.getCreationTime介绍

暂无

代码示例

代码示例来源：origin: eclipse/hono

  1. /**
  2.  * Sets the <em>#SYS_PROPERTY_CREATION_TIME</em> of the AMQP 1.0 message to the current timestamp.
  3.  *
  4.  * @param msg the message for that the creation-time property is set.
  5.  */
  6. public static void setCreationTime(final Message msg) {
  7.   if (msg.getCreationTime() == 0) {
  8.     msg.setCreationTime(Instant.now().toEpochMilli());
  9.   }
  10. }

代码示例来源：origin: apache/activemq-artemis

  1. /**
  2. * Gets the absolute expiration time property on the message.
  3. */
  4. public long getCreationTime() {
  5.  return getWrappedMessage().getCreationTime();
  6. }

代码示例来源：origin: org.eclipse.hono/hono-core

  1. /**
  2.  * Sets the <em>#SYS_PROPERTY_CREATION_TIME</em> of the AMQP 1.0 message to the current timestamp.
  3.  *
  4.  * @param msg the message for that the creation-time property is set.
  5.  */
  6. public static void setCreationTime(final Message msg) {
  7.   if (msg.getCreationTime() == 0) {
  8.     msg.setCreationTime(Instant.now().toEpochMilli());
  9.   }
  10. }

代码示例来源：origin: org.eclipse.hono/hono-core

  1. /**
  2.  * Verify if a device is currently connected to a protocol adapter. This is evaluated at the point in time this
  3.  * method is invoked.
  4.  * <p>
  5.  * This could be used as a trigger condition for an attempt to send a command upstream to the device.
  6.  *
  7.  * @param msg Message that is evaluated.
  8.  * @return Boolean {@code true} if the message signals that the device now should be ready to receive a command,
  9.  *         {@code false} otherwise.
  10.  * @throws NullPointerException If msg is {@code null}.
  11.  */
  12. public static Boolean isDeviceCurrentlyConnected(final Message msg) {
  13.   return Optional.ofNullable(MessageHelper.getTimeUntilDisconnect(msg)).map(ttd -> {
  14.     if (ttd == MessageHelper.TTD_VALUE_UNLIMITED) {
  15.       return Boolean.TRUE;
  16.     } else if (ttd == 0) {
  17.       return Boolean.FALSE;
  18.     } else {
  19.       final Instant creationTime = Instant.ofEpochMilli(msg.getCreationTime());
  20.       return Instant.now().isBefore(creationTime.plusSeconds(ttd));
  21.     }
  22.   }).orElse(Boolean.FALSE);
  23. }

代码示例来源：origin: eclipse/hono

  1. /**
  2.  * Verify if a device is currently connected to a protocol adapter. This is evaluated at the point in time this
  3.  * method is invoked.
  4.  * <p>
  5.  * This could be used as a trigger condition for an attempt to send a command upstream to the device.
  6.  *
  7.  * @param msg Message that is evaluated.
  8.  * @return Boolean {@code true} if the message signals that the device now should be ready to receive a command,
  9.  *         {@code false} otherwise.
  10.  * @throws NullPointerException If msg is {@code null}.
  11.  */
  12. public static Boolean isDeviceCurrentlyConnected(final Message msg) {
  13.   return Optional.ofNullable(MessageHelper.getTimeUntilDisconnect(msg)).map(ttd -> {
  14.     if (ttd == MessageHelper.TTD_VALUE_UNLIMITED) {
  15.       return Boolean.TRUE;
  16.     } else if (ttd == 0) {
  17.       return Boolean.FALSE;
  18.     } else {
  19.       final Instant creationTime = Instant.ofEpochMilli(msg.getCreationTime());
  20.       return Instant.now().isBefore(creationTime.plusSeconds(ttd));
  21.     }
  22.   }).orElse(Boolean.FALSE);
  23. }

代码示例来源：origin: org.apache.beam/beam-sdks-java-io-amqp

  1. @Override
  2. public boolean advance() {
  3.  messenger.recv();
  4.  if (messenger.incoming() <= 0) {
  5.   current = null;
  6.   return false;
  7.  }
  8.  Message message = messenger.get();
  9.  Tracker tracker = messenger.incomingTracker();
  10.  checkpointMark.trackers.add(tracker);
  11.  currentTimestamp = new Instant(message.getCreationTime());
  12.  watermark = currentTimestamp;
  13.  current = message;
  14.  return true;
  15. }

代码示例来源：origin: org.eclipse.hono/hono-core

  1. /**
  2.  * Provide an instance of {@link TimeUntilDisconnectNotification} if a message indicates that the device sending it
  3.  * is currently connected to a protocol adapter.
  4.  * <p>
  5.  * If this is not the case, the returned {@link Optional} will be empty.
  6.  *
  7.  * @param msg Message that is evaluated.
  8.  * @return Optional containing an instance of the class {@link TimeUntilDisconnectNotification} if the device is considered
  9.  * being ready to receive an upstream message or is empty otherwise.
  10.  * @throws NullPointerException If msg is {@code null}.
  11.  */
  12. public static Optional<TimeUntilDisconnectNotification> fromMessage(final Message msg) {
  13.   final Integer ttd = MessageHelper.getTimeUntilDisconnect(msg);
  14.   if (ttd == null) {
  15.     return Optional.empty();
  16.   } else if (ttd == 0 || MessageHelper.isDeviceCurrentlyConnected(msg)) {
  17.     final String tenantId = MessageHelper.getTenantIdAnnotation(msg);
  18.     final String deviceId = MessageHelper.getDeviceId(msg);
  19.     if (tenantId != null && deviceId != null) {
  20.       final Instant creationTime = Instant.ofEpochMilli(msg.getCreationTime());
  21.       final TimeUntilDisconnectNotification notification =
  22.           new TimeUntilDisconnectNotification(tenantId, deviceId, ttd,
  23.               getReadyUntilInstantFromTtd(ttd, creationTime), creationTime);
  24.       return Optional.of(notification);
  25.     }
  26.   }
  27.   return Optional.empty();
  28. }

代码示例来源：origin: eclipse/hono

  1. /**
  2.  * Provide an instance of {@link TimeUntilDisconnectNotification} if a message indicates that the device sending it
  3.  * is currently connected to a protocol adapter.
  4.  * <p>
  5.  * If this is not the case, the returned {@link Optional} will be empty.
  6.  *
  7.  * @param msg Message that is evaluated.
  8.  * @return Optional containing an instance of the class {@link TimeUntilDisconnectNotification} if the device is considered
  9.  * being ready to receive an upstream message or is empty otherwise.
  10.  * @throws NullPointerException If msg is {@code null}.
  11.  */
  12. public static Optional<TimeUntilDisconnectNotification> fromMessage(final Message msg) {
  13.   final Integer ttd = MessageHelper.getTimeUntilDisconnect(msg);
  14.   if (ttd == null) {
  15.     return Optional.empty();
  16.   } else if (ttd == 0 || MessageHelper.isDeviceCurrentlyConnected(msg)) {
  17.     final String tenantId = MessageHelper.getTenantIdAnnotation(msg);
  18.     final String deviceId = MessageHelper.getDeviceId(msg);
  19.     if (tenantId != null && deviceId != null) {
  20.       final Instant creationTime = Instant.ofEpochMilli(msg.getCreationTime());
  21.       final TimeUntilDisconnectNotification notification =
  22.           new TimeUntilDisconnectNotification(tenantId, deviceId, ttd,
  23.               getReadyUntilInstantFromTtd(ttd, creationTime), creationTime);
  24.       return Optional.of(notification);
  25.     }
  26.   }
  27.   return Optional.empty();
  28. }

代码示例来源：origin: Azure/azure-event-hubs-java

  1. receiveProperties.put(AmqpConstants.AMQP_PROPERTY_ABSOLUTE_EXPRITY_TIME, amqpMessage.getExpiryTime());
  2. if (amqpMessage.getProperties().getCreationTime() != null)
  3.   receiveProperties.put(AmqpConstants.AMQP_PROPERTY_CREATION_TIME, amqpMessage.getCreationTime());
  4. if (amqpMessage.getGroupId() != null)
  5.   receiveProperties.put(AmqpConstants.AMQP_PROPERTY_GROUP_ID, amqpMessage.getGroupId());

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Message类方法

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