javax.jms.Message.getJMSDeliveryTime()方法的使用及代码示例

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

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

Message.getJMSDeliveryTime介绍

[英]Gets the message's delivery time value.

When a message is sent, the JMSDeliveryTime header field is left unassigned. After completion of the send or publish method, it holds the delivery time of the message. This is the the difference, measured in milliseconds, between the delivery time and midnight, January 1, 1970 UTC.

A message's delivery time is the earliest time when a JMS provider may deliver the message to a consumer. The provider must not deliver messages before the delivery time has been reached.
[中]获取消息的传递时间值。
发送消息时,JMSDeliveryTime标头字段将保持未分配状态。发送或发布方法完成后,它保留消息的传递时间。这是交付时间与UTC 1970年1月1日午夜之间的差值,以毫秒为单位。
消息的传递时间是JMS提供者可以向使用者传递消息的最早时间。在到达传递时间之前,提供商不得传递消息。

代码示例

代码示例来源:origin: org.jboss.genericjms/generic-jms-ra-jar

  1. @Override
  2. public long getJMSDeliveryTime() throws JMSException {
  3. return message.getJMSDeliveryTime();
  4. }

代码示例来源:origin: apache/qpid-jms

  1. private static long getForeignMessageDeliveryTime(Message foreignMessage) throws JMSException {
  2. // Verify if the getJMSDeliveryTime method exists, i.e the foreign provider isn't only JMS 1.1.
  3. Method deliveryTimeMethod = null;
  4. try {
  5. Class<?> clazz = foreignMessage.getClass();
  6. Method method = clazz.getMethod("getJMSDeliveryTime", (Class[]) null);
  7. if (!Modifier.isAbstract(method.getModifiers())) {
  8. deliveryTimeMethod = method;
  9. }
  10. } catch (NoSuchMethodException e) {
  11. // Assume its a JMS 1.1 Message, we will return 0.
  12. }
  13. if (deliveryTimeMethod != null) {
  14. // Method exists, isn't abstract, so use it.
  15. return foreignMessage.getJMSDeliveryTime();
  16. }
  17. return 0;
  18. }
  19. }

代码示例来源:origin: org.apache.qpid/qpid-jms-client

  1. private static long getForeignMessageDeliveryTime(Message foreignMessage) throws JMSException {
  2. // Verify if the getJMSDeliveryTime method exists, i.e the foreign provider isn't only JMS 1.1.
  3. Method deliveryTimeMethod = null;
  4. try {
  5. Class<?> clazz = foreignMessage.getClass();
  6. Method method = clazz.getMethod("getJMSDeliveryTime", (Class[]) null);
  7. if (!Modifier.isAbstract(method.getModifiers())) {
  8. deliveryTimeMethod = method;
  9. }
  10. } catch (NoSuchMethodException e) {
  11. // Assume its a JMS 1.1 Message, we will return 0.
  12. }
  13. if (deliveryTimeMethod != null) {
  14. // Method exists, isn't abstract, so use it.
  15. return foreignMessage.getJMSDeliveryTime();
  16. }
  17. return 0;
  18. }
  19. }

代码示例来源:origin: org.apache.activemq/artemis-ra

  1. @Override
  2. public long getJMSDeliveryTime() throws JMSException {
  3. if (ActiveMQRALogger.LOGGER.isTraceEnabled()) {
  4. ActiveMQRALogger.LOGGER.trace("getJMSDeliveryTime()");
  5. }
  6. return message.getJMSDeliveryTime();
  7. }

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

  1. @Override
  2. public long getJMSDeliveryTime() throws JMSException {
  3. if (ActiveMQRALogger.LOGGER.isTraceEnabled()) {
  4. ActiveMQRALogger.LOGGER.trace("getJMSDeliveryTime()");
  5. }
  6. return message.getJMSDeliveryTime();
  7. }

代码示例来源:origin: com.github.jbricks.soap2jms/s2j_common

  1. public WsJmsMessage jmsToSoap(final Message message, final JMSImplementation impl) throws JMSException {
  2. JMSMessageClassEnum messageType = JMSMessageClassEnum.UNSUPPORTED;
  3. for (final Map.Entry<Class<? extends Message>, JMSMessageClassEnum> entry : ENUM_BY_CLASS.entrySet()) {
  4. if (entry.getKey().isInstance(message)) {
  5. messageType = entry.getValue();
  6. }
  7. }
  8. final List<Headers> headers = convertHeaders(message);
  9. String clientId = null;
  10. if (JMSImplementation.ARTEMIS_ACTIVE_MQ.equals(impl)
  11. && message.propertyExists(SoapToJmsSerializer.ACTIVEMQ_DUPLICATE_ID)) {
  12. clientId = message.getStringProperty(SoapToJmsSerializer.ACTIVEMQ_DUPLICATE_ID);
  13. }
  14. final DataHandler bodyStream = extractBody(message, messageType);
  15. final WsJmsMessage wsmessage = new WsJmsMessage(headers, message.getJMSCorrelationID(),
  16. message.getJMSDeliveryMode(), message.getJMSDeliveryTime(), message.getJMSExpiration(), // expiration
  17. message.getJMSMessageID(), message.getJMSPriority(), message.getJMSRedelivered(), //
  18. message.getJMSTimestamp(), message.getJMSType(), //
  19. clientId, messageType.toString(), bodyStream);
  20. return wsmessage;
  21. }

相关文章