org.switchyard.Message.getContext()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(7.4k)|赞(0)|评价(0)|浏览(279)

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

Message.getContext介绍

[英]Retrieves the message context.
[中]检索消息上下文。

代码示例

代码示例来源：origin: jboss-switchyard/core

  1. @Override
  2. public Context getContext(Message message) {
  3.   if (_message != null && _message == message) {
  4.     return getContext();
  5.   }
  6.   return message.getContext();
  7. }

代码示例来源：origin: org.switchyard.components/switchyard-component-bean

  1. /**
  2.  * {@inheritDoc}
  3.  */
  4. @Override
  5. public Context getContext() {
  6.   return getMessage().getContext();
  7. }

代码示例来源：origin: jboss-switchyard/components

  1. /**
  2.  * {@inheritDoc}
  3.  */
  4. @Override
  5. public Context getContext() {
  6.   return getMessage().getContext();
  7. }

代码示例来源：origin: org.switchyard/switchyard-bus-camel

  1. @Override
  2. public Context getContext(Message message) {
  3.   if (_exchange.getIn() == message) {
  4.     return getContext();
  5.   }
  6.   return message.getContext();
  7. }

代码示例来源：origin: org.switchyard/switchyard-runtime

  1. @Override
  2. public Context getContext(Message message) {
  3.   if (_message != null && _message == message) {
  4.     return getContext();
  5.   }
  6.   return message.getContext();
  7. }

代码示例来源：origin: jboss-switchyard/core

  1. @Override
  2. public Context getContext(Message message) {
  3.   if (_exchange.getIn() == message) {
  4.     return getContext();
  5.   }
  6.   return message.getContext();
  7. }

代码示例来源：origin: org.switchyard.components/switchyard-component-common-knowledge

  1. private static Object run(Message message, Expression expression, Map<String, Object> expressionVariables) {
  2.   Map<String, Object> variables = new HashMap<String, Object>();
  3.   if (expressionVariables != null) {
  4.     variables.putAll(expressionVariables);
  5.   }
  6.   // these always take precedence!
  7.   variables.put(CONTEXT, new ContextMap(message.getContext(), Scope.MESSAGE));
  8.   variables.put(MESSAGE, message);
  9.   return expression.run(variables);
  10. }

代码示例来源：origin: jboss-switchyard/components

  1. private static Object run(Message message, Expression expression, Map<String, Object> expressionVariables) {
  2.   Map<String, Object> variables = new HashMap<String, Object>();
  3.   if (expressionVariables != null) {
  4.     variables.putAll(expressionVariables);
  5.   }
  6.   // these always take precedence!
  7.   variables.put(CONTEXT, new ContextMap(message.getContext(), Scope.MESSAGE));
  8.   variables.put(MESSAGE, message);
  9.   return expression.run(variables);
  10. }

代码示例来源：origin: org.switchyard/switchyard-api

  1. /**
  2.  * Associate this instance with the supplied message context.
  3.  * @param message associate the transform to this message
  4.  */
  5. public void associateWith(Message message) {
  6.   message.getContext().setProperty(TransformSequence.class.getName(), this)
  7.     .addLabels(BehaviorLabel.TRANSIENT.label());
  8. }

代码示例来源：origin: jboss-switchyard/core

  1. /**
  2.  * Associate this instance with the supplied message context.
  3.  * @param message associate the transform to this message
  4.  */
  5. public void associateWith(Message message) {
  6.   message.getContext().setProperty(TransformSequence.class.getName(), this)
  7.     .addLabels(BehaviorLabel.TRANSIENT.label());
  8. }

代码示例来源：origin: org.switchyard/switchyard-runtime

  1. @Override
  2. public synchronized void sendFault(Message message) {
  3.   assertMessageOK(message);
  4.   
  5.   // You can't send a fault before you send a message
  6.   if (_phase == null) {
  7.     throw RuntimeMessages.MESSAGES.sendFaultNotAllowed();
  8.   }
  9.   
  10.   _phase = ExchangePhase.OUT;
  11.   _state = ExchangeState.FAULT;
  12.   initFaultContentType();
  13.   // set relatesTo header on OUT context
  14.   message.getContext().setProperty(RELATES_TO, _message.getContext().getPropertyValue(MESSAGE_ID))
  15.     .addLabels(BehaviorLabel.TRANSIENT.label());
  16.   sendInternal(message);
  17. }

代码示例来源：origin: jboss-switchyard/core

  1. @Override
  2. public synchronized void sendFault(Message message) {
  3.   assertMessageOK(message);
  4.   
  5.   // You can't send a fault before you send a message
  6.   if (_phase == null) {
  7.     throw RuntimeMessages.MESSAGES.sendFaultNotAllowed();
  8.   }
  9.   
  10.   _phase = ExchangePhase.OUT;
  11.   _state = ExchangeState.FAULT;
  12.   initFaultContentType();
  13.   // set relatesTo header on OUT context
  14.   message.getContext().setProperty(RELATES_TO, _message.getContext().getPropertyValue(MESSAGE_ID))
  15.     .addLabels(BehaviorLabel.TRANSIENT.label());
  16.   sendInternal(message);
  17. }

