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

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

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

Message.getObjectProperty介绍

[英]Returns the value of the Java object property with the specified name.

This method can be used to return, in objectified format, an object that has been stored as a property in the message with the equivalent setObjectProperty method call, or its equivalent primitive settypeProperty method.
[中]返回具有指定名称的Java对象属性的值。
此方法可用于以对象化格式返回对象，该对象已作为属性存储在消息中，并具有等效的setObjectProperty方法调用或其等效的基元settypeProperty方法。

代码示例

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

  1. protected int extractProducerCountFromMessage(Message message, int count) {
  2.   try {
  3.     Object value = message.getObjectProperty("producerCount");
  4.     if (value instanceof Number) {
  5.       Number n = (Number)value;
  6.       return n.intValue();
  7.     }
  8.     LOG.warn("No producerCount header available on the message: " + message);
  9.   } catch (Exception e) {
  10.     LOG.warn("Failed to extract producerCount from message: " + message + ".Reason: " + e, e);
  11.   }
  12.   return count;
  13. }

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

  1. /**
  2.  * Lets rely by default on the broker telling us what the consumer count is
  3.  * as it can ensure that we are up to date at all times and have not
  4.  * received messages out of order etc.
  5.  */
  6. protected int extractConsumerCountFromMessage(Message message, int count) {
  7.   try {
  8.     Object value = message.getObjectProperty("consumerCount");
  9.     if (value instanceof Number) {
  10.       Number n = (Number)value;
  11.       return n.intValue();
  12.     }
  13.     LOG.warn("No consumerCount header available on the message: " + message);
  14.   } catch (Exception e) {
  15.     LOG.warn("Failed to extract consumerCount from message: " + message + ".Reason: " + e, e);
  16.   }
  17.   return count;
  18. }

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

  1. @SuppressWarnings("unchecked")
  2. private Map<String, String> extractMessageProperties(final Message message) {
  3.   final Map<String, String> properties = new HashMap<>();
  4.   try {
  5.     final Enumeration<String> propertyNames = message.getPropertyNames();
  6.     while (propertyNames.hasMoreElements()) {
  7.       String propertyName = propertyNames.nextElement();
  8.       properties.put(propertyName, String.valueOf(message.getObjectProperty(propertyName)));
  9.     }
  10.   } catch (JMSException e) {
  11.     this.processLog.warn("Failed to extract message properties", e);
  12.   }
  13.   return properties;
  14. }

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

  1. static void doFilterProperties(
  2.   Message message, Set<String> namesToClear, ArrayList<Object> retainedProperties
  3. ) throws JMSException {
  4.  Enumeration<?> names = message.getPropertyNames();
  5.  while (names.hasMoreElements()) {
  6.   String name = (String) names.nextElement();
  7.   Object value = message.getObjectProperty(name);
  8.   if (!namesToClear.contains(name) && value != null) {
  9.    retainedProperties.add(name);
  10.    retainedProperties.add(value);
  11.   }
  12.  }
  13.  // redo the properties to keep
  14.  message.clearProperties();
  15.  for (int i = 0, length = retainedProperties.size(); i < length; i += 2) {
  16.   message.setObjectProperty(
  17.     retainedProperties.get(i).toString(),
  18.     retainedProperties.get(i + 1)
  19.   );
  20.  }
  21. }

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

  1. try {
  2.   String headerName = this.toHeaderName(propertyName);
  3.   headers.put(headerName, jmsMessage.getObjectProperty(propertyName));

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

  1. @Test
  2. public void userDefinedPropertyMappedFromHeader() throws JMSException {
  3.   Message<String> message = initBuilder()
  4.       .setHeader("foo", 123)
  5.       .build();
  6.   javax.jms.Message jmsMessage = new StubTextMessage();
  7.   mapper.fromHeaders(message.getHeaders(), jmsMessage);
  8.   Object value = jmsMessage.getObjectProperty("foo");
  9.   assertNotNull(value);
  10.   assertEquals(Integer.class, value.getClass());
  11.   assertEquals(123, ((Integer) value).intValue());
  12. }

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

  1. @Test
  2. public void propertyMappingExceptionIsNotFatal() throws JMSException {
  3.   Message<String> message = initBuilder()
  4.       .setHeader("foo", 123)
  5.       .setHeader("bad", 456)
  6.       .setHeader("bar", 789)
  7.       .build();
  8.   javax.jms.Message jmsMessage = new StubTextMessage() {
  9.     @Override
  10.     public void setObjectProperty(String name, Object value) throws JMSException {
  11.       if (name.equals("bad")) {
  12.         throw new JMSException("illegal property");
  13.       }
  14.       super.setObjectProperty(name, value);
  15.     }
  16.   };
  17.   mapper.fromHeaders(message.getHeaders(), jmsMessage);
  18.   Object foo = jmsMessage.getObjectProperty("foo");
  19.   assertNotNull(foo);
  20.   Object bar = jmsMessage.getObjectProperty("bar");
  21.   assertNotNull(bar);
  22.   Object bad = jmsMessage.getObjectProperty("bad");
  23.   assertNull(bad);
  24. }

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

  1. @Test
  2. public void illegalArgumentExceptionIsNotFatal() throws JMSException {
  3.   Message<String> message = initBuilder()
  4.       .setHeader("foo", 123)
  5.       .setHeader("bad", 456)
  6.       .setHeader("bar", 789)
  7.       .build();
  8.   javax.jms.Message jmsMessage = new StubTextMessage() {
  9.     @Override
  10.     public void setObjectProperty(String name, Object value) throws JMSException {
  11.       if (name.equals("bad")) {
  12.         throw new IllegalArgumentException("illegal property");
  13.       }
  14.       super.setObjectProperty(name, value);
  15.     }
  16.   };
  17.   mapper.fromHeaders(message.getHeaders(), jmsMessage);
  18.   Object foo = jmsMessage.getObjectProperty("foo");
  19.   assertNotNull(foo);
  20.   Object bar = jmsMessage.getObjectProperty("bar");
  21.   assertNotNull(bar);
  22.   Object bad = jmsMessage.getObjectProperty("bad");
  23.   assertNull(bad);
  24. }

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

  1. final String propName = (String) enumeration.nextElement();
  2. final Object value = message.getObjectProperty(propName);

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

  1. @Test
  2. public void userDefinedPropertyMappedFromHeaderWithCustomPrefix() throws JMSException {
  3.   Message<String> message = initBuilder()
  4.       .setHeader("foo", 123)
  5.       .build();
  6.   mapper.setOutboundPrefix("custom_");
  7.   javax.jms.Message jmsMessage = new StubTextMessage();
  8.   mapper.fromHeaders(message.getHeaders(), jmsMessage);
  9.   Object value = jmsMessage.getObjectProperty("custom_foo");
  10.   assertNotNull(value);
  11.   assertEquals(Integer.class, value.getClass());
  12.   assertEquals(123, ((Integer) value).intValue());
  13. }

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

  1. @Test
  2. public void userDefinedPropertyWithUnsupportedType() throws JMSException {
  3.   Destination destination = new Destination() {};
  4.   Message<String> message = initBuilder()
  5.       .setHeader("destination", destination)
  6.       .build();
  7.   javax.jms.Message jmsMessage = new StubTextMessage();
  8.   mapper.fromHeaders(message.getHeaders(), jmsMessage);
  9.   Object value = jmsMessage.getObjectProperty("destination");
  10.   assertNull(value);
  11. }

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

  1. @Test
  2. public void contentTypePropertyMappedFromHeader() throws JMSException {
  3.   Message<String> message = initBuilder()
  4.       .setHeader(MessageHeaders.CONTENT_TYPE, "foo")
  5.       .build();
  6.   javax.jms.Message jmsMessage = new StubTextMessage();
  7.   mapper.fromHeaders(message.getHeaders(), jmsMessage);
  8.   Object value = jmsMessage.getObjectProperty(JmsHeaderMapper.CONTENT_TYPE_PROPERTY);
  9.   assertNotNull(value);
  10.   assertEquals("foo", value);
  11. }

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

  1. String name = props.nextElement();
  2. Object prop = foreign.getObjectProperty(name);

代码示例来源：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. @Test
  2. public void testPropertyMappingExceptionIsNotFatal() throws JMSException {
  3.   Message<String> message = MessageBuilder.withPayload("test")
  4.       .setHeader("foo", new Integer(123))
  5.       .setHeader("bad", new Integer(456))
  6.       .setHeader("bar", new Integer(789))
  7.       .build();
  8.   DefaultJmsHeaderMapper mapper = new DefaultJmsHeaderMapper();
  9.   javax.jms.Message jmsMessage = new StubTextMessage() {
  10.     @Override
  11.     public void setObjectProperty(String name, Object value) throws JMSException {
  12.       if (name.equals("bad")) {
  13.         throw new JMSException("illegal property");
  14.       }
  15.       super.setObjectProperty(name, value);
  16.     }
  17.   };
  18.   mapper.fromHeaders(message.getHeaders(), jmsMessage);
  19.   Object foo = jmsMessage.getObjectProperty("foo");
  20.   assertNotNull(foo);
  21.   Object bar = jmsMessage.getObjectProperty("bar");
  22.   assertNotNull(bar);
  23.   Object bad = jmsMessage.getObjectProperty("bad");
  24.   assertNull(bad);
  25. }

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

  1. @Test
  2. public void testIllegalArgumentExceptionIsNotFatal() throws JMSException {
  3.   Message<String> message = MessageBuilder.withPayload("test")
  4.       .setHeader("foo", new Integer(123))
  5.       .setHeader("bad", new Integer(456))
  6.       .setHeader("bar", new Integer(789))
  7.       .build();
  8.   DefaultJmsHeaderMapper mapper = new DefaultJmsHeaderMapper();
  9.   javax.jms.Message jmsMessage = new StubTextMessage() {
  10.     @Override
  11.     public void setObjectProperty(String name, Object value) throws JMSException {
  12.       if (name.equals("bad")) {
  13.         throw new IllegalArgumentException("illegal property");
  14.       }
  15.       super.setObjectProperty(name, value);
  16.     }
  17.   };
  18.   mapper.fromHeaders(message.getHeaders(), jmsMessage);
  19.   Object foo = jmsMessage.getObjectProperty("foo");
  20.   assertNotNull(foo);
  21.   Object bar = jmsMessage.getObjectProperty("bar");
  22.   assertNotNull(bar);
  23.   Object bad = jmsMessage.getObjectProperty("bad");
  24.   assertNull(bad);
  25. }

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

  1. @Test
  2. public void testUserDefinedPropertyMappedFromHeader() throws JMSException {
  3.   Message<String> message = MessageBuilder.withPayload("test")
  4.       .setHeader("foo", new Integer(123))
  5.       .build();
  6.   DefaultJmsHeaderMapper mapper = new DefaultJmsHeaderMapper();
  7.   javax.jms.Message jmsMessage = new StubTextMessage();
  8.   mapper.fromHeaders(message.getHeaders(), jmsMessage);
  9.   Object value = jmsMessage.getObjectProperty("foo");
  10.   assertNotNull(value);
  11.   assertEquals(Integer.class, value.getClass());
  12.   assertEquals(123, ((Integer) value).intValue());
  13. }

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

  1. @Test
  2. public void testUserDefinedPropertyMappedFromHeaderWithCustomPrefix() throws JMSException {
  3.   Message<String> message = MessageBuilder.withPayload("test")
  4.       .setHeader("foo", new Integer(123))
  5.       .build();
  6.   DefaultJmsHeaderMapper mapper = new DefaultJmsHeaderMapper();
  7.   mapper.setOutboundPrefix("custom_");
  8.   javax.jms.Message jmsMessage = new StubTextMessage();
  9.   mapper.fromHeaders(message.getHeaders(), jmsMessage);
  10.   Object value = jmsMessage.getObjectProperty("custom_foo");
  11.   assertNotNull(value);
  12.   assertEquals(Integer.class, value.getClass());
  13.   assertEquals(123, ((Integer) value).intValue());
  14. }

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

  1. @Test
  2. public void testUserDefinedPropertyWithUnsupportedType() throws JMSException {
  3.   Destination destination = new Destination() {
  4.   };
  5.   Message<String> message = MessageBuilder.withPayload("test")
  6.       .setHeader("destination", destination)
  7.       .build();
  8.   DefaultJmsHeaderMapper mapper = new DefaultJmsHeaderMapper();
  9.   javax.jms.Message jmsMessage = new StubTextMessage();
  10.   mapper.fromHeaders(message.getHeaders(), jmsMessage);
  11.   Object value = jmsMessage.getObjectProperty("destination");
  12.   assertNull(value);
  13. }

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

  1. @Test
  2. public void testContentTypePropertyMappedFromHeader() throws JMSException {
  3.   Message<String> message = MessageBuilder.withPayload("test")
  4.       .setHeader(MessageHeaders.CONTENT_TYPE, "foo")
  5.       .build();
  6.   DefaultJmsHeaderMapper mapper = new DefaultJmsHeaderMapper();
  7.   javax.jms.Message jmsMessage = new StubTextMessage();
  8.   mapper.fromHeaders(message.getHeaders(), jmsMessage);
  9.   Object value = jmsMessage.getObjectProperty("content_type");
  10.   assertNotNull(value);
  11.   assertEquals("foo", value);
  12. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Message类方法

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