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

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

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

Message.getJMSCorrelationID介绍

[英]Gets the correlation ID for the message.

This method is used to return correlation ID values that are either provider-specific message IDs or application-specific String values.
[中]获取消息的相关ID。
此方法用于返回相关ID值，这些值是特定于提供程序的消息ID或特定于应用程序的字符串值。

代码示例

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

  1. /**
  2.  * Post-process the given response message before it will be sent.
  3.  * <p>The default implementation sets the response's correlation id
  4.  * to the request message's correlation id, if any; otherwise to the
  5.  * request message id.
  6.  * @param request the original incoming JMS message
  7.  * @param response the outgoing JMS message about to be sent
  8.  * @throws JMSException if thrown by JMS API methods
  9.  * @see javax.jms.Message#setJMSCorrelationID
  10.  */
  11. protected void postProcessResponse(Message request, Message response) throws JMSException {
  12.   String correlation = request.getJMSCorrelationID();
  13.   if (correlation == null) {
  14.     correlation = request.getJMSMessageID();
  15.   }
  16.   response.setJMSCorrelationID(correlation);
  17. }

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

  1. } catch (JMSException e) {
  2.  String corrIDString = foreign.getJMSCorrelationID();
  3.  if (corrIDString != null) {
  4.    setJMSCorrelationID(corrIDString);
  5. String corrIDString = foreign.getJMSCorrelationID();
  6. if (corrIDString != null) {
  7.  setJMSCorrelationID(corrIDString);

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

  1. /**
  2.  * Create the invocation result response message.
  3.  * <p>The default implementation creates a JMS ObjectMessage for the given
  4.  * RemoteInvocationResult object. It sets the response's correlation id
  5.  * to the request message's correlation id, if any; otherwise to the
  6.  * request message id.
  7.  * @param request the original request message
  8.  * @param session the JMS session to use
  9.  * @param result the invocation result
  10.  * @return the message response to send
  11.  * @throws javax.jms.JMSException if creating the message failed
  12.  */
  13. protected Message createResponseMessage(Message request, Session session, RemoteInvocationResult result)
  14.     throws JMSException {
  15.   Message response = this.messageConverter.toMessage(result, session);
  16.   String correlation = request.getJMSCorrelationID();
  17.   if (correlation == null) {
  18.     correlation = request.getJMSMessageID();
  19.   }
  20.   response.setJMSCorrelationID(correlation);
  21.   return response;
  22. }

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

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

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

  1. try {
  2.   try {
  3.     String correlationId = jmsMessage.getJMSCorrelationID();
  4.     if (correlationId != null) {
  5.       headers.put(JmsHeaders.CORRELATION_ID, correlationId);

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

  1. @Test
  2. public void jmsCorrelationIdMappedFromHeader() throws JMSException {
  3.   String jmsCorrelationId = "ABC-123";
  4.   Message<String> message = initBuilder()
  5.       .setHeader(JmsHeaders.CORRELATION_ID, jmsCorrelationId).build();
  6.   javax.jms.Message jmsMessage = new StubTextMessage();
  7.   mapper.fromHeaders(message.getHeaders(), jmsMessage);
  8.   assertNotNull(jmsMessage.getJMSCorrelationID());
  9.   assertEquals(jmsCorrelationId, jmsMessage.getJMSCorrelationID());
  10. }

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

  1. @Test
  2. public void jmsCorrelationIdIgnoredIfIncorrectType() throws JMSException {
  3.   Message<String> message = initBuilder()
  4.       .setHeader(JmsHeaders.CORRELATION_ID, new Date()).build();
  5.   javax.jms.Message jmsMessage = new StubTextMessage();
  6.   mapper.fromHeaders(message.getHeaders(), jmsMessage);
  7.   assertNull(jmsMessage.getJMSCorrelationID());
  8. }

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

  1. if (message.getJMSCorrelationID() != null) {
  2.   attributes.put(ATTRIBUTE_PREFIX + JMS_CORRELATION_ID, message.getJMSCorrelationID());

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

  1. @Test
  2. public void jmsCorrelationIdNumberConvertsToString() throws JMSException {
  3.   Message<String> message = initBuilder()
  4.       .setHeader(JmsHeaders.CORRELATION_ID, 123).build();
  5.   javax.jms.Message jmsMessage = new StubTextMessage();
  6.   mapper.fromHeaders(message.getHeaders(), jmsMessage);
  7.   assertEquals("123", jmsMessage.getJMSCorrelationID());
  8. }

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

  1. @Test
  2. public void attemptToWriteDisallowedCorrelationIdNumberPropertyIsNotFatal() throws JMSException {
  3.   Message<String> message = initBuilder()
  4.       .setHeader(JmsHeaders.CORRELATION_ID, 123)
  5.       .setHeader("foo", "bar")
  6.       .build();
  7.   javax.jms.Message jmsMessage = new StubTextMessage() {
  8.     @Override
  9.     public void setJMSCorrelationID(String correlationId) throws JMSException {
  10.       throw new JMSException("illegal property");
  11.     }
  12.   };
  13.   mapper.fromHeaders(message.getHeaders(), jmsMessage);
  14.   assertNull(jmsMessage.getJMSCorrelationID());
  15.   assertNotNull(jmsMessage.getStringProperty("foo"));
  16.   assertEquals("bar", jmsMessage.getStringProperty("foo"));
  17. }

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

  1. @Test
  2. public void attemptToWriteDisallowedCorrelationIdStringPropertyIsNotFatal() throws JMSException {
  3.   Message<String> message = initBuilder()
  4.       .setHeader(JmsHeaders.CORRELATION_ID, "abc")
  5.       .setHeader("foo", "bar")
  6.       .build();
  7.   javax.jms.Message jmsMessage = new StubTextMessage() {
  8.     @Override
  9.     public void setJMSCorrelationID(String correlationId) throws JMSException {
  10.       throw new JMSException("illegal property");
  11.     }
  12.   };
  13.   mapper.fromHeaders(message.getHeaders(), jmsMessage);
  14.   assertNull(jmsMessage.getJMSCorrelationID());
  15.   assertNotNull(jmsMessage.getStringProperty("foo"));
  16.   assertEquals("bar", jmsMessage.getStringProperty("foo"));
  17. }

代码示例来源：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-integration

  1. private void copyCorrelationIdFromRequestToReply(javax.jms.Message requestMessage, javax.jms.Message replyMessage)
  2.     throws JMSException {
  3.   if (this.correlationKey != null) {
  4.     if (this.correlationKey.equals("JMSCorrelationID")) {
  5.       replyMessage.setJMSCorrelationID(requestMessage.getJMSCorrelationID());
  6.     }
  7.     else {
  8.       String value = requestMessage.getStringProperty(this.correlationKey);
  9.       if (value != null) {
  10.         replyMessage.setStringProperty(this.correlationKey, value);
  11.       }
  12.       else if (this.logger.isWarnEnabled()) {
  13.         this.logger.warn("No property value available on request Message for correlationKey '"
  14.             + this.correlationKey + "'");
  15.       }
  16.     }
  17.   }
  18.   else if (replyMessage.getJMSCorrelationID() == null) {
  19.     replyMessage.setJMSCorrelationID(requestMessage.getJMSMessageID());
  20.   }
  21. }

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

  1. @Test
  2. public void testJmsCorrelationIdMappedFromHeader() throws JMSException {
  3.   String jmsCorrelationId = "ABC-123";
  4.   Message<String> message = MessageBuilder.withPayload("test")
  5.       .setHeader(JmsHeaders.CORRELATION_ID, jmsCorrelationId).build();
  6.   DefaultJmsHeaderMapper mapper = new DefaultJmsHeaderMapper();
  7.   javax.jms.Message jmsMessage = new StubTextMessage();
  8.   mapper.fromHeaders(message.getHeaders(), jmsMessage);
  9.   assertNotNull(jmsMessage.getJMSCorrelationID());
  10.   assertEquals(jmsCorrelationId, jmsMessage.getJMSCorrelationID());
  11. }

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

  1. @Test
  2. public void testJmsCorrelationIdNumberConvertsToString() throws JMSException {
  3.   Message<String> message = MessageBuilder.withPayload("test")
  4.       .setHeader(JmsHeaders.CORRELATION_ID, new Integer(123)).build();
  5.   DefaultJmsHeaderMapper mapper = new DefaultJmsHeaderMapper();
  6.   javax.jms.Message jmsMessage = new StubTextMessage();
  7.   mapper.fromHeaders(message.getHeaders(), jmsMessage);
  8.   assertEquals("123", jmsMessage.getJMSCorrelationID());
  9. }

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

  1. @Test
  2. public void testJmsCorrelationIdIgnoredIfIncorrectType() throws JMSException {
  3.   Message<String> message = MessageBuilder.withPayload("test")
  4.       .setHeader(JmsHeaders.CORRELATION_ID, new Date()).build();
  5.   DefaultJmsHeaderMapper mapper = new DefaultJmsHeaderMapper();
  6.   javax.jms.Message jmsMessage = new StubTextMessage();
  7.   mapper.fromHeaders(message.getHeaders(), jmsMessage);
  8.   assertNull(jmsMessage.getJMSCorrelationID());
  9. }

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

  1. @Test
  2. public void attemptToWriteDisallowedCorrelationIdNumberPropertyIsNotFatal() throws JMSException {
  3.   Message<String> message = MessageBuilder.withPayload("test")
  4.       .setHeader(JmsHeaders.CORRELATION_ID, new Integer(123))
  5.       .setHeader("foo", "bar")
  6.       .build();
  7.   DefaultJmsHeaderMapper mapper = new DefaultJmsHeaderMapper();
  8.   javax.jms.Message jmsMessage = new StubTextMessage() {
  9.     @Override
  10.     public void setJMSCorrelationID(String correlationId) throws JMSException {
  11.       throw new JMSException("illegal property");
  12.     }
  13.   };
  14.   mapper.fromHeaders(message.getHeaders(), jmsMessage);
  15.   assertNull(jmsMessage.getJMSCorrelationID());
  16.   assertNotNull(jmsMessage.getStringProperty("foo"));
  17.   assertEquals("bar", jmsMessage.getStringProperty("foo"));
  18. }

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

  1. @Test
  2. public void attemptToWriteDisallowedCorrelationIdStringPropertyIsNotFatal() throws JMSException {
  3.   Message<String> message = MessageBuilder.withPayload("test")
  4.       .setHeader(JmsHeaders.CORRELATION_ID, "abc")
  5.       .setHeader("foo", "bar")
  6.       .build();
  7.   DefaultJmsHeaderMapper mapper = new DefaultJmsHeaderMapper();
  8.   javax.jms.Message jmsMessage = new StubTextMessage() {
  9.     @Override
  10.     public void setJMSCorrelationID(String correlationId) throws JMSException {
  11.       throw new JMSException("illegal property");
  12.     }
  13.   };
  14.   mapper.fromHeaders(message.getHeaders(), jmsMessage);
  15.   assertNull(jmsMessage.getJMSCorrelationID());
  16.   assertNotNull(jmsMessage.getStringProperty("foo"));
  17.   assertEquals("bar", jmsMessage.getStringProperty("foo"));
  18. }

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

  1. @Test
  2. public void testWithReply() throws Exception {
  3.   QueueChannel replies = new QueueChannel();
  4.   this.gateway1.setOutputChannel(replies);
  5.   this.gateway1.start();
  6.   this.gateway1.handleMessage(MessageBuilder.withPayload("foo")
  7.       .setHeader(JmsHeaders.CORRELATION_ID, "baz")// make sure it's restored in case we're from an upstream gw
  8.       .build());
  9.   JmsTemplate template = new JmsTemplate(this.ccf);
  10.   template.setReceiveTimeout(10000);
  11.   final Message received = template.receive("asyncTest1");
  12.   assertNotNull(received);
  13.   template.send(received.getJMSReplyTo(), (MessageCreator) session -> {
  14.     TextMessage textMessage = session.createTextMessage("bar");
  15.     textMessage.setJMSCorrelationID(received.getJMSCorrelationID());
  16.     return textMessage;
  17.   });
  18.   org.springframework.messaging.Message<?> reply = replies.receive(10000);
  19.   assertNotNull(reply);
  20.   assertEquals("bar", reply.getPayload());
  21.   assertEquals("baz", reply.getHeaders().get(JmsHeaders.CORRELATION_ID));
  22.   this.gateway1.stop();
  23. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Message类方法

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