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

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

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

Message.setJMSRedelivered介绍

[英]Specifies whether this message is being redelivered.

This method is for use by JMS providers only to set this field when a message is delivered. This message cannot be used by clients to configure the redelivered status of the message. This method is public to allow a JMS provider to set this field when sending a message whose implementation is not its own.
[中]指定是否重新传递此邮件。
此方法仅用于JMS提供程序在传递消息时设置此字段。客户端无法使用此消息配置消息的重新传递状态。此方法是公共的，允许JMS提供程序在发送非其自身实现的消息时设置此字段。

代码示例

代码示例来源：origin: apache/nifi

  1. message.setJMSPriority(Integer.parseInt(entry.getValue()));
  2. } else if (entry.getKey().equals(JmsHeaders.REDELIVERED)) {
  3.   message.setJMSRedelivered(Boolean.parseBoolean(entry.getValue()));
  4. } else if (entry.getKey().equals(JmsHeaders.TIMESTAMP)) {
  5.   message.setJMSTimestamp(Long.parseLong(entry.getValue()));

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

  1. /**
  2.    * Copies the standard JMS and user defined properties from the givem
  3.    * message to the specified message
  4.    *
  5.    * @param fromMessage the message to take the properties from
  6.    * @param toMessage the message to add the properties to
  7.    * @throws JMSException
  8.    */
  9.   public static void copyProperties(Message fromMessage, Message toMessage) throws JMSException {
  10.     toMessage.setJMSMessageID(fromMessage.getJMSMessageID());
  11.     toMessage.setJMSCorrelationID(fromMessage.getJMSCorrelationID());
  12.     toMessage.setJMSReplyTo(transformDestination(fromMessage.getJMSReplyTo()));
  13.     toMessage.setJMSDestination(transformDestination(fromMessage.getJMSDestination()));
  14.     toMessage.setJMSDeliveryMode(fromMessage.getJMSDeliveryMode());
  15.     toMessage.setJMSRedelivered(fromMessage.getJMSRedelivered());
  16.     toMessage.setJMSType(fromMessage.getJMSType());
  17.     toMessage.setJMSExpiration(fromMessage.getJMSExpiration());
  18.     toMessage.setJMSPriority(fromMessage.getJMSPriority());
  19.     toMessage.setJMSTimestamp(fromMessage.getJMSTimestamp());
  21.     Enumeration propertyNames = fromMessage.getPropertyNames();
  23.     while (propertyNames.hasMoreElements()) {
  24.       String name = propertyNames.nextElement().toString();
  25.       Object obj = fromMessage.getObjectProperty(name);
  26.       toMessage.setObjectProperty(name, obj);
  27.     }
  28.   }
  29. }

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

  1. message.setJMSRedelivered(false);

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

  1. public void setJMSRedelivered(boolean redelivered) throws JMSException
  2. {
  3.  message.setJMSRedelivered(redelivered);
  4. }

代码示例来源：origin: org.apache.tomee/openejb-core

  1. @Override
  2. public void setJMSRedelivered(final boolean redelivered) throws JMSException {
  3.   message.setJMSRedelivered(redelivered);
  4. }

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

  1. public void setJMSRedelivered(boolean redelivered) throws JMSException {
  2.   message.setJMSRedelivered(redelivered);
  3. }

代码示例来源：origin: org.apache.qpid/qpid-jca

  1. /**
  2. * Set redelivered status
  3. * @param redelivered The value
  4. * @exception JMSException Thrown if an error occurs
  5. */
  6. public void setJMSRedelivered(final boolean redelivered) throws JMSException
  7. {
  8.  if (_log.isTraceEnabled())
  9.  {
  10.    _log.trace("setJMSRedelivered(" + redelivered + ")");
  11.  }
  12.  _message.setJMSRedelivered(redelivered);
  13. }

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

  1. /**
  2. * Set redelivered status
  3. *
  4. * @param redelivered The value
  5. * @throws JMSException Thrown if an error occurs
  6. */
  7. @Override
  8. public void setJMSRedelivered(final boolean redelivered) throws JMSException {
  9.  if (ActiveMQRALogger.LOGGER.isTraceEnabled()) {
  10.    ActiveMQRALogger.LOGGER.trace("setJMSRedelivered(" + redelivered + ")");
  11.  }
  12.  message.setJMSRedelivered(redelivered);
  13. }

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

  1. /**
  2. * Set redelivered status
  3. *
  4. * @param redelivered The value
  5. * @throws JMSException Thrown if an error occurs
  6. */
  7. @Override
  8. public void setJMSRedelivered(final boolean redelivered) throws JMSException {
  9.  if (ActiveMQRALogger.LOGGER.isTraceEnabled()) {
  10.    ActiveMQRALogger.LOGGER.trace("setJMSRedelivered(" + redelivered + ")");
  11.  }
  12.  message.setJMSRedelivered(redelivered);
  13. }

