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

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

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

Message.getJMSDestination介绍

[英]Gets the Destination object for this message.

The JMSDestination header field contains the destination to which the message is being sent.

When a message is sent, this field is ignored. After completion of the send or publish method, the field holds the destination specified by the method.

When a message is received, its JMSDestination value must be equivalent to the value assigned when it was sent.
[中]获取此消息的目标对象。
JMSDestination标头字段包含消息要发送到的目的地。
发送消息时，忽略此字段。发送或发布方法完成后，该字段保存该方法指定的目的地。
接收到消息时，其JMSDestination值必须等于发送消息时分配的值。

代码示例

代码示例来源：origin: openzipkin/brave

  1. @Override Destination destination(Message message) {
  2.  try {
  3.   return message.getJMSDestination();
  4.  } catch (JMSException ignored) {
  5.   // don't crash on wonky exceptions!
  6.  }
  7.  return null;
  8. }

代码示例来源：origin: openzipkin/brave

  1. @Override Destination destination(Message message) {
  2.  try {
  3.   Destination result = message.getJMSDestination();
  4.   if (result != null) return result;
  5.   return delegate.getDestination();
  6.  } catch (JMSException ignored) {
  7.   // don't crash on wonky exceptions!
  8.  }
  9.  return null;
  10. }

代码示例来源：origin: openzipkin/brave

  1. void tagQueueOrTopic(Message message, SpanCustomizer span) {
  2.  try {
  3.   Destination destination = message.getJMSDestination();
  4.   if (destination != null) tagQueueOrTopic(destination, span);
  5.  } catch (JMSException e) {
  6.   // don't crash on wonky exceptions!
  7.  }
  8. }

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

  1. public void updateState(List<TridentTuple> tuples, TridentCollector collector) throws JMSException {
  2.   try {
  3.     for (TridentTuple tuple : tuples) {
  4.       Message msg = this.options.msgProducer.toMessage(this.session, tuple);
  5.       if (msg != null) {
  6.         if (msg.getJMSDestination() != null) {
  7.           this.messageProducer.send(msg.getJMSDestination(), msg);
  8.         } else {
  9.           this.messageProducer.send(msg);
  10.         }
  11.       }
  12.     }
  13.   } catch (JMSException e) {
  14.     LOG.warn("Failed to send jmd message for a trident batch ", e);
  15.     if (this.options.jmsTransactional) {
  16.       session.rollback();
  17.     }
  18.     throw new FailedException("Failed to write tuples", e);
  19.   }
  20. }

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

  1. throw new MessageConversionException(
  2.     "Could not find type id property [" + this.typeIdPropertyName + "] on message [" +
  3.     message.getJMSMessageID() + "] from destination [" + message.getJMSDestination() + "]");

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

  1. Message msg = this.producer.toMessage(this.session, input);
  2. if (msg != null) {
  3.   if (msg.getJMSDestination() != null) {
  4.     this.messageProducer.send(msg.getJMSDestination(), msg);
  5.   } else {
  6.     this.messageProducer.send(msg);

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

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

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

  1. Destination destination = jmsMessage.getJMSDestination();
  2. if (destination != null) {
  3.   headers.put(JmsHeaders.DESTINATION, destination);

代码示例来源：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: apache/nifi

  1. attributes.put(ATTRIBUTE_PREFIX + JMS_CORRELATION_ID, message.getJMSCorrelationID());
  2. if (message.getJMSDestination() != null) {
  3.   String destinationName;
  4.   if (message.getJMSDestination() instanceof Queue) {
  5.     destinationName = ((Queue) message.getJMSDestination()).getQueueName();
  6.   } else {
  7.     destinationName = ((Topic) message.getJMSDestination()).getTopicName();

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

  1. setJMSDestination(foreign.getJMSDestination());
  2. setJMSDeliveryMode(foreign.getJMSDeliveryMode());
  3. setJMSExpiration(foreign.getJMSExpiration());

代码示例来源：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.getJMSDestination());

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

  1. Destination destination = jmsMessage.getJMSDestination();
  2. if (destination != null) {
  3.   headers.put(JmsHeaders.DESTINATION, destination);

代码示例来源：origin: org.eclipse.persistence/com.springsource.org.eclipse.persistence

  1. /**
  2.  * INTERNAL:
  3.  */
  4. protected String logDebugJMSTopic(Message message) throws JMSException {
  5.   String topic = ((Topic)message.getJMSDestination()).getTopicName();
  6.   Object[] args = { topic };
  7.   // call logDebugWithoutLevelCheck to avoid the second rcm.shouldLogDebugMessage() check
  8.   rcm.logDebugWithoutLevelCheck("retreived_remote_message_from_JMS_topic", args);
  9.   return topic;
  10. }

代码示例来源：origin: com.haulmont.thirdparty/eclipselink

  1. /**
  2.  * INTERNAL:
  3.  */
  4. protected String logDebugJMSTopic(Message message) throws JMSException {
  5.   String topic = ((Topic)message.getJMSDestination()).getTopicName();
  6.   Object[] args = { topic };
  7.   // call logDebugWithoutLevelCheck to avoid the second rcm.shouldLogDebugMessage() check
  8.   rcm.logDebugWithoutLevelCheck("retreived_remote_message_from_JMS_topic", args);
  9.   return topic;
  10. }

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

  1. @Test
  2. public void testJMSDestination() throws Exception {
  3.  queueProducer.send(queueProducerSession.createMessage());
  4.  Message m = queueConsumer.receive();
  5.  ProxyAssertSupport.assertEquals(queue1, m.getJMSDestination());
  6. }

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

  1. @Test
  2. public void testClearMessage() throws Exception {
  3.  queueProducer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
  4.  Message message = queueProducerSession.createTextMessage("some message");
  5.  queueProducer.send(message);
  6.  message = queueConsumer.receive(1000);
  7.  ProxyAssertSupport.assertNotNull(message);
  8.  message.clearProperties();
  9.  ProxyAssertSupport.assertNotNull(message.getJMSDestination());
  10. }

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

  1. @Test
  2. public void testForeignJMSDestination() throws JMSException {
  3.  Message message = queueProducerSession.createMessage();
  4.  Destination foreignDestination = new ForeignDestination();
  5.  message.setJMSDestination(foreignDestination);
  6.  ProxyAssertSupport.assertSame(foreignDestination, message.getJMSDestination());
  7.  queueProducer.send(message);
  8.  ProxyAssertSupport.assertSame(queue1, message.getJMSDestination());
  9.  Message receivedMessage = queueConsumer.receive(2000);
  10.  MessageHeaderTestBase.ensureEquivalent(receivedMessage, (ActiveMQMessage) message);
  11. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Message类方法

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