org.apache.tuscany.sca.invocation.Message.setFaultBody()方法的使用及代码示例

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

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

Message.setFaultBody介绍

[英]Set the message body with a fault object. After this method is called, isFault() returns true.
[中]将消息正文设置为故障对象。调用此方法后，isFault（）返回true。

代码示例

代码示例来源：origin: com.jns.apps/scallop-binding-rmi-runtime

  1. public Message invoke(Message msg) {
  2.   try {
  3.     Object[] args = msg.getBody();
  4.     Object resp = invokeTarget(args);
  5.     msg.setBody(resp);
  6.   } catch (InvocationTargetException e) {
  7.     msg.setFaultBody(e.getCause());
  8.   } catch (Exception e) {
  9.     msg.setFaultBody(e);
  10.   }
  11.   return msg;
  12. }

代码示例来源：origin: com.jns.apps/scallop-binding-rmi-runtime

  1. public Message invoke(Message msg) {
  2.   try {
  3.     Object[] args = msg.getBody();
  4.     Object resp = invokeTarget(args);
  5.     msg.setBody(resp);
  6.   } catch (InvocationTargetException e) {
  7.     if (e.getCause() instanceof ServiceRuntimeException) {
  8.       msg.setFaultBody(e.getCause().getCause());
  9.     } else {
  10.       msg.setFaultBody(e.getCause());
  11.     }
  12.   } catch (Exception e) {
  13.     msg.setFaultBody(e);
  14.   }
  15.   return msg;
  16. }

代码示例来源：origin: com.jns.apps/scallop-binding-rmi-runtime

  1. public Message invoke(Message msg) {
  2.   try {
  3.     Object[] args = msg.getBody();
  4.     Object resp = invokeTarget(args);
  5.     msg.setBody(resp);
  6.   } catch (InvocationTargetException e) {
  7.     if (e.getCause() instanceof ServiceRuntimeException) {
  8.       msg.setFaultBody(e.getCause().getCause());
  9.     } else {
  10.       msg.setFaultBody(e.getCause());
  11.     }
  12.   } catch (Exception e) {
  13.     msg.setFaultBody(e);
  14.   }
  15.   return msg;
  16. }

代码示例来源：origin: org.apache.tuscany.sca/tuscany-binding-rmi-runtime

  1. public Message invoke(Message msg) {
  2.   try {
  3.     Object[] args = msg.getBody();
  4.     Object resp = invokeTarget(args);
  5.     msg.setBody(resp);
  6.   } catch (InvocationTargetException e) {
  7.     msg.setFaultBody(e.getCause());
  8.   } catch (Throwable e) {
  9.     msg.setFaultBody(e);
  10.   }
  11.   return msg;
  12. }

代码示例来源：origin: org.apache.tuscany.sca.aggregation/tuscany-binding-rmi-runtime-aggregation

  1. public Message invoke(Message msg) {
  2.   try {
  3.     Object[] args = msg.getBody();
  4.     Object resp = invokeTarget(args);
  5.     msg.setBody(resp);
  6.   } catch (InvocationTargetException e) {
  7.     msg.setFaultBody(e.getCause());
  8.   } catch (Throwable e) {
  9.     msg.setFaultBody(e);
  10.   }
  11.   return msg;
  12. }

代码示例来源：origin: org.apache.tuscany.sca/tuscany-implementation-osgi-runtime

  1. public Message invoke(Message msg) {
  2.   try {
  3.     Object resp = invokeTarget(msg);
  4.     msg.setBody(resp);
  5.   } catch (InvocationTargetException e) {
  6.     msg.setFaultBody(e.getCause());
  7.   }
  8.   return msg;
  9. }

代码示例来源：origin: org.apache.tuscany.sca/tuscany-implementation-spring-runtime

  1. /**
  2.  * @param msg the message to invoke on the target bean
  3.  */
  4. public Message invoke(Message msg) {
  5.   try {
  6.     Object resp = doInvoke(msg.getBody());
  7.     msg.setBody(resp);
  8.   } catch (SpringInvocationException e) {
  9.     msg.setFaultBody(e.getCause());
  10.   } catch (Throwable e) {
  11.     msg.setFaultBody(e);
  12.   }
  13.   //System.out.println("Spring Invoker - invoke called");
  14.   return msg;
  15. } // end method invoke

代码示例来源：origin: org.apache.tuscany.sca/tuscany-base-runtime

  1. private void setFault(Message msg, SOAPFaultException e) {
  2.   SOAPFault fault = e.getFault();
  3.   Detail detail = fault.getDetail();
  4.   if (detail != null) {
  5.     for (Iterator i = detail.getDetailEntries(); i.hasNext();) {
  6.       DetailEntry entry = (DetailEntry)i.next();
  7.       FaultException fe = new FaultException(e.getMessage(), entry, e);
  8.       fe.setFaultName(entry.getElementQName());
  9.       msg.setFaultBody(fe);
  10.     }
  11.   } else {
  12.     msg.setFaultBody(e);
  13.   }
  14. }