代码示例来源：origin: org.apache.nifi/nifi-jms-processors

  1. message.setJMSPriority(Integer.parseInt(entry.getValue()));
  2. } else if (entry.getKey().equals(JmsHeaders.REDELIVERED)) {
  3.   message.setJMSRedelivered(Boolean.parseBoolean(entry.getValue()));
  4. } else if (entry.getKey().equals(JmsHeaders.TIMESTAMP)) {
  5.   message.setJMSTimestamp(Long.parseLong(entry.getValue()));

代码示例来源：origin: jboss-switchyard/components

  1. message.setJMSType(value.toString());
  2. } else if (name.equals(HEADER_JMS_REDELIVERED)) {
  3.   message.setJMSRedelivered(Boolean.parseBoolean(value.toString()));

代码示例来源：origin: com.github.fridujo/spring-automocker

  1. public Message toMessage(Session session) throws JMSException {
  2.   Message message = toMessageInternal(session);
  3.   if (messageId != null)
  4.     message.setJMSMessageID(messageId);
  5.   if (timestamp != null)
  6.     message.setJMSTimestamp(timestamp);
  7.   if (correlationId != null)
  8.     message.setJMSCorrelationID(correlationId);
  9.   if (replyTo != null)
  10.     message.setJMSReplyTo(session.createQueue(replyTo));
  11.   if (deliveryMode != null)
  12.     message.setJMSDeliveryMode(deliveryMode);
  13.   if (redelivered != null)
  14.     message.setJMSRedelivered(redelivered);
  15.   if (type != null)
  16.     message.setJMSType(type);
  17.   if (expiration != null)
  18.     message.setJMSExpiration(expiration);
  19.   if (priority != null)
  20.     message.setJMSPriority(priority);
  21.   properties.entrySet()
  22.     .forEach(ThrowingConsumer.silent(e -> message.setObjectProperty(e.getKey(), e.getValue())));
  23.   return message;
  24. }

代码示例来源：origin: org.apache.activemq/activemq-client

  1. /**
  2.    * Copies the standard JMS and user defined properties from the givem
  3.    * message to the specified message
  4.    *
  5.    * @param fromMessage the message to take the properties from
  6.    * @param toMessage the message to add the properties to
  7.    * @throws JMSException
  8.    */
  9.   public static void copyProperties(Message fromMessage, Message toMessage) throws JMSException {
  10.     toMessage.setJMSMessageID(fromMessage.getJMSMessageID());
  11.     toMessage.setJMSCorrelationID(fromMessage.getJMSCorrelationID());
  12.     toMessage.setJMSReplyTo(transformDestination(fromMessage.getJMSReplyTo()));
  13.     toMessage.setJMSDestination(transformDestination(fromMessage.getJMSDestination()));
  14.     toMessage.setJMSDeliveryMode(fromMessage.getJMSDeliveryMode());
  15.     toMessage.setJMSRedelivered(fromMessage.getJMSRedelivered());
  16.     toMessage.setJMSType(fromMessage.getJMSType());
  17.     toMessage.setJMSExpiration(fromMessage.getJMSExpiration());
  18.     toMessage.setJMSPriority(fromMessage.getJMSPriority());
  19.     toMessage.setJMSTimestamp(fromMessage.getJMSTimestamp());
  21.     Enumeration propertyNames = fromMessage.getPropertyNames();
  23.     while (propertyNames.hasMoreElements()) {
  24.       String name = propertyNames.nextElement().toString();
  25.       Object obj = fromMessage.getObjectProperty(name);
  26.       toMessage.setObjectProperty(name, obj);
  27.     }
  28.   }
  29. }

