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

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

本文整理了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

protected int extractProducerCountFromMessage(Message message, int count) {
  try {
    Object value = message.getObjectProperty("producerCount");
    if (value instanceof Number) {
      Number n = (Number)value;
      return n.intValue();
    }
    LOG.warn("No producerCount header available on the message: " + message);
  } catch (Exception e) {
    LOG.warn("Failed to extract producerCount from message: " + message + ".Reason: " + e, e);
  }
  return count;
}

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

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

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

@SuppressWarnings("unchecked")
private Map<String, String> extractMessageProperties(final Message message) {
  final Map<String, String> properties = new HashMap<>();
  try {
    final Enumeration<String> propertyNames = message.getPropertyNames();
    while (propertyNames.hasMoreElements()) {
      String propertyName = propertyNames.nextElement();
      properties.put(propertyName, String.valueOf(message.getObjectProperty(propertyName)));
    }
  } catch (JMSException e) {
    this.processLog.warn("Failed to extract message properties", e);
  }
  return properties;
}

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

static void doFilterProperties(
  Message message, Set<String> namesToClear, ArrayList<Object> retainedProperties
) throws JMSException {
 Enumeration<?> names = message.getPropertyNames();
 while (names.hasMoreElements()) {
  String name = (String) names.nextElement();
  Object value = message.getObjectProperty(name);
  if (!namesToClear.contains(name) && value != null) {
   retainedProperties.add(name);
   retainedProperties.add(value);
  }
 }
 // redo the properties to keep
 message.clearProperties();
 for (int i = 0, length = retainedProperties.size(); i < length; i += 2) {
  message.setObjectProperty(
    retainedProperties.get(i).toString(),
    retainedProperties.get(i + 1)
  );
 }
}

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

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

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

@Test
public void userDefinedPropertyMappedFromHeader() throws JMSException {
  Message<String> message = initBuilder()
      .setHeader("foo", 123)
      .build();
  javax.jms.Message jmsMessage = new StubTextMessage();
  mapper.fromHeaders(message.getHeaders(), jmsMessage);
  Object value = jmsMessage.getObjectProperty("foo");
  assertNotNull(value);
  assertEquals(Integer.class, value.getClass());
  assertEquals(123, ((Integer) value).intValue());
}

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

@Test
public void propertyMappingExceptionIsNotFatal() throws JMSException {
  Message<String> message = initBuilder()
      .setHeader("foo", 123)
      .setHeader("bad", 456)
      .setHeader("bar", 789)
      .build();
  javax.jms.Message jmsMessage = new StubTextMessage() {
    @Override
    public void setObjectProperty(String name, Object value) throws JMSException {
      if (name.equals("bad")) {
        throw new JMSException("illegal property");
      }
      super.setObjectProperty(name, value);
    }
  };
  mapper.fromHeaders(message.getHeaders(), jmsMessage);
  Object foo = jmsMessage.getObjectProperty("foo");
  assertNotNull(foo);
  Object bar = jmsMessage.getObjectProperty("bar");
  assertNotNull(bar);
  Object bad = jmsMessage.getObjectProperty("bad");
  assertNull(bad);
}

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

@Test
public void illegalArgumentExceptionIsNotFatal() throws JMSException {
  Message<String> message = initBuilder()
      .setHeader("foo", 123)
      .setHeader("bad", 456)
      .setHeader("bar", 789)
      .build();
  javax.jms.Message jmsMessage = new StubTextMessage() {
    @Override
    public void setObjectProperty(String name, Object value) throws JMSException {
      if (name.equals("bad")) {
        throw new IllegalArgumentException("illegal property");
      }
      super.setObjectProperty(name, value);
    }
  };
  mapper.fromHeaders(message.getHeaders(), jmsMessage);
  Object foo = jmsMessage.getObjectProperty("foo");
  assertNotNull(foo);
  Object bar = jmsMessage.getObjectProperty("bar");
  assertNotNull(bar);
  Object bad = jmsMessage.getObjectProperty("bad");
  assertNull(bad);
}

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

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

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