代码示例来源：origin: org.apache.tuscany.sca/tuscany-implementation-bpel-runtime

  1. public Message invoke(Message msg) {
  2.   try {
  3.     if( isCallback ) {
  4.       // Extract the callback endpoint metadata
  5.       callbackEPR = msg.getFrom();
  6.     } // end if
  7.     Object[] args = msg.getBody();
  8.     Object resp = doTheWork(args);
  9.     msg.setBody(resp);
  10.   } catch (InvocationTargetException e) {
  11.     msg.setFaultBody(e.getCause());
  12.   }
  13.   return msg;
  14. }

代码示例来源：origin: org.apache.tuscany.sca/tuscany-binding-jms-runtime

  1. public Message invokeResponse(Message msg) {
  2.   if (msg.getBody() != null){
  3.     Object response = responseMessageProcessor.extractPayloadFromJMSMessage((javax.jms.Message)msg.getBody());
  4.     if (response instanceof InvocationTargetException) {
  5.       msg.setFaultBody(((InvocationTargetException) response).getCause());
  6.     } else {
  7.       if (response != null){
  8.         msg.setBody(response);
  9.       } else {
  10.         msg.setBody(null);
  11.       }
  12.     }
  13.   }
  14.   return msg;
  15. }

代码示例来源：origin: org.apache.tuscany.sca/tuscany-binding-jms-runtime

  1. public Message invokeResponse(Message msg) {
  2.   if (msg.getBody() != null){
  3.     Object response = responseMessageProcessor.extractPayloadFromJMSMessage((javax.jms.Message)msg.getBody());
  4.     
  5.     if (response instanceof InvocationTargetException) {
  6.       msg.setFaultBody(((InvocationTargetException) response).getCause());
  7.     } else {
  8.       if (response != null){
  9.         msg.setBody(response);
  10.       } else {
  11.         msg.setBody(null);
  12.       }
  13.     }
  14.   }
  15.   return msg;
  16. }

代码示例来源：origin: org.apache.tuscany.sca/tuscany-binding-jms-runtime

  1. public Message invokeResponse(Message msg) {
  2.   if (msg.getBody() != null){
  3.     Object response = responseMessageProcessor.extractPayloadFromJMSMessage((javax.jms.Message)msg.getBody());
  4.     
  5.     if (response instanceof InvocationTargetException) {
  6.       msg.setFaultBody(((InvocationTargetException) response).getCause());
  7.     } else {
  8.       if (response != null){
  9.         msg.setBody(response);
  10.       } else {
  11.         msg.setBody(null);
  12.       }
  13.     }
  14.   }
  15.   return msg;
  16. }

代码示例来源：origin: org.apache.tuscany.sca/tuscany-binding-ws-runtime-axis2

  1. public Message invoke(Message msg) {
  2.   try {
  3.     Object resp = null; 
  4.     
  5.     if (msg.getOperation().isNonBlocking()) {
  6.       resp = invokeTargetOneWay(msg);
  7.     } else {
  8.       resp = invokeTarget(msg);
  9.     }
  10.     
  11.     msg.setBody(resp);
  12.   } catch (AxisFault e) {
  13.     if (e.getDetail() != null ) {
  14.       FaultException f = new FaultException(e.getMessage(), e.getDetail(), e);
  15.       f.setFaultName(e.getDetail().getQName());
  16.       msg.setFaultBody(f);
  17.     } else {
  18.       msg.setFaultBody(e);
  19.     }
  20.   } catch (Throwable e) {
  21.     msg.setFaultBody(e);
  22.   }
  23.   return msg;
  24. }

代码示例来源：origin: org.apache.tuscany.sca/tuscany-implementation-script-runtime

  1. public Message invoke(Message msg) {
  2.   try {
  3.     Object resp = doInvoke((Object[])msg.getBody(), msg.getOperation());
  4.     msg.setBody(resp);
  5.   } catch (ScriptException e) {
  6.     msg.setFaultBody(e.getCause());
  7.   }
  8.   return msg;
  9. }

