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

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

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

Message.getContent介绍

[英]Returns the content from the body of the message.
[中]返回消息正文中的内容。

代码示例

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

  1. @Override
  2. public Throwable getCause() {
  3. if (Throwable.class.isAssignableFrom(_faultMessage.getContent().getClass())) {
  4. return _faultMessage.getContent(Throwable.class);
  5. } else {
  6. return super.getCause();
  7. }
  8. }
  9. }

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

  1. @Override
  2. public Throwable getCause() {
  3. if (Throwable.class.isAssignableFrom(_faultMessage.getContent().getClass())) {
  4. return _faultMessage.getContent(Throwable.class);
  5. } else {
  6. return super.getCause();
  7. }
  8. }
  9. }

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

  1. private static Object[] castArg(Method method, Message message) {
  2. if (method.getParameterTypes().length == 1 && message != null) {
  3. return new Object[]{message.getContent(method.getParameterTypes()[0])};
  4. }
  5. return null;
  6. }

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

  1. private static Object[] castArg(Method method, Message message) {
  2. if (method.getParameterTypes().length == 1 && message != null) {
  3. return new Object[]{message.getContent(method.getParameterTypes()[0])};
  4. }
  5. return null;
  6. }

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

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

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

  1. /**
  2. * {@inheritDoc}
  3. */
  4. @Override
  5. public <T> T getContent(Class<T> type) {
  6. return getMessage().getContent(type);
  7. }

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

  1. /**
  2. * {@inheritDoc}
  3. */
  4. @Override
  5. public <T> T getContent(Class<T> type) {
  6. return getMessage().getContent(type);
  7. }

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

  1. private static List<Object> getInputList(Message message, List<ExpressionMapping> inputs, KnowledgeRuntimeEngine runtime) {
  2. List<Object> list = new ArrayList<Object>();
  3. if (inputs.size() > 0) {
  4. list.addAll(getList(message, inputs));
  5. } else {
  6. expand(filterRemoteDefaultInputContent(message.getContent(), runtime), list);
  7. }
  8. return list;
  9. }

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

  1. private static List<Object> getInputList(Message message, List<ExpressionMapping> inputs, KnowledgeRuntimeEngine runtime) {
  2. List<Object> list = new ArrayList<Object>();
  3. if (inputs.size() > 0) {
  4. list.addAll(getList(message, inputs));
  5. } else {
  6. expand(filterRemoteDefaultInputContent(message.getContent(), runtime), list);
  7. }
  8. return list;
  9. }

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

  1. @Override
  2. public void handleFault(Exchange exchange) {
  3. _fault = exchange.getMessage().getContent();
  4. super.handleFault(exchange);
  5. }
  6. }

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

  1. @Override
  2. public void handleFault(Exchange exchange) {
  3. _fault = exchange.getMessage().getContent();
  4. super.handleFault(exchange);
  5. }
  6. }

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

  1. private static List<Object> getList(Message message, List<ExpressionMapping> expressionMappings) {
  2. List<Object> list = new ArrayList<Object>();
  3. if (expressionMappings == null || expressionMappings.size() == 0) {
  4. expand(message.getContent(), list);
  5. } else {
  6. Map<String, List<Object>> listMap = getListMap(message, expressionMappings, true, toVariable(message));
  7. for (List<Object> value : listMap.values()) {
  8. expand(value, list);
  9. }
  10. }
  11. return list;
  12. }

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

  1. private static List<Object> getList(Message message, List<ExpressionMapping> expressionMappings) {
  2. List<Object> list = new ArrayList<Object>();
  3. if (expressionMappings == null || expressionMappings.size() == 0) {
  4. expand(message.getContent(), list);
  5. } else {
  6. Map<String, List<Object>> listMap = getListMap(message, expressionMappings, true, toVariable(message));
  7. for (List<Object> value : listMap.values()) {
  8. expand(value, list);
  9. }
  10. }
  11. return list;
  12. }

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

  1. @Test
  2. public void testContent() throws Exception {
  3. final String message = "Hello There!";
  4. _message.setContent(message);
  5. Assert.assertEquals(message, _message.getContent());
  6. // the following tests to make sure casting to same type works
  7. String content = _message.getContent(String.class);
  8. Assert.assertEquals(message, content);
  9. }

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

  1. @Override
  2. public void handleMessage(Exchange exchange) throws HandlerException {
  3. String content = (String) exchange.getMessage().getContent();
  4. if (content.equals("Hello there, SwitchYard")) {
  5. success=true;
  6. }
  7. }
  8. }

代码示例来源:origin: org.switchyard.quickstarts/switchyard-bean-service

  1. @Override
  2. public void after(String target, Exchange exchange) throws HandlerException {
  3. // We only want to intercept successful replies from OrderService
  4. if (exchange.getProvider().getName().getLocalPart().equals("OrderService")
  5. && ExchangeState.OK.equals(exchange.getState())) {
  6. OrderAck orderAck = exchange.getMessage().getContent(OrderAck.class);
  7. orderAck.setStatus(orderAck.getStatus() + " [intercepted]");
  8. }
  9. }

代码示例来源:origin: org.switchyard.quickstarts/switchyard-quickstart-http-binding

  1. /**
  2. * {@inheritDoc}
  3. */
  4. @Override
  5. public HttpBindingData decompose(Exchange exchange, HttpBindingData target) throws Exception {
  6. Object content = exchange.getMessage().getContent();
  7. if ((content instanceof String) && (content.equals(""))) {
  8. exchange.getContext().setProperty(HttpContextMapper.HTTP_RESPONSE_STATUS, 404).addLabels(new String[]{EndpointLabel.HTTP.label()});
  9. }
  10. target = super.decompose(exchange, target);
  11. return target;
  12. }

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

  1. @Override
  2. public org.switchyard.Message compose(JMSBindingData source, Exchange exchange) throws Exception {
  3. org.switchyard.Message msg = super.compose(source, exchange);
  4. msg.setContent(msg.getContent(String.class) + "test");
  5. return msg;
  6. }

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

  1. /**
  2. * {@inheritDoc}
  3. */
  4. @SuppressWarnings("unchecked")
  5. @Override
  6. public IndexedRecordBindingData decompose(Exchange exchange, IndexedRecordBindingData target) throws Exception {
  7. Message sourceMessage = exchange.getMessage();
  8. getContextMapper().mapTo(exchange.getContext(), target);
  9. final List<?> content = sourceMessage.getContent(List.class);
  10. target.getRecord().addAll(content);
  11. return target;
  12. }

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

  1. @Override
  2. public JMSBindingData decompose(Exchange exchange, JMSBindingData target) throws Exception {
  3. exchange.getMessage().setContent(exchange.getMessage().getContent(String.class)+"test");
  4. return super.decompose(exchange, target);
  5. }

相关文章