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

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

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

Message.getStringProperty介绍

[英]Returns the value of the String property with the specified name.
[中]返回具有指定名称的字符串属性的值。

代码示例

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

  1. @Override public String get(Message carrier, String key) {
  2.  try {
  3.   return carrier.getStringProperty(key);
  4.  } catch (JMSException e) {
  5.   // don't crash on wonky exceptions!
  6.   return null;
  7.  }
  8. }

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

  1. /**
  2.  * Method to return HCatEventMessage contained in the JMS message.
  3.  * @param message The JMS Message instance
  4.  * @return The contained HCatEventMessage
  5.  */
  6. public static HCatEventMessage getMessage(Message message) {
  7.  try {
  8.   String messageBody = ((TextMessage)message).getText();
  9.   String eventType   = message.getStringProperty(HCatConstants.HCAT_EVENT);
  10.   String messageVersion = message.getStringProperty(HCatConstants.HCAT_MESSAGE_VERSION);
  11.   String messageFormat = message.getStringProperty(HCatConstants.HCAT_MESSAGE_FORMAT);
  12.   if (StringUtils.isEmpty(messageBody) || StringUtils.isEmpty(eventType))
  13.    throw new IllegalArgumentException("Could not extract HCatEventMessage. " +
  14.              "EventType and/or MessageBody is null/empty.");
  15.   return MessageFactory.getDeserializer(messageFormat, messageVersion).getHCatEventMessage(eventType, messageBody);
  16.  }
  17.  catch (JMSException exception) {
  18.   throw new IllegalArgumentException("Could not extract HCatEventMessage. ", exception);
  19.  }
  20. }

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

  1. String typeId = message.getStringProperty(this.typeIdPropertyName);
  2. if (typeId == null) {
  3.   throw new MessageConversionException(

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

  1. while (propertyNames.hasMoreElements()) {
  2.  String name = propertyNames.nextElement().toString();
  3.  String value = message.getStringProperty(name);
  4.  headers.put(name, value);

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

  1. @SuppressWarnings("unchecked")
  2. protected List<String> assertReceivedObjectMessageWithListBody(Message message) throws JMSException {
  3.   assertNotNull("Should have received a message!", message);
  4.   assertEquals("foo header", "abc", message.getStringProperty("foo"));
  5.   assertTrue("Should be an object message but was: " + message, message instanceof ObjectMessage);
  6.   ObjectMessage objectMessage = (ObjectMessage)message;
  7.   List<String> body = (List<String>)objectMessage.getObject();
  8.   LOG.info("Received body: " + body);
  9.   assertEquals("Size of list should be 1", 1, body.size());
  10.   assertEquals("element 0 of list", "First", body.get(0));
  11.   return body;
  12. }

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

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

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

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

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

  1. @Test
  2. public void buildMessageWithStandardMessage() throws JMSException {
  3.   Destination replyTo = new Destination() {};
  4.   Message<String> result = MessageBuilder.withPayload("Response")
  5.       .setHeader("foo", "bar")
  6.       .setHeader(JmsHeaders.TYPE, "msg_type")
  7.       .setHeader(JmsHeaders.REPLY_TO, replyTo)
  8.       .build();
  9.   Session session = mock(Session.class);
  10.   given(session.createTextMessage("Response")).willReturn(new StubTextMessage("Response"));
  11.   MessagingMessageListenerAdapter listener = getSimpleInstance("echo", Message.class);
  12.   javax.jms.Message replyMessage = listener.buildMessage(session, result);
  13.   verify(session).createTextMessage("Response");
  14.   assertNotNull("reply should never be null", replyMessage);
  15.   assertEquals("Response", ((TextMessage) replyMessage).getText());
  16.   assertEquals("custom header not copied", "bar", replyMessage.getStringProperty("foo"));
  17.   assertEquals("type header not copied", "msg_type", replyMessage.getJMSType());
  18.   assertEquals("replyTo header not copied", replyTo, replyMessage.getJMSReplyTo());
  19. }

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

  1. @Override
  2. public void onMessage(javax.jms.Message message) {
  3.   String correlation = null;
  4.   try {
  5.     if (logger.isTraceEnabled()) {
  6.       logger.trace(this.getComponentName() + " Received " + message);
  7.     }
  8.     if (this.correlationKey == null ||
  9.         this.correlationKey.equals("JMSCorrelationID") ||
  10.         this.correlationKey.equals("JMSCorrelationID*")) {
  11.       correlation = message.getJMSCorrelationID();
  12.     }
  13.     else {
  14.       correlation = message.getStringProperty(this.correlationKey);
  15.     }
  16.     Assert.state(correlation != null, "Message with no correlationId received");
  17.     if (isAsync()) {
  18.       onMessageAsync(message, correlation);
  19.     }
  20.     else {
  21.       onMessageSync(message, correlation);
  22.     }
  23.   }
  24.   catch (Exception e) {
  25.     if (logger.isWarnEnabled()) {
  26.       logger.warn("Failed to consume reply with correlationId " + correlation, e);
  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 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 attemptToWriteDisallowedTypePropertyIsNotFatal() throws JMSException {
  3.   Message<String> message = MessageBuilder.withPayload("test")
  4.       .setHeader(JmsHeaders.TYPE, "someType")
  5.       .setHeader("foo", "bar")
  6.       .build();
  7.   DefaultJmsHeaderMapper mapper = new DefaultJmsHeaderMapper();
  8.   javax.jms.Message jmsMessage = new StubTextMessage() {
  9.     @Override
  10.     public void setJMSType(String type) throws JMSException {
  11.       throw new JMSException("illegal property");
  12.     }
  13.   };
  14.   mapper.fromHeaders(message.getHeaders(), jmsMessage);
  15.   assertNull(jmsMessage.getJMSType());
  16.   assertNotNull(jmsMessage.getStringProperty("foo"));
  17.   assertEquals("bar", jmsMessage.getStringProperty("foo"));
  18. }

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

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

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

  1. @Override
  2.   public void setProperties(Message message) throws JMSException {
  3.     super.setProperties(message);
  4.     setEventStatus(EventStatus.valueOf(message.getStringProperty(JMSHeaderConstants.EVENT_STATUS)));
  5.     setAppName(message.getStringProperty(JMSHeaderConstants.APP_NAME));
  6.     setUser(message.getStringProperty(JMSHeaderConstants.USER));
  7.   }
  8. }

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

  1. /**
  2.  * Set the JMS selector properties for message object
  3.  * @param message the message
  4.  * @throws JMSException in case of a JMS error occurs
  5.  */
  6. @JsonIgnore
  7. public void setProperties(Message message) throws JMSException {
  8.   setAppType(AppType.valueOf(message.getStringProperty(JMSHeaderConstants.APP_TYPE)));
  9.   setMessageType(MessageType.valueOf(message.getStringProperty(JMSHeaderConstants.MESSAGE_TYPE)));
  10. }

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

  1. @SuppressWarnings("unchecked")
  2. protected List<String> assertReceivedObjectMessageWithListBody(Message message) throws JMSException {
  3.  assertNotNull("Should have received a message!", message);
  4.  assertEquals("foo header", "abc", message.getStringProperty("foo"));
  5.  assertTrue("Should be an object message but was: " + message, message instanceof ObjectMessage);
  6.  ObjectMessage objectMessage = (ObjectMessage) message;
  7.  List<String> body = (List<String>) objectMessage.getObject();
  8.  System.out.println("Received body: " + body);
  9.  assertEquals("Size of list should be 1", 1, body.size());
  10.  assertEquals("element 0 of list", "First", body.get(0));
  11.  return body;
  12. }

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

  1. @Test
  2.   public void testJMSXDeliveryCountConversion() throws Exception {
  3.    Message m1 = queueProducerSession.createMessage();
  4.    queueProducer.send(m1);
  6.    Message m2 = queueConsumer.receive(2000);
  8.    int count = m2.getIntProperty("JMSXDeliveryCount");
  9.    ProxyAssertSupport.assertEquals(String.valueOf(count), m2.getStringProperty("JMSXDeliveryCount"));
  10.    ProxyAssertSupport.assertEquals(count, m2.getLongProperty("JMSXDeliveryCount"));
  11.   }
  12. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Message类方法

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