代码示例来源：origin: org.apache.tuscany.sca/tuscany-binding-sca-runtime

  1. /**
  2.  * Regular (sync) processing of response message
  3.  */
  4. public Message processResponse(Message msg){
  5.   if (passByValue) {
  6.     // Note source and target operation swapped so result is in source class loader
  7.     if (msg.isFault()) {
  8.       Object transformedFault = bindingSCATransformer.transformFault(msg.getBody());
  9.       msg.setFaultBody(transformedFault);
  10.     } else {
  11.       Object transformedOutput = bindingSCATransformer.transformOutput(msg.getBody()); 
  12.       msg.setBody(transformedOutput);
  13.     } // end if
  14.   } // end if
  15.   return msg;
  16. } // end method processResponse

代码示例来源：origin: org.apache.tuscany.sca/tuscany-base-runtime

  1. /**
  2.  * Regular (sync) processing of response message
  3.  */
  4. public Message processResponse(Message msg){
  5.   if (passByValue) {
  6.     // Note source and target operation swapped so result is in source class loader
  7.     if (msg.isFault()) {
  8.       Object transformedFault = bindingSCATransformer.transformFault(msg.getBody());
  9.       msg.setFaultBody(transformedFault);
  10.     } else {
  11.       Object transformedOutput = bindingSCATransformer.transformOutput(msg.getBody()); 
  12.       msg.setBody(transformedOutput);
  13.     } // end if
  14.   } // end if
  15.   return msg;
  16. } // end method processResponse

代码示例来源：origin: org.apache.tuscany.sca/tuscany-binding-jms-runtime

  1. public Message invokeResponse(Message msg) {
  2.   if (msg.getBody() != null){
  3.     javax.jms.Message jmsMsg = (javax.jms.Message)msg.getBody();
  4.     Object response = responseMessageProcessor.extractPayloadFromJMSMessage(jmsMsg);
  5.     if (response != null ){
  6.       msg.setBody(response);
  7.       try {
  8.         if (jmsMsg.getBooleanProperty(JMSBindingConstants.FAULT_PROPERTY)) {
  9.           FaultException e = new FaultException("remote exception", response);
  10.           xmlhelper.setFaultName(e, response);
  11.           msg.setFaultBody(e);
  12.         }
  13.       } catch (JMSException e) {
  14.         throw new JMSBindingException(e);
  15.       }
  16.     } else {
  17.       msg.setBody(null);
  18.     }
  19.   }
  20.   return msg;
  21. }

代码示例来源：origin: org.apache.tuscany.sca/tuscany-binding-jms-runtime

  1. public Message invokeResponse(Message msg) {
  2.   if (msg.getBody() != null){
  3.     javax.jms.Message jmsMsg = (javax.jms.Message)msg.getBody();
  4.     Object response = responseMessageProcessor.extractPayloadFromJMSMessage(jmsMsg);
  5.     if (response != null ){
  6.       msg.setBody(response);
  7.       try {
  8.         if (jmsMsg.getBooleanProperty(JMSBindingConstants.FAULT_PROPERTY)) {
  9.           FaultException e = new FaultException("remote exception", response);
  10.           xmlhelper.setFaultName(e, response);
  11.           msg.setFaultBody(e);
  12.         }
  13.       } catch (JMSException e) {
  14.         throw new JMSBindingException(e);
  15.       }
  16.     } else {
  17.       msg.setBody(null);
  18.     }
  19.   }
  20.   return msg;
  21. }

代码示例来源：origin: org.apache.tuscany.sca/tuscany-base-runtime

  1. public Message invoke(Message msg) {
  2.   if (chain.allowsPassByReference()) {
  3.     return nextInvoker.invoke(msg);
  4.   }
  5.   msg.setBody(mediator.copyInput(msg.getBody(), operation));
  6.   Message resultMsg = nextInvoker.invoke(msg);
  7.   if (!resultMsg.isFault() && operation.getOutputType() != null) {
  8.     resultMsg.setBody(mediator.copyOutput(resultMsg.getBody(), operation));
  9.   }
  10.   if (resultMsg.isFault()) {
  11.     resultMsg.setFaultBody(mediator.copyFault(resultMsg.getBody(), operation));
  12.   }
  13.   return resultMsg;
  14. }

代码示例来源：origin: org.apache.tuscany.sca/tuscany-core-databinding

  1. public Message invoke(Message msg) {
  2.   if (chain.allowsPassByReference()) {
  3.     return nextInvoker.invoke(msg);
  4.   }
  5.   msg.setBody(mediator.copyInput(msg.getBody(), operation));
  6.   Message resultMsg = nextInvoker.invoke(msg);
  7.   if (!resultMsg.isFault() && operation.getOutputType() != null) {
  8.     resultMsg.setBody(mediator.copyOutput(resultMsg.getBody(), operation));
  9.   }
  10.   if (resultMsg.isFault()) {
  11.     resultMsg.setFaultBody(mediator.copyFault(resultMsg.getBody(), operation));
  12.   }
  13.   return resultMsg;
  14. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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