@Test
public void userDefinedPropertyMappedFromHeaderWithCustomPrefix() throws JMSException {
  Message<String> message = initBuilder()
      .setHeader("foo", 123)
      .build();
  mapper.setOutboundPrefix("custom_");
  javax.jms.Message jmsMessage = new StubTextMessage();
  mapper.fromHeaders(message.getHeaders(), jmsMessage);
  Object value = jmsMessage.getObjectProperty("custom_foo");
  assertNotNull(value);
  assertEquals(Integer.class, value.getClass());
  assertEquals(123, ((Integer) value).intValue());
}

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

@Test
public void userDefinedPropertyWithUnsupportedType() throws JMSException {
  Destination destination = new Destination() {};
  Message<String> message = initBuilder()
      .setHeader("destination", destination)
      .build();
  javax.jms.Message jmsMessage = new StubTextMessage();
  mapper.fromHeaders(message.getHeaders(), jmsMessage);
  Object value = jmsMessage.getObjectProperty("destination");
  assertNull(value);
}

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

@Test
public void contentTypePropertyMappedFromHeader() throws JMSException {
  Message<String> message = initBuilder()
      .setHeader(MessageHeaders.CONTENT_TYPE, "foo")
      .build();
  javax.jms.Message jmsMessage = new StubTextMessage();
  mapper.fromHeaders(message.getHeaders(), jmsMessage);
  Object value = jmsMessage.getObjectProperty(JmsHeaderMapper.CONTENT_TYPE_PROPERTY);
  assertNotNull(value);
  assertEquals("foo", value);
}

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

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

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

/**
   * Copies the standard JMS and user defined properties from the givem
   * message to the specified message
   *
   * @param fromMessage the message to take the properties from
   * @param toMessage the message to add the properties to
   * @throws JMSException
   */
  public static void copyProperties(Message fromMessage, Message toMessage) throws JMSException {
    toMessage.setJMSMessageID(fromMessage.getJMSMessageID());
    toMessage.setJMSCorrelationID(fromMessage.getJMSCorrelationID());
    toMessage.setJMSReplyTo(transformDestination(fromMessage.getJMSReplyTo()));
    toMessage.setJMSDestination(transformDestination(fromMessage.getJMSDestination()));
    toMessage.setJMSDeliveryMode(fromMessage.getJMSDeliveryMode());
    toMessage.setJMSRedelivered(fromMessage.getJMSRedelivered());
    toMessage.setJMSType(fromMessage.getJMSType());
    toMessage.setJMSExpiration(fromMessage.getJMSExpiration());
    toMessage.setJMSPriority(fromMessage.getJMSPriority());
    toMessage.setJMSTimestamp(fromMessage.getJMSTimestamp());

    Enumeration propertyNames = fromMessage.getPropertyNames();

    while (propertyNames.hasMoreElements()) {
      String name = propertyNames.nextElement().toString();
      Object obj = fromMessage.getObjectProperty(name);
      toMessage.setObjectProperty(name, obj);
    }
  }
}

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

@Test
public void testPropertyMappingExceptionIsNotFatal() throws JMSException {
  Message<String> message = MessageBuilder.withPayload("test")
      .setHeader("foo", new Integer(123))
      .setHeader("bad", new Integer(456))
      .setHeader("bar", new Integer(789))
      .build();
  DefaultJmsHeaderMapper mapper = new DefaultJmsHeaderMapper();
  javax.jms.Message jmsMessage = new StubTextMessage() {
    @Override
    public void setObjectProperty(String name, Object value) throws JMSException {
      if (name.equals("bad")) {
        throw new JMSException("illegal property");
      }
      super.setObjectProperty(name, value);
    }
  };
  mapper.fromHeaders(message.getHeaders(), jmsMessage);
  Object foo = jmsMessage.getObjectProperty("foo");
  assertNotNull(foo);
  Object bar = jmsMessage.getObjectProperty("bar");
  assertNotNull(bar);
  Object bad = jmsMessage.getObjectProperty("bad");
  assertNull(bad);
}

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

