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

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

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

Message.clearProperties介绍

[英]Clears a message's properties.

The message's header fields and body are not cleared.
[中]清除消息的属性。
消息的标题字段和正文未清除。

代码示例

代码示例来源: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: org.jboss.genericjms/generic-jms-ra-jar

  1. public void clearProperties() throws JMSException {
  2. message.clearProperties();
  3. }

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

  1. @Override
  2. public void clearProperties() throws JMSException {
  3. message.clearProperties();
  4. }

代码示例来源:origin: org.jboss.jbossas/jboss-as-connector

  1. public void clearProperties() throws JMSException
  2. {
  3. message.clearProperties();
  4. }

代码示例来源:origin: org.apache.qpid/qpid-jca

  1. /**
  2. * Clear properties
  3. * @exception JMSException Thrown if an error occurs
  4. */
  5. public void clearProperties() throws JMSException
  6. {
  7. if (_log.isTraceEnabled())
  8. {
  9. _log.trace("clearProperties()");
  10. }
  11. _message.clearProperties();
  12. }

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

  1. /**
  2. * Clear properties
  3. *
  4. * @throws JMSException Thrown if an error occurs
  5. */
  6. @Override
  7. public void clearProperties() throws JMSException {
  8. if (ActiveMQRALogger.LOGGER.isTraceEnabled()) {
  9. ActiveMQRALogger.LOGGER.trace("clearProperties()");
  10. }
  11. message.clearProperties();
  12. }

代码示例来源:origin: org.apache.geronimo.ext.openejb/openejb-itests-beans

  1. @AroundInvoke
  2. public Object mdbInterceptor(InvocationContext ctx) throws Exception
  3. {
  4. Object[] objArr = ctx.getParameters();
  5. Message msg = (Message)objArr[0];
  6. msg.clearProperties();
  7. msg.setBooleanProperty("ClassLevelBusinessMethodInterception",true);
  8. ctx.setParameters(objArr);
  9. return ctx.proceed();
  10. }

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

  1. /**
  2. * Clear properties
  3. *
  4. * @throws JMSException Thrown if an error occurs
  5. */
  6. @Override
  7. public void clearProperties() throws JMSException {
  8. if (ActiveMQRALogger.LOGGER.isTraceEnabled()) {
  9. ActiveMQRALogger.LOGGER.trace("clearProperties()");
  10. }
  11. message.clearProperties();
  12. }

代码示例来源:origin: org.apache.openejb/openejb-itests-beans

  1. @AroundInvoke
  2. public Object mdbInterceptor(final InvocationContext ctx) throws Exception {
  3. final Object[] objArr = ctx.getParameters();
  4. final Message msg = (Message) objArr[0];
  5. msg.clearProperties();
  6. msg.setBooleanProperty("ClassLevelBusinessMethodInterception", true);
  7. ctx.setParameters(objArr);
  8. return ctx.proceed();
  9. }

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

  1. private static void copyProperties(final Message msg) throws JMSException {
  2. Enumeration<String> en = msg.getPropertyNames();
  3. Map<String, Object> oldProps = null;
  4. while (en.hasMoreElements()) {
  5. String propName = en.nextElement();
  6. if (oldProps == null) {
  7. oldProps = new HashMap<>();
  8. }
  9. oldProps.put(propName, msg.getObjectProperty(propName));
  10. }
  11. msg.clearProperties();
  12. if (oldProps != null) {
  13. for (Entry<String, Object> entry : oldProps.entrySet()) {
  14. String propName = entry.getKey();
  15. Object val = entry.getValue();
  16. if (val instanceof byte[] == false) {
  17. //Can't set byte[] array props through the JMS API - if we're bridging an ActiveMQ Artemis message it might have such props
  18. msg.setObjectProperty(propName, entry.getValue());
  19. } else if (msg instanceof ActiveMQMessage) {
  20. ((ActiveMQMessage) msg).getCoreMessage().putBytesProperty(propName, (byte[]) val);
  21. }
  22. }
  23. }
  24. }

代码示例来源:origin: org.apache.camel/camel-jms

  1. jmsMessage.clearProperties();
  2. for (Entry<String, Object> entry : map.entrySet()) {
  3. jmsMessage.setObjectProperty(entry.getKey(), entry.getValue());

代码示例来源:origin: org.hornetq/hornetq-jms

  1. msg.clearProperties();

代码示例来源:origin: org.ballerinalang/ballerina-jms

  1. @Override
  2. public void execute(Context context, CallableUnitCallback callableUnitCallback) {
  3. Struct messageStruct = BallerinaAdapter.getReceiverObject(context);
  4. Message message = BallerinaAdapter.getNativeObject(messageStruct,
  5. Constants.JMS_MESSAGE_OBJECT,
  6. Message.class,
  7. context);
  8. try {
  9. message.clearProperties();
  10. } catch (JMSException e) {
  11. BallerinaAdapter.returnError("Error when clearing the message properties", context, e);
  12. }
  13. }
  14. }

代码示例来源:origin: org.jboss.jbossas/jboss-as-connector

  1. msg.clearProperties();

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

  1. @Test
  2. public void testClearMessage() throws Exception {
  3. queueProducer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
  4. Message message = queueProducerSession.createTextMessage("some message");
  5. queueProducer.send(message);
  6. message = queueConsumer.receive(1000);
  7. ProxyAssertSupport.assertNotNull(message);
  8. message.clearProperties();
  9. ProxyAssertSupport.assertNotNull(message.getJMSDestination());
  10. }

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

  1. currentMessage.clearProperties();
  2. setMessageProperties(currentMessage, properties);
  3. properties.clear();

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

  1. currentMessage.clearProperties();
  2. setMessageProperties(currentMessage, properties);
  3. properties.clear();

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

  1. m2.clearProperties();

相关文章