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

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

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

Message.setStringProperty介绍

[英]Sets a String property value with the specified name into the message.
[中]在消息中设置具有指定名称的字符串属性值。

代码示例

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

  1. /**
  2.  * Set a type id for the given payload object on the given JMS Message.
  3.  * <p>The default implementation consults the configured type id mapping and
  4.  * sets the resulting value (either a mapped id or the raw Java class name)
  5.  * into the configured type id message property.
  6.  * @param object the payload object to set a type id for
  7.  * @param message the JMS Message to set the type id on
  8.  * @throws JMSException if thrown by JMS methods
  9.  * @see #getJavaTypeForMessage(javax.jms.Message)
  10.  * @see #setTypeIdPropertyName(String)
  11.  * @see #setTypeIdMappings(java.util.Map)
  12.  */
  13. protected void setTypeIdOnMessage(Object object, Message message) throws JMSException {
  14.   if (this.typeIdPropertyName != null) {
  15.     String typeId = this.classIdMappings.get(object.getClass());
  16.     if (typeId == null) {
  17.       typeId = object.getClass().getName();
  18.     }
  19.     message.setStringProperty(this.typeIdPropertyName, typeId);
  20.   }
  21. }

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

  1. /** This is only safe to call after {@link JmsTracing#extractAndClearMessage(Message)} */
  2. static void addB3SingleHeader(Message message, TraceContext context) {
  3.  try {
  4.   message.setStringProperty("b3", writeB3SingleFormatWithoutParentId(context));
  5.  } catch (JMSException ignored) {
  6.   // don't crash on wonky exceptions!
  7.  }
  8. }

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

  1. private void assertAttemptReadDisallowedPropertyIsNotFatal(javax.jms.Message jmsMessage, String headerId)
  2.     throws JMSException {
  3.   jmsMessage.setStringProperty("foo", "bar");
  4.   Map<String, Object> headers = mapper.toHeaders(jmsMessage);
  5.   assertNull(headers.get(headerId));
  6.   assertNotNull(headers.get("foo"));
  7.   assertEquals("bar", headers.get("foo"));
  8. }

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

  1. protected Message createMessage(int i) throws Exception {
  2.   Message answer;
  3.   if (payload != null) {
  4.     answer = session.createBytesMessage();
  5.     ((BytesMessage) answer).writeBytes(payload);
  6.   } else {
  7.     if (textMessageSize > 0) {
  8.       if (messageText == null) {
  9.         messageText = readInputStream(getClass().getResourceAsStream("demo.txt"), textMessageSize, i);
  10.       }
  11.     } else if (payloadUrl != null) {
  12.       messageText = readInputStream(new URL(payloadUrl).openStream(), -1, i);
  13.     } else if (message != null) {
  14.       messageText = message;
  15.     } else {
  16.       messageText = createDefaultMessage(i);
  17.     }
  18.     answer = session.createTextMessage(messageText);
  19.   }
  20.   if ((msgGroupID != null) && (!msgGroupID.isEmpty())) {
  21.     answer.setStringProperty("JMSXGroupID", msgGroupID);
  22.   }
  23.   return answer;
  24. }

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

  1. Message msg = session.get().createTextMessage(hCatEventMessage.toString());
  2. msg.setStringProperty(HCatConstants.HCAT_EVENT, hCatEventMessage.getEventType().toString());
  3. msg.setStringProperty(HCatConstants.HCAT_MESSAGE_VERSION, messageFactory.getVersion());
  4. msg.setStringProperty(HCatConstants.HCAT_MESSAGE_FORMAT, messageFactory.getMessageFormat());
  5. MessageProducer producer = createProducer(topic);
  6. producer.send(msg);

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

  1. @Test
  2. public void contentTypePropertyMappedToHeader() throws JMSException {
  3.   javax.jms.Message jmsMessage = new StubTextMessage();
  4.   jmsMessage.setStringProperty("content_type", "foo");
  5.   assertInboundHeader(jmsMessage, MessageHeaders.CONTENT_TYPE, "foo");
  6. }

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

  1. private void testMessageConverterIsUsed() throws JMSException {
  2.   MethodJmsListenerEndpoint endpoint = createDefaultMethodJmsEndpoint(
  3.       this.listener.getClass(), "handleIt", String.class, String.class);
  4.   Message message = new StubTextMessage("foo-bar");
  5.   message.setStringProperty("my-header", "my-value");
  6.   invokeListener(endpoint, message);
  7.   assertListenerMethodInvocation("handleIt");
  8. }

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

  1. message.setStringProperty(jmsPropName, value);
  2. } else if (type.equalsIgnoreCase(PROP_TYPE_INTEGER)) {
  3.   message.setIntProperty(jmsPropName, Integer.parseInt(value));

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

  1. @Test
  2. public void parameterAnnotationWithJdkProxy() throws JMSException {
  3.   ProxyFactory pf = new ProxyFactory(sample);
  4.   listener = (JmsEndpointSampleInterface) pf.getProxy();
  5.   containerFactory.setMessageConverter(new UpperCaseMessageConverter());
  6.   MethodJmsListenerEndpoint endpoint = createDefaultMethodJmsEndpoint(
  7.       JmsEndpointSampleInterface.class, "handleIt", String.class, String.class);
  8.   Message message = new StubTextMessage("foo-bar");
  9.   message.setStringProperty("my-header", "my-value");
  10.   invokeListener(endpoint, message);
  11.   assertListenerMethodInvocation("handleIt");
  12. }

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

  1. @Test
  2. public void parameterAnnotationWithCglibProxy() throws JMSException {
  3.   ProxyFactory pf = new ProxyFactory(sample);
  4.   pf.setProxyTargetClass(true);
  5.   listener = (JmsEndpointSampleBean) pf.getProxy();
  6.   containerFactory.setMessageConverter(new UpperCaseMessageConverter());
  7.   MethodJmsListenerEndpoint endpoint = createDefaultMethodJmsEndpoint(
  8.       JmsEndpointSampleBean.class, "handleIt", String.class, String.class);
  9.   Message message = new StubTextMessage("foo-bar");
  10.   message.setStringProperty("my-header", "my-value");
  11.   invokeListener(endpoint, message);
  12.   assertListenerMethodInvocation("handleIt");
  13. }

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

  1. public void testChangeMutableObjectInObjectMessageThenRollback() throws Exception {
  2.   ArrayList<String> list = new ArrayList<String>();
  3.   list.add("First");
  4.   Message outbound = session.createObjectMessage(list);
  5.   outbound.setStringProperty("foo", "abc");
  6.   beginTx();
  7.   producer.send(outbound);
  8.   commitTx();
  9.   LOG.info("About to consume message 1");
  10.   beginTx();
  11.   Message message = consumer.receive(5000);
  12.   List<String> body = assertReceivedObjectMessageWithListBody(message);
  13.   // now lets try mutate it
  14.   try {
  15.     message.setStringProperty("foo", "def");
  16.     fail("Cannot change properties of the object!");
  17.   } catch (JMSException e) {
  18.     LOG.info("Caught expected exception: " + e, e);
  19.   }
  20.   body.clear();
  21.   body.add("This should never be seen!");
  22.   rollbackTx();
  23.   beginTx();
  24.   message = consumer.receive(5000);
  25.   List<String> secondBody = assertReceivedObjectMessageWithListBody(message);
  26.   assertNotSame("Second call should return a different body", secondBody, body);
  27.   commitTx();
  28. }

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

  1. @Before
  2. public void setUp() throws Exception {
  3.   brokerService = new BrokerService();
  4.   brokerService.setPersistent(false);
  5.   brokerService.setUseJmx(true);
  6.   String connectionUri = brokerService.addConnector("tcp://localhost:0").getPublishableConnectString();
  7.   brokerService.start();
  8.   brokerService.waitUntilStarted();
  9.   ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(connectionUri);
  10.   final Connection conn = connectionFactory.createConnection();
  11.   try {
  12.     conn.start();
  13.     final Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
  14.     final Destination queue = session.createQueue(testQueueName);
  15.     final Message toSend = session.createMessage();
  16.     toSend.setStringProperty("foo", "bar");
  17.     final MessageProducer producer = session.createProducer(queue);
  18.     producer.send(queue, toSend);
  19.   } finally {
  20.     conn.close();
  21.   }
  22. }

代码示例来源：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 attemptToReadDisallowedRedeliveredPropertyIsNotFatal() throws JMSException {
  3.   DefaultJmsHeaderMapper mapper = new DefaultJmsHeaderMapper();
  4.   javax.jms.Message jmsMessage = new StubTextMessage() {
  5.     @Override
  6.     public boolean getJMSRedelivered() throws JMSException {
  7.       throw new JMSException("illegal property");
  8.     }
  9.   };
  10.   jmsMessage.setStringProperty("foo", "bar");
  11.   Map<String, Object> headers = mapper.toHeaders(jmsMessage);
  12.   assertNull(headers.get(JmsHeaders.REDELIVERED));
  13.   assertNotNull(headers.get("foo"));
  14.   assertEquals("bar", headers.get("foo"));
  15. }

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

  1. @Test
  2. public void attemptToReadDisallowedTypePropertyIsNotFatal() throws JMSException {
  3.   DefaultJmsHeaderMapper mapper = new DefaultJmsHeaderMapper();
  4.   javax.jms.Message jmsMessage = new StubTextMessage() {
  5.     @Override
  6.     public String getJMSType() throws JMSException {
  7.       throw new JMSException("illegal property");
  8.     }
  9.   };
  10.   jmsMessage.setStringProperty("foo", "bar");
  11.   Map<String, Object> headers = mapper.toHeaders(jmsMessage);
  12.   assertNull(headers.get(JmsHeaders.TYPE));
  13.   assertNotNull(headers.get("foo"));
  14.   assertEquals("bar", headers.get("foo"));
  15. }

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

  1. @Test
  2. public void attemptToReadDisallowedCorrelationIdPropertyIsNotFatal() throws JMSException {
  3.   DefaultJmsHeaderMapper mapper = new DefaultJmsHeaderMapper();
  4.   javax.jms.Message jmsMessage = new StubTextMessage() {
  5.     @Override
  6.     public String getJMSCorrelationID() throws JMSException {
  7.       throw new JMSException("illegal property");
  8.     }
  9.   };
  10.   jmsMessage.setStringProperty("foo", "bar");
  11.   Map<String, Object> headers = mapper.toHeaders(jmsMessage);
  12.   assertNull(headers.get(JmsHeaders.CORRELATION_ID));
  13.   assertNotNull(headers.get("foo"));
  14.   assertEquals("bar", headers.get("foo"));
  15. }

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

  1. @Test
  2. public void attemptToReadDisallowedReplyToPropertyIsNotFatal() throws JMSException {
  3.   DefaultJmsHeaderMapper mapper = new DefaultJmsHeaderMapper();
  4.   javax.jms.Message jmsMessage = new StubTextMessage() {
  5.     @Override
  6.     public Destination getJMSReplyTo() throws JMSException {
  7.       throw new JMSException("illegal property");
  8.     }
  9.   };
  10.   jmsMessage.setStringProperty("foo", "bar");
  11.   Map<String, Object> headers = mapper.toHeaders(jmsMessage);
  12.   assertNull(headers.get(JmsHeaders.REPLY_TO));
  13.   assertNotNull(headers.get("foo"));
  14.   assertEquals("bar", headers.get("foo"));
  15. }

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

  1. @Test
  2. public void attemptToReadDisallowedMessageIdPropertyIsNotFatal() throws JMSException {
  3.   DefaultJmsHeaderMapper mapper = new DefaultJmsHeaderMapper();
  4.   javax.jms.Message jmsMessage = new StubTextMessage() {
  5.     @Override
  6.     public String getJMSMessageID() throws JMSException {
  7.       throw new JMSException("illegal property");
  8.     }
  9.   };
  10.   jmsMessage.setStringProperty("foo", "bar");
  11.   Map<String, Object> headers = mapper.toHeaders(jmsMessage);
  12.   assertNull(headers.get(JmsHeaders.MESSAGE_ID));
  13.   assertNotNull(headers.get("foo"));
  14.   assertEquals("bar", headers.get("foo"));
  15. }

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

  1. public void fromHeaders(MessageHeaders headers, javax.jms.Message jmsMessage) {
  2.   super.fromHeaders(headers, jmsMessage);
  3.   String messageHistory = headers.get(MessageHistory.HEADER_NAME, MessageHistory.class).toString();
  4.   try {
  5.     jmsMessage.setStringProperty("outbound_history", messageHistory);
  6.   }
  7.   catch (Exception e) {
  8.     throw new MessagingException("Problem setting JMS properties", e);
  9.   }
  10. }

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

  1. @Test
  2. public void testContentTypePropertyMappedToHeader() throws JMSException {
  3.   javax.jms.Message jmsMessage = new StubTextMessage();
  4.   jmsMessage.setStringProperty("content_type", "foo");
  5.   DefaultJmsHeaderMapper mapper = new DefaultJmsHeaderMapper();
  6.   Map<String, Object> headers = mapper.toHeaders(jmsMessage);
  7.   Object attrib = headers.get(MessageHeaders.CONTENT_TYPE);
  8.   assertNotNull(attrib);
  9.   assertEquals("foo", attrib);
  10. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Message类方法

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