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

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

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

Message.getPropertyNames介绍

[英]Returns an Enumeration of all the property names.

Note that JMS standard header fields are not considered properties and are not returned in this enumeration.
[中]返回所有属性名称的枚举。
请注意，JMS标准头字段不被视为属性，并且在此枚举中不会返回。

代码示例

代码示例来源：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. Enumeration<?> jmsPropertyNames = jmsMessage.getPropertyNames();
  2. if (jmsPropertyNames != null) {
  3.   while (jmsPropertyNames.hasMoreElements()) {

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

  1. @Test
  2. public void headerConversionLazilyInvoked() throws JMSException {
  3.   javax.jms.Message jmsMessage = mock(javax.jms.Message.class);
  4.   when(jmsMessage.getPropertyNames()).thenThrow(new IllegalArgumentException("Header failure"));
  5.   MessagingMessageListenerAdapter listener = getSimpleInstance("simple", Message.class);
  6.   Message<?> message = listener.toMessagingMessage(jmsMessage);
  7.   this.thrown.expect(IllegalArgumentException.class);
  8.   this.thrown.expectMessage("Header failure");
  9.   message.getHeaders(); // Triggers headers resolution
  10. }

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

  1. public static Map<String, String> createAttributeMap(final Message message) throws JMSException {
  2.   final Map<String, String> attributes = new HashMap<>();
  3.   final Enumeration<?> enumeration = message.getPropertyNames();
  4.   while (enumeration.hasMoreElements()) {
  5.     final String propName = (String) enumeration.nextElement();

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

  1. Map<String, String> headers = event.getHeaders();
  2. @SuppressWarnings("rawtypes")
  3. Enumeration propertyNames = message.getPropertyNames();
  4. while (propertyNames.hasMoreElements()) {
  5.  String name = propertyNames.nextElement().toString();

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

  1. for (Enumeration<String> props = foreign.getPropertyNames(); props.hasMoreElements(); ) {
  2.   String name = props.nextElement();

代码示例来源：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. Enumeration<?> jmsPropertyNames = jmsMessage.getPropertyNames();
  2. if (jmsPropertyNames != null) {
  3.   while (jmsPropertyNames.hasMoreElements()) {

代码示例来源：origin: org.eclipse.ditto/ditto-services-amqpbridge-messaging

  1. private Map<String, String> extractHeadersMapFromJmsMessage(final Message message) throws JMSException {
  2.   @SuppressWarnings("unchecked") final List<String> names = Collections.list(message.getPropertyNames());
  3.   return names.stream()
  4.       .map(key -> getPropertyAsEntry(message, key))
  5.       .filter(Objects::nonNull)
  6.       .collect(toMap(Entry::getKey, Entry::getValue));
  7. }

代码示例来源：origin: org.fusesource.fabric.bridge/fabric-bridge

  1. protected void getMessageProperties(Message message, Map<String, Object> map)
  2.     throws JMSException {
  3.   @SuppressWarnings("rawtypes")
  4.   Enumeration names;
  5.   names = message.getPropertyNames();
  6.   while (names.hasMoreElements()) {
  7.     String name = names.nextElement().toString();
  8.     Object value = message.getObjectProperty(name);
  9.     map.put(name, value);
  10.   }
  11. }

代码示例来源：origin: org.projectodd.wunderboss/wunderboss-messaging

  1. @Override
  2. public Map<String, Object> properties() {
  3.   Map<String, Object> headers = new HashMap<>();
  4.   try {
  5.     for(String name : (List<String>)Collections.list(this.baseMessage.getPropertyNames())) {
  6.      headers.put(name, this.baseMessage.getObjectProperty(name));
  7.     }
  8.   } catch (JMSException e) {
  9.     throw new IllegalStateException("Failed to read properties from message", e);
  10.   }
  11.   return headers;
  12. }

代码示例来源：origin: com.github.fridujo/spring-automocker

  1. public Map<String, Object> getHeaders() {
  2.   try {
  3.     return (Map<String, Object>) Collections.list(message.getPropertyNames())
  4.       .stream()
  5.       .collect(Collectors.toMap(Function.identity(), ThrowingFunction.silent(propertyName -> message.getObjectProperty((String) propertyName))));
  6.   } catch (JMSException e) {
  7.     throw new IllegalStateException("Unable to read JMS properties", e);
  8.   }
  9. }

代码示例来源：origin: se.ugli.jocote/jocote

  1. @SuppressWarnings("unchecked")
  2. private static Map<String, Object> properties(final javax.jms.Message message) throws JMSException {
  3.   final HashMap<String, Object> result = new HashMap<>();
  4.   final Enumeration<String> propertyNames = message.getPropertyNames();
  5.   while (propertyNames.hasMoreElements()) {
  6.     final String propertyName = propertyNames.nextElement();
  7.     result.put(propertyName, message.getObjectProperty(propertyName));
  8.   }
  9.   result.put(JMS_MESSAGE_TYPE, getJmsMessageType(message));
  10.   return result;
  11. }

代码示例来源：origin: org.ihtsdo.otf.common/otf-common

  1. public void copyProperties(Message sourceMessage, Message targetMessage, String newPropertyNamePrefix) throws JMSException {
  2.   @SuppressWarnings("unchecked")
  3.   final Enumeration<String> propertyNames = sourceMessage.getPropertyNames();
  4.   while (propertyNames.hasMoreElements()) {
  5.     final String propertyName = propertyNames.nextElement();
  6.     targetMessage.setObjectProperty(newPropertyNamePrefix + propertyName, sourceMessage.getObjectProperty(propertyName));
  7.   }
  8. }

代码示例来源：origin: rabbitmq/rabbitmq-jms-client

  1. private static void copyProperties(RMQMessage rmqMsg, Message msg) throws JMSException {
  2.     @SuppressWarnings("unchecked")
  3.     Enumeration<String> propNames = msg.getPropertyNames();
  5.     while (propNames.hasMoreElements()) {
  6.       String name = propNames.nextElement();
  7.       rmqMsg.setObjectProperty(name, msg.getObjectProperty(name));
  8.     }
  9.   }
  10. }

代码示例来源：origin: undera/jmeter-plugins

  1. @Override
  2. public Object fromMessage(Message message) throws JMSException, MessageConversionException {
  3.   Enumeration<String> names = message.getPropertyNames();
  4.   messageProperties = new HashMap<String, String>();
  5.   while (names.hasMoreElements()) {
  6.     String name = names.nextElement();
  7.     messageProperties.put(name, message.getStringProperty(name));
  8.   }
  9.   BytesMessage bm = (BytesMessage) message;
  10.   byte[] transfer = new byte[(int) bm.getBodyLength()];
  11.   bm.readBytes(transfer);
  12.   return new String(transfer);
  13. }

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

  1. private void readProperties(Message message) throws JMSException {
  2.   Enumeration<String> enm = CastUtils.cast(message.getPropertyNames());
  3.   while (enm.hasMoreElements()) {
  4.     String name = enm.nextElement();
  5.     String val = message.getStringProperty(name);
  6.     String unescapedName = name.replace("__", ".");
  7.     putProperty(unescapedName, val);
  8.   }
  9. }

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

  1. /**
  2. * Get property names
  3. *
  4. * @return The values
  5. * @throws JMSException Thrown if an error occurs
  6. */
  7. @Override
  8. public Enumeration getPropertyNames() throws JMSException {
  9.  if (ActiveMQRALogger.LOGGER.isTraceEnabled()) {
  10.    ActiveMQRALogger.LOGGER.trace("getPropertyNames()");
  11.  }
  12.  return message.getPropertyNames();
  13. }

代码示例来源：origin: de.mhus.lib/mhu-lib-jms

  1. public static IProperties getProperties(Message msg) throws JMSException {
  2.   MProperties out = new MProperties();
  3.   if (msg == null) return out;
  4.   @SuppressWarnings("unchecked")
  5.   Enumeration<String> enu = msg.getPropertyNames();
  6.   while (enu.hasMoreElements()) {
  7.     String name = enu.nextElement();
  8.     out.setProperty( name, msg.getObjectProperty(name) );
  9.   }
  10.   return out;
  11. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Message类方法

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