@Test
public void testIllegalArgumentExceptionIsNotFatal() throws JMSException {
  Message<String> message = MessageBuilder.withPayload("test")
      .setHeader("foo", new Integer(123))
      .setHeader("bad", new Integer(456))
      .setHeader("bar", new Integer(789))
      .build();
  DefaultJmsHeaderMapper mapper = new DefaultJmsHeaderMapper();
  javax.jms.Message jmsMessage = new StubTextMessage() {
    @Override
    public void setObjectProperty(String name, Object value) throws JMSException {
      if (name.equals("bad")) {
        throw new IllegalArgumentException("illegal property");
      }
      super.setObjectProperty(name, value);
    }
  };
  mapper.fromHeaders(message.getHeaders(), jmsMessage);
  Object foo = jmsMessage.getObjectProperty("foo");
  assertNotNull(foo);
  Object bar = jmsMessage.getObjectProperty("bar");
  assertNotNull(bar);
  Object bad = jmsMessage.getObjectProperty("bad");
  assertNull(bad);
}

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

@Test
public void testUserDefinedPropertyMappedFromHeader() throws JMSException {
  Message<String> message = MessageBuilder.withPayload("test")
      .setHeader("foo", new Integer(123))
      .build();
  DefaultJmsHeaderMapper mapper = new DefaultJmsHeaderMapper();
  javax.jms.Message jmsMessage = new StubTextMessage();
  mapper.fromHeaders(message.getHeaders(), jmsMessage);
  Object value = jmsMessage.getObjectProperty("foo");
  assertNotNull(value);
  assertEquals(Integer.class, value.getClass());
  assertEquals(123, ((Integer) value).intValue());
}

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

@Test
public void testUserDefinedPropertyMappedFromHeaderWithCustomPrefix() throws JMSException {
  Message<String> message = MessageBuilder.withPayload("test")
      .setHeader("foo", new Integer(123))
      .build();
  DefaultJmsHeaderMapper mapper = new DefaultJmsHeaderMapper();
  mapper.setOutboundPrefix("custom_");
  javax.jms.Message jmsMessage = new StubTextMessage();
  mapper.fromHeaders(message.getHeaders(), jmsMessage);
  Object value = jmsMessage.getObjectProperty("custom_foo");
  assertNotNull(value);
  assertEquals(Integer.class, value.getClass());
  assertEquals(123, ((Integer) value).intValue());
}

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

@Test
public void testUserDefinedPropertyWithUnsupportedType() throws JMSException {
  Destination destination = new Destination() {
  };
  Message<String> message = MessageBuilder.withPayload("test")
      .setHeader("destination", destination)
      .build();
  DefaultJmsHeaderMapper mapper = new DefaultJmsHeaderMapper();
  javax.jms.Message jmsMessage = new StubTextMessage();
  mapper.fromHeaders(message.getHeaders(), jmsMessage);
  Object value = jmsMessage.getObjectProperty("destination");
  assertNull(value);
}

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

@Test
public void testContentTypePropertyMappedFromHeader() throws JMSException {
  Message<String> message = MessageBuilder.withPayload("test")
      .setHeader(MessageHeaders.CONTENT_TYPE, "foo")
      .build();
  DefaultJmsHeaderMapper mapper = new DefaultJmsHeaderMapper();
  javax.jms.Message jmsMessage = new StubTextMessage();
  mapper.fromHeaders(message.getHeaders(), jmsMessage);
  Object value = jmsMessage.getObjectProperty("content_type");
  assertNotNull(value);
  assertEquals("foo", value);
}

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

Message

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    Message类方法

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