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

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

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

Message.getJMSRedelivered介绍

[英]Gets an indication of whether this message is being redelivered.

If a client receives a message with the JMSRedelivered field set, it is likely, but not guaranteed, that this message was delivered earlier but that its receipt was not acknowledged at that time.
[中]获取是否重新传递此消息的指示。
如果客户机接收到设置了JMSRedelived字段的消息，则很可能（但不能保证）该消息是在较早的时候传递的，但当时没有确认其接收。

代码示例

代码示例来源：origin: spring-projects/spring-batch

  1. /**
  2.  * If any of the arguments is a message, check the JMS re-delivered flag and
  3.  * return it, otherwise return false to be on the safe side.
  4.  * 
  5.  * @see org.springframework.retry.interceptor.NewMethodArgumentsIdentifier#isNew(java.lang.Object[])
  6.  */
  7. @Override
  8. public boolean isNew(Object[] args) {
  9.   for (Object item : args) {
  10.     if (item instanceof Message) {
  11.       try {
  12.         return !((Message) item).getJMSRedelivered();
  13.       }
  14.       catch (JMSException e) {
  15.         throw new UnexpectedInputException("Could not extract message ID", e);
  16.       }
  17.     }
  18.   }
  19.   return false;
  20. }

代码示例来源：origin: log4j/log4j

  1. sbuf.append(m.getJMSRedelivered());

代码示例来源：origin: spring-projects/spring-framework

  1. headers.put(JmsHeaders.REDELIVERED, jmsMessage.getJMSRedelivered());

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

  1. private Map<String, String> extractMessageHeaders(final Message message) throws JMSException {
  2.   final Map<String, String> messageHeaders = new HashMap<>();
  3.   messageHeaders.put(JmsHeaders.DELIVERY_MODE, String.valueOf(message.getJMSDeliveryMode()));
  4.   messageHeaders.put(JmsHeaders.EXPIRATION, String.valueOf(message.getJMSExpiration()));
  5.   messageHeaders.put(JmsHeaders.PRIORITY, String.valueOf(message.getJMSPriority()));
  6.   messageHeaders.put(JmsHeaders.REDELIVERED, String.valueOf(message.getJMSRedelivered()));
  7.   messageHeaders.put(JmsHeaders.TIMESTAMP, String.valueOf(message.getJMSTimestamp()));
  8.   messageHeaders.put(JmsHeaders.CORRELATION_ID, message.getJMSCorrelationID());
  9.   messageHeaders.put(JmsHeaders.MESSAGE_ID, message.getJMSMessageID());
  10.   messageHeaders.put(JmsHeaders.TYPE, message.getJMSType());
  11.   String replyToDestinationName = this.retrieveDestinationName(message.getJMSReplyTo(), JmsHeaders.REPLY_TO);
  12.   if (replyToDestinationName != null) {
  13.     messageHeaders.put(JmsHeaders.REPLY_TO, replyToDestinationName);
  14.   }
  15.   String destinationName = this.retrieveDestinationName(message.getJMSDestination(), JmsHeaders.DESTINATION);
  16.   if (destinationName != null) {
  17.     messageHeaders.put(JmsHeaders.DESTINATION, destinationName);
  18.   }
  19.   return messageHeaders;
  20. }

代码示例来源：origin: spring-projects/spring-batch

  1. @Test
  2. public void testIsNewForMessage() throws Exception {
  3.   Message message = mock(Message.class);
  4.   when(message.getJMSRedelivered()).thenReturn(true);
  5.   assertEquals(false, newMethodArgumentsIdentifier.isNew(new Object[]{message}));
  6.   
  7. }

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

  1. attributes.put(ATTRIBUTE_PREFIX + JMS_EXPIRATION, String.valueOf(message.getJMSExpiration()));
  2. attributes.put(ATTRIBUTE_PREFIX + JMS_PRIORITY, String.valueOf(message.getJMSPriority()));
  3. attributes.put(ATTRIBUTE_PREFIX + JMS_REDELIVERED, String.valueOf(message.getJMSRedelivered()));
  4. attributes.put(ATTRIBUTE_PREFIX + JMS_TIMESTAMP, String.valueOf(message.getJMSTimestamp()));
  5. return attributes;

