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

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

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

Message.setObjectProperty介绍

[英]Sets a Java object property value with the specified name into the message.

Note that this method works only for the objectified primitive object types ( Integer, Double, Long ...) and String objects.
[中]在消息中设置具有指定名称的Java对象属性值。
请注意，此方法仅适用于对象化的基本对象类型（整数、双精度、长…）和字符串对象。

代码示例

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

  1. try {
  2.   String propertyName = this.fromHeaderName(headerName);
  3.   jmsMessage.setObjectProperty(propertyName, value);

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

  1. /**
  2. * Sets all properties we carry onto the message.
  3. *
  4. * @param message
  5. * @throws JMSException
  6. */
  7. private void setProperties(Message message) throws JMSException {
  8.  for (SimpleString name : properties.getPropertyNames()) {
  9.    message.setObjectProperty(name.toString(), properties.getProperty(name));
  10.  }
  11. }

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

  1. message.setFloatProperty(jmsPropName, Float.parseFloat(value));
  2. } else if (type.equalsIgnoreCase(PROP_TYPE_OBJECT)) {
  3.   message.setObjectProperty(jmsPropName, value);
  4. } else {
  5.   logger.warn("Attribute key '{}' for {} has value '{}', but expected one of: integer, string, object, byte, double, float, long, short, boolean; not adding this property",

代码示例来源：origin: stackoverflow.com

  1. Message message = session.createMessage();
  2. message.setObjectProperty("OS", "LINUX");
  3. producer.send(message);

代码示例来源：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. try {
  2.   String propertyName = this.fromHeaderName(headerName);
  3.   jmsMessage.setObjectProperty(propertyName, value);
  4. jmsMessage.setObjectProperty(propertyName, value.toString());

代码示例来源：origin: org.jboss.genericjms/generic-jms-ra-jar

  1. public void setObjectProperty(String name, Object value) throws JMSException {
  2.   message.setObjectProperty(name, value);
  3. }

代码示例来源：origin: org.apache.tomee/openejb-core

  1. private void setProperties(final Message message) throws JMSException {
  2.   for (final Map.Entry<String, Object> entry : properties.entrySet()) {
  3.     message.setObjectProperty(entry.getKey(), entry.getValue());
  4.   }
  5. }

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

  1. private void setProperties(Message message, Map<String, ? extends Object> messageProperties) throws JMSException {
  2.   if (messageProperties != null) {
  3.     for (Map.Entry<String, ? extends Object> stringObjectEntry : messageProperties.entrySet()) {
  4.       message.setObjectProperty(stringObjectEntry.getKey(), stringObjectEntry.getValue());
  5.     }
  6.   }
  7. }

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

  1. protected void setMessageProperties(Message message,
  2.     Map<String, Object> properties) throws JMSException {
  3.   for (Entry<String, Object> entry : properties.entrySet()) {
  4.     message.setObjectProperty(entry.getKey(), entry.getValue());
  5.   }
  6. }

代码示例来源：origin: com.github.hqstevenson.junit/activemq-junit

  1. public static void setMessageProperties(Message message, Map<String, Object> properties) throws JMSException {
  2.   if (properties != null) {
  3.     for (Map.Entry<String, Object> property : properties.entrySet()) {
  4.       message.setObjectProperty(property.getKey(), property.getValue());
  5.     }
  6.   }
  7. }

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

  1. protected static void fillInProperties(javax.jms.Message message, Map<String, Object> properties) throws JMSException {
  2.   for(Map.Entry<String, Object> each : properties.entrySet()) {
  3.     message.setObjectProperty(each.getKey(), each.getValue());
  4.   }
  5. }

代码示例来源：origin: org.geoserver.community/gs-jms-commons

  1. protected void updateProperties(Message message) throws JMSException {
  2.   // append the name of the server
  3.   message.setObjectProperty(
  4.       JMSConfiguration.INSTANCE_NAME_KEY,
  5.       properties.get(JMSConfiguration.INSTANCE_NAME_KEY));
  6.   // set other properties
  7.   final Set<Entry<Object, Object>> set = properties.entrySet();
  8.   final Iterator<Entry<Object, Object>> it = set.iterator();
  9.   while (it.hasNext()) {
  10.     final Entry<Object, Object> entry = it.next();
  11.     message.setObjectProperty(entry.getKey().toString(), entry.getValue());
  12.   }
  13. }

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

  1. public static void setMessageProperties(Message message, Map<String, Object> properties) {
  2.  if (properties != null && properties.size() > 0) {
  3.    for (Map.Entry<String, Object> property : properties.entrySet()) {
  4.     try {
  5.       message.setObjectProperty(property.getKey(), property.getValue());
  6.     } catch (JMSException jmsEx) {
  7.       throw new EmbeddedJMSResourceException(String.format("Failed to set property {%s = %s}", property.getKey(), property.getValue().toString()), jmsEx);
  8.     }
  9.    }
  10.  }
  11. }

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

  1. public static void setMessageProperties(Message message, Map<String, Object> properties) {
  2.  if (properties != null && properties.size() > 0) {
  3.    for (Map.Entry<String, Object> property : properties.entrySet()) {
  4.     try {
  5.       message.setObjectProperty(property.getKey(), property.getValue());
  6.     } catch (JMSException jmsEx) {
  7.       throw new EmbeddedJMSResourceException(String.format("Failed to set property {%s = %s}", property.getKey(), property.getValue().toString()), jmsEx);
  8.     }
  9.    }
  10.  }
  11. }

代码示例来源：origin: pl.edu.icm.synat/synat-platform-connector

  1. private void addProperties(final Event event, final Message message) throws JMSException {
  2.   Map<String, Object> filterableValues = event.getFilterableValues();
  3.   if (filterableValues == null) {
  4.     addDefaultProperties(event, message);
  5.   } else {
  6.     Set<Entry<String, Object>> entrySet = filterableValues.entrySet();
  7.     for (Entry<String, Object> entry : entrySet) {
  8.       message.setObjectProperty(entry.getKey(), entry.getValue());
  9.     }
  10.   }
  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: org.jboss.eap/wildfly-client-all

  1. /**
  2. * Sets all properties we carry onto the message.
  3. *
  4. * @param message
  5. * @throws JMSException
  6. */
  7. private void setProperties(Message message) throws JMSException {
  8.  for (SimpleString name : properties.getPropertyNames()) {
  9.    message.setObjectProperty(name.toString(), properties.getProperty(name));
  10.  }
  11. }

代码示例来源：origin: io.tracee/tracee-jms

  1. /**
  2.  * Writes the current TraceeContext to the given javaee message.
  3.  * This method is idempotent.
  4.  */
  5. protected void writeTraceeContextToMessage(Message message) throws JMSException {
  6.   if (!backend.isEmpty() && backend.getConfiguration().shouldProcessContext(AsyncDispatch)) {
  7.     final Map<String, String> filteredContext = backend.getConfiguration().filterDeniedParams(backend, AsyncDispatch);
  8.     message.setObjectProperty(TraceeConstants.JMS_HEADER_NAME, filteredContext);
  9.   }
  10. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Message类方法

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