代码示例来源：origin: jboss-switchyard/core

  1. private void initContentType(Message message) {
  2.   QName exchangeInputType = _contract.getConsumerOperation().getInputType();
  3.   if (exchangeInputType != null) {
  4.     message.getContext().setProperty(Exchange.CONTENT_TYPE, exchangeInputType, Scope.MESSAGE)
  5.       .addLabels(BehaviorLabel.TRANSIENT.label());
  6.   }
  7. }

代码示例来源：origin: org.switchyard/switchyard-runtime

  1. private void initContentType(Message message) {
  2.   QName exchangeInputType = _contract.getConsumerOperation().getInputType();
  3.   if (exchangeInputType != null) {
  4.     message.getContext().setProperty(Exchange.CONTENT_TYPE, exchangeInputType, Scope.MESSAGE)
  5.       .addLabels(BehaviorLabel.TRANSIENT.label());
  6.   }
  7. }

代码示例来源：origin: org.switchyard/switchyard-runtime

  1. private void initFaultContentType() {
  2.   if (_contract.getProviderOperation() != null) {
  3.     QName serviceOperationFaultType = _contract.getProviderOperation().getFaultType();
  4.     if (serviceOperationFaultType != null) {
  5.       _message.getContext().setProperty(Exchange.FAULT_TYPE, serviceOperationFaultType, Scope.MESSAGE)
  6.         .addLabels(BehaviorLabel.TRANSIENT.label());
  7.     }
  8.   }
  9. }

代码示例来源：origin: jboss-switchyard/core

  1. private void initFaultContentType() {
  2.   if (_contract.getProviderOperation() != null) {
  3.     QName serviceOperationFaultType = _contract.getProviderOperation().getFaultType();
  4.     if (serviceOperationFaultType != null) {
  5.       _message.getContext().setProperty(Exchange.FAULT_TYPE, serviceOperationFaultType, Scope.MESSAGE)
  6.         .addLabels(BehaviorLabel.TRANSIENT.label());
  7.     }
  8.   }
  9. }

代码示例来源：origin: org.switchyard/switchyard-runtime

  1. @Override
  2. public synchronized void send(Message message) {
  3.   assertMessageOK(message);
  4.   // Set exchange phase
  5.   if (_phase == null) {
  6.     _phase = ExchangePhase.IN;
  7.     initContentType(message);
  8.   } else if (_phase.equals(ExchangePhase.IN)) {
  9.     _phase = ExchangePhase.OUT;
  10.     initContentType(message);
  11.     // set relatesTo header on OUT context
  12.     Object propertyValue = _message.getContext().getPropertyValue(MESSAGE_ID);
  13.     message.getContext().setProperty(RELATES_TO, propertyValue)
  14.       .addLabels(BehaviorLabel.TRANSIENT.label());
  15.   } else {
  16.     throw RuntimeMessages.MESSAGES.sendMessageNotAllowed(_phase.toString());
  17.   }
  18.   sendInternal(message);
  19. }

代码示例来源：origin: jboss-switchyard/core

  1. @Override
  2. public synchronized void send(Message message) {
  3.   assertMessageOK(message);
  4.   // Set exchange phase
  5.   if (_phase == null) {
  6.     _phase = ExchangePhase.IN;
  7.     initContentType(message);
  8.   } else if (_phase.equals(ExchangePhase.IN)) {
  9.     _phase = ExchangePhase.OUT;
  10.     initContentType(message);
  11.     // set relatesTo header on OUT context
  12.     Object propertyValue = _message.getContext().getPropertyValue(MESSAGE_ID);
  13.     message.getContext().setProperty(RELATES_TO, propertyValue)
  14.       .addLabels(BehaviorLabel.TRANSIENT.label());
  15.   } else {
  16.     throw RuntimeMessages.MESSAGES.sendMessageNotAllowed(_phase.toString());
  17.   }
  18.   sendInternal(message);
  19. }

代码示例来源：origin: jboss-switchyard/core

  1. @Test
  2. public void testRelatesToSetOnReply() {
  3.   ServiceReference service = _domain.createInOutService(
  4.     new QName("ReplyTest"), new MockHandler().forwardInToOut());
  5.   MockHandler replyHandler = new MockHandler();
  6.   Exchange exchange = service.createExchange(replyHandler);
  7.   Message message = exchange.createMessage();
  8.   exchange.send(message);
  9.   String requestId = message.getContext().getPropertyValue(Exchange.MESSAGE_ID);
  10.   String replyId = exchange.getMessage().getContext().getPropertyValue(Exchange.MESSAGE_ID);
  11.   String replyRelatesTo = exchange.getMessage().getContext().getPropertyValue(Exchange.RELATES_TO);
  12.   Assert.assertEquals(requestId, replyRelatesTo);
  13.   Assert.assertFalse(requestId.equals(replyId));
  14. }

代码示例来源：origin: jboss-switchyard/core

  1. @Test
  2. public void testMessageIdSetOnSend() {
  3.   ServiceReference service = _domain.createInOnlyService(new QName("IdTest"));
  4.   Exchange exchange = service.createExchange();
  5.   exchange.send(exchange.createMessage());
  6.   Assert.assertNotNull(exchange.getMessage().getContext().getProperty(Exchange.MESSAGE_ID));
  7. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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