代码示例来源：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: spring-projects/spring-framework

  1. @Test
  2. public void jmsReadOnlyPropertiesNotMapped() throws JMSException {
  3.   Message<String> message = initBuilder()
  4.       .setHeader(JmsHeaders.DESTINATION, new Destination() {})
  5.       .setHeader(JmsHeaders.DELIVERY_MODE, DeliveryMode.NON_PERSISTENT)
  6.       .setHeader(JmsHeaders.EXPIRATION, 1000L)
  7.       .setHeader(JmsHeaders.MESSAGE_ID, "abc-123")
  8.       .setHeader(JmsHeaders.PRIORITY, 9)
  9.       .setHeader(JmsHeaders.REDELIVERED, true)
  10.       .setHeader(JmsHeaders.TIMESTAMP, System.currentTimeMillis())
  11.       .build();
  12.   javax.jms.Message jmsMessage = new StubTextMessage();
  13.   mapper.fromHeaders(message.getHeaders(), jmsMessage);
  14.   assertNull(jmsMessage.getJMSDestination());
  15.   assertEquals(DeliveryMode.PERSISTENT, jmsMessage.getJMSDeliveryMode());
  16.   assertEquals(0, jmsMessage.getJMSExpiration());
  17.   assertNull(jmsMessage.getJMSMessageID());
  18.   assertEquals(javax.jms.Message.DEFAULT_PRIORITY, jmsMessage.getJMSPriority());
  19.   assertFalse(jmsMessage.getJMSRedelivered());
  20.   assertEquals(0, jmsMessage.getJMSTimestamp());
  21. }

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

  1. sbuf.append(m.getJMSRedelivered());

代码示例来源：origin: spring-projects/spring-integration

  1. headers.put(JmsHeaders.REDELIVERED, jmsMessage.getJMSRedelivered());

代码示例来源：origin: org.fornax.cartridges/fornax-cartridges-sculptor-framework

  1. protected boolean isJmsRedelivered(Message msg) {
  2.   try {
  3.     return msg.getJMSRedelivered();
  4.   } catch (JMSException e) {
  5.     return false;
  6.   }
  7. }

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

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

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

  1. public boolean getJMSRedelivered() throws JMSException
  2. {
  3.  return message.getJMSRedelivered();
  4. }

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

  1. /**
  2.  * Gets the JMSRedelivered from the message.
  3.  *
  4.  * @param message  the message
  5.  * @return <tt>true</tt> if redelivered, <tt>false</tt> if not, <tt>null</tt> if not able to determine
  6.  */
  7. public static Boolean getJMSRedelivered(Message message) {
  8.   try {
  9.     return message.getJMSRedelivered();
  10.   } catch (Exception e) {
  11.     // ignore if JMS broker do not support this
  12.   }
  13.   return null;
  14. }

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

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

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

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

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

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

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

  1. @Test
  2. public void testRedeliveryWithClientAck() throws Exception {
  3.  conn.connect(defUser, defPass);
  4.  subscribe(conn, "subId", "client");
  5.  sendJmsMessage(getName());
  6.  ClientStompFrame frame = conn.receiveFrame();
  7.  Assert.assertTrue(frame.getCommand().equals(Stomp.Responses.MESSAGE));
  8.  conn.disconnect();
  9.  // message should be received since message was not acknowledged
  10.  MessageConsumer consumer = session.createConsumer(queue);
  11.  Message message = consumer.receive(1000);
  12.  Assert.assertNotNull(message);
  13.  Assert.assertTrue(message.getJMSRedelivered());
  14. }

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

  1. @Test
  2. public void testRedeliveryWithClientAck() throws Exception {
  3.  conn.connect(defUser, defPass);
  4.  subscribe(conn, "subscriptionId", Stomp.Headers.Subscribe.AckModeValues.CLIENT);
  5.  sendJmsMessage(getName());
  6.  ClientStompFrame frame = conn.receiveFrame();
  7.  assertTrue(frame.getCommand().equals(Stomp.Responses.MESSAGE));
  8.  conn.disconnect();
  9.  // message should be received since message was not acknowledged
  10.  MessageConsumer consumer = session.createConsumer(queue);
  11.  Message message = consumer.receive(1000);
  12.  Assert.assertNotNull(message);
  13.  Assert.assertTrue(message.getJMSRedelivered());
  14. }

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

  1. @Test
  2. public void testRedeliveryWithClientAck() throws Exception {
  3.  conn.connect(defUser, defPass);
  4.  subscribe(conn, null, Stomp.Headers.Subscribe.AckModeValues.CLIENT);
  5.  sendJmsMessage(getName());
  6.  ClientStompFrame frame = conn.receiveFrame(10000);
  7.  Assert.assertEquals(Stomp.Responses.MESSAGE, frame.getCommand());
  8.  conn.disconnect();
  9.  // message should be received since message was not acknowledged
  10.  MessageConsumer consumer = session.createConsumer(queue);
  11.  Message message = consumer.receive(1000);
  12.  Assert.assertNotNull(message);
  13.  Assert.assertTrue(message.getJMSRedelivered());
  14. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Message类方法

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