代码示例来源：origin: org.fusesource.stompjms/stompjms-client

  1. /**
  2.    * Copies the standard JMS and user defined properties from the givem
  3.    * message to the specified message
  4.    *
  5.    * @param fromMessage the message to take the properties from
  6.    * @param toMessage   the message to add the properties to
  7.    * @throws JMSException
  8.    */
  9.   public static void copyProperties(StompJmsConnection connection, Message fromMessage, Message toMessage) throws JMSException {
  10.     toMessage.setJMSMessageID(fromMessage.getJMSMessageID());
  11.     toMessage.setJMSCorrelationID(fromMessage.getJMSCorrelationID());
  12.     toMessage.setJMSReplyTo(transformDestination(connection, fromMessage.getJMSReplyTo()));
  13.     toMessage.setJMSDestination(transformDestination(connection, fromMessage.getJMSDestination()));
  14.     toMessage.setJMSDeliveryMode(fromMessage.getJMSDeliveryMode());
  15.     toMessage.setJMSRedelivered(fromMessage.getJMSRedelivered());
  16.     toMessage.setJMSType(fromMessage.getJMSType());
  17.     toMessage.setJMSExpiration(fromMessage.getJMSExpiration());
  18.     toMessage.setJMSPriority(fromMessage.getJMSPriority());
  19.     toMessage.setJMSTimestamp(fromMessage.getJMSTimestamp());
  21.     Enumeration propertyNames = fromMessage.getPropertyNames();
  23.     while (propertyNames.hasMoreElements()) {
  24.       String name = propertyNames.nextElement().toString();
  25.       Object obj = fromMessage.getObjectProperty(name);
  26.       toMessage.setObjectProperty(name, obj);
  27.     }
  28.   }
  29. }

代码示例来源：origin: org.apache.activemq/activemq-all

  1. /**
  2.    * Copies the standard JMS and user defined properties from the givem
  3.    * message to the specified message
  4.    *
  5.    * @param fromMessage the message to take the properties from
  6.    * @param toMessage the message to add the properties to
  7.    * @throws JMSException
  8.    */
  9.   public static void copyProperties(Message fromMessage, Message toMessage) throws JMSException {
  10.     toMessage.setJMSMessageID(fromMessage.getJMSMessageID());
  11.     toMessage.setJMSCorrelationID(fromMessage.getJMSCorrelationID());
  12.     toMessage.setJMSReplyTo(transformDestination(fromMessage.getJMSReplyTo()));
  13.     toMessage.setJMSDestination(transformDestination(fromMessage.getJMSDestination()));
  14.     toMessage.setJMSDeliveryMode(fromMessage.getJMSDeliveryMode());
  15.     toMessage.setJMSRedelivered(fromMessage.getJMSRedelivered());
  16.     toMessage.setJMSType(fromMessage.getJMSType());
  17.     toMessage.setJMSExpiration(fromMessage.getJMSExpiration());
  18.     toMessage.setJMSPriority(fromMessage.getJMSPriority());
  19.     toMessage.setJMSTimestamp(fromMessage.getJMSTimestamp());
  21.     Enumeration propertyNames = fromMessage.getPropertyNames();
  23.     while (propertyNames.hasMoreElements()) {
  24.       String name = propertyNames.nextElement().toString();
  25.       Object obj = fromMessage.getObjectProperty(name);
  26.       toMessage.setObjectProperty(name, obj);
  27.     }
  28.   }
  29. }

代码示例来源：origin: fusesource/stompjms

  1. /**
  2.    * Copies the standard JMS and user defined properties from the givem
  3.    * message to the specified message
  4.    *
  5.    * @param fromMessage the message to take the properties from
  6.    * @param toMessage   the message to add the properties to
  7.    * @throws JMSException
  8.    */
  9.   public static void copyProperties(StompJmsConnection connection, Message fromMessage, Message toMessage) throws JMSException {
  10.     toMessage.setJMSMessageID(fromMessage.getJMSMessageID());
  11.     toMessage.setJMSCorrelationID(fromMessage.getJMSCorrelationID());
  12.     toMessage.setJMSReplyTo(transformDestination(connection, fromMessage.getJMSReplyTo()));
  13.     toMessage.setJMSDestination(transformDestination(connection, fromMessage.getJMSDestination()));
  14.     toMessage.setJMSDeliveryMode(fromMessage.getJMSDeliveryMode());
  15.     toMessage.setJMSRedelivered(fromMessage.getJMSRedelivered());
  16.     toMessage.setJMSType(fromMessage.getJMSType());
  17.     toMessage.setJMSExpiration(fromMessage.getJMSExpiration());
  18.     toMessage.setJMSPriority(fromMessage.getJMSPriority());
  19.     toMessage.setJMSTimestamp(fromMessage.getJMSTimestamp());
  21.     Enumeration propertyNames = fromMessage.getPropertyNames();
  23.     while (propertyNames.hasMoreElements()) {
  24.       String name = propertyNames.nextElement().toString();
  25.       Object obj = fromMessage.getObjectProperty(name);
  26.       toMessage.setObjectProperty(name, obj);
  27.     }
  28.   }
  29. }

代码示例来源：origin: org.apache.activemq/activemq-osgi

  1. /**
  2.    * Copies the standard JMS and user defined properties from the givem
  3.    * message to the specified message
  4.    *
  5.    * @param fromMessage the message to take the properties from
  6.    * @param toMessage the message to add the properties to
  7.    * @throws JMSException
  8.    */
  9.   public static void copyProperties(Message fromMessage, Message toMessage) throws JMSException {
  10.     toMessage.setJMSMessageID(fromMessage.getJMSMessageID());
  11.     toMessage.setJMSCorrelationID(fromMessage.getJMSCorrelationID());
  12.     toMessage.setJMSReplyTo(transformDestination(fromMessage.getJMSReplyTo()));
  13.     toMessage.setJMSDestination(transformDestination(fromMessage.getJMSDestination()));
  14.     toMessage.setJMSDeliveryMode(fromMessage.getJMSDeliveryMode());
  15.     toMessage.setJMSRedelivered(fromMessage.getJMSRedelivered());
  16.     toMessage.setJMSType(fromMessage.getJMSType());
  17.     toMessage.setJMSExpiration(fromMessage.getJMSExpiration());
  18.     toMessage.setJMSPriority(fromMessage.getJMSPriority());
  19.     toMessage.setJMSTimestamp(fromMessage.getJMSTimestamp());
  21.     Enumeration propertyNames = fromMessage.getPropertyNames();
  23.     while (propertyNames.hasMoreElements()) {
  24.       String name = propertyNames.nextElement().toString();
  25.       Object obj = fromMessage.getObjectProperty(name);
  26.       toMessage.setObjectProperty(name, obj);
  27.     }
  28.   }
  29. }

代码示例来源：origin: pierre/meteo

  1. /**
  2.    * Copies the standard JMS and user defined properties from the givem
  3.    * message to the specified message
  4.    * 
  5.    * @param fromMessage the message to take the properties from
  6.    * @param toMessage the message to add the properties to
  7.    * @throws JMSException
  8.    */
  9.   public static void copyProperties(Message fromMessage, Message toMessage) throws JMSException {
  10.     toMessage.setJMSMessageID(fromMessage.getJMSMessageID());
  11.     toMessage.setJMSCorrelationID(fromMessage.getJMSCorrelationID());
  12.     toMessage.setJMSReplyTo(transformDestination(fromMessage.getJMSReplyTo()));
  13.     toMessage.setJMSDestination(transformDestination(fromMessage.getJMSDestination()));
  14.     toMessage.setJMSDeliveryMode(fromMessage.getJMSDeliveryMode());
  15.     toMessage.setJMSRedelivered(fromMessage.getJMSRedelivered());
  16.     toMessage.setJMSType(fromMessage.getJMSType());
  17.     toMessage.setJMSExpiration(fromMessage.getJMSExpiration());
  18.     toMessage.setJMSPriority(fromMessage.getJMSPriority());
  19.     toMessage.setJMSTimestamp(fromMessage.getJMSTimestamp());
  21.     Enumeration propertyNames = fromMessage.getPropertyNames();
  23.     while (propertyNames.hasMoreElements()) {
  24.       String name = propertyNames.nextElement().toString();
  25.       Object obj = fromMessage.getObjectProperty(name);
  26.       toMessage.setObjectProperty(name, obj);
  27.     }
  28.   }
  29. }

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

  1. message.setJMSExpiration(wsMessage.getJmsExpiration());
  2. message.setJMSPriority(wsMessage.getJmsPriority());
  3. message.setJMSRedelivered(wsMessage.isJmsRedelivered());
  4. message.setJMSTimestamp(wsMessage.getJmsTimestamp());
  5. message.setJMSType(wsMessage.getJmsType());

代码示例来源：origin: timewalker74/ffmq

  1. dstMessage.setJMSMessageID(srcMessage.getJMSMessageID());
  2. dstMessage.setJMSPriority(srcMessage.getJMSPriority());
  3. dstMessage.setJMSRedelivered(srcMessage.getJMSRedelivered());

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Message类方法

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