本文整理了Java中org.apache.axis2.context.MessageContext.setEnvelope()
方法的一些代码示例,展示了MessageContext.setEnvelope()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。MessageContext.setEnvelope()
方法的具体详情如下:
包路径:org.apache.axis2.context.MessageContext
类名称:MessageContext
方法名:setEnvelope
暂无
代码示例来源:origin: org.apache.synapse/synapse-core
public void setEnvelope(SOAPEnvelope envelope) throws AxisFault {
axis2MessageContext.setEnvelope(envelope);
}
代码示例来源:origin: wso2/wso2-synapse
public void setEnvelope(SOAPEnvelope envelope) throws AxisFault {
axis2MessageContext.setEnvelope(envelope);
}
代码示例来源:origin: org.apache.axis2/axis2-transport-testkit
@Override
public void invokeBusinessLogic(MessageContext inMessage, MessageContext outMessage) throws AxisFault {
outMessage.setEnvelope(inMessage.getEnvelope());
}
});
代码示例来源:origin: org.apache.axis2.transport/axis2-transport-testkit
@Override
public void invokeBusinessLogic(MessageContext inMessage, MessageContext outMessage) throws AxisFault {
outMessage.setEnvelope(inMessage.getEnvelope());
}
});
代码示例来源:origin: apache/axis2-java
@Override
public void invokeBusinessLogic(MessageContext inMessage, MessageContext outMessage) throws AxisFault {
outMessage.setEnvelope(inMessage.getEnvelope());
}
});
代码示例来源:origin: org.apache.sandesha2/sandesha2-core
public void setSOAPEnvelop(SOAPEnvelope envelope) throws SandeshaException {
try {
msgContext.setEnvelope(envelope);
} catch (AxisFault e) {
throw new SandeshaException(e.getMessage());
}
}
代码示例来源:origin: org.wso2.carbon.business-process/org.wso2.carbon.bpel
private void setOutMessageContextSOAPEnvelope(final BPELMessageContext bpelMessageContext)
throws AxisFault {
SOAPEnvelope envelope = bpelMessageContext.getSoapFactoryForCurrentMessageFlow()
.getDefaultEnvelope();
bpelMessageContext.getOutMessageContext().setEnvelope(envelope);
}
代码示例来源:origin: org.apache.axis2/axis2-adb
public InvocationResponse invoke(MessageContext msgContext)
throws AxisFault {
SOAPEnvelope resultEnvelope = invokeJavaMethod(msgContext);
Object responseMCObject = msgContext.getOperationContext().getMessageContext(
WSDLConstants.MESSAGE_LABEL_IN_VALUE);
if (responseMCObject != null) {
MessageContext responseMC = (MessageContext) responseMCObject;
responseMC.setEnvelope(resultEnvelope);
}
return InvocationResponse.CONTINUE;
}
private SOAPEnvelope invokeJavaMethod(MessageContext inMessage)
代码示例来源:origin: apache/axis2-java
public InvocationResponse invoke(MessageContext msgContext)
throws AxisFault {
SOAPEnvelope resultEnvelope = invokeJavaMethod(msgContext);
Object responseMCObject = msgContext.getOperationContext().getMessageContext(
WSDLConstants.MESSAGE_LABEL_IN_VALUE);
if (responseMCObject != null) {
MessageContext responseMC = (MessageContext) responseMCObject;
responseMC.setEnvelope(resultEnvelope);
}
return InvocationResponse.CONTINUE;
}
private SOAPEnvelope invokeJavaMethod(MessageContext inMessage)
代码示例来源:origin: org.wso2.xkms/xkms
private static void fillSOAPEnvelope(MessageContext messageContext, OMElement xmlPayload,
ServiceClient serviceClient)
throws AxisFault {
messageContext.setServiceContext(serviceClient.getServiceContext());
SOAPFactory soapFactory = getSOAPFactory(serviceClient.getOptions());
SOAPEnvelope envelope = soapFactory.getDefaultEnvelope();
if (xmlPayload != null) {
envelope.getBody().addChild(xmlPayload);
}
serviceClient.addHeadersToEnvelope(envelope);
messageContext.setEnvelope(envelope);
}
代码示例来源:origin: org.apache.synapse/synapse-core
private static MessageContext cloneForSend(MessageContext ori, String preserveAddressing)
throws AxisFault {
MessageContext newMC = MessageHelper.clonePartially(ori);
newMC.setEnvelope(ori.getEnvelope());
if (preserveAddressing != null && Boolean.parseBoolean(preserveAddressing)) {
newMC.setMessageID(ori.getMessageID());
} else {
MessageHelper.removeAddressingHeaders(newMC);
}
newMC.setProperty(org.apache.axis2.context.MessageContext.TRANSPORT_HEADERS,
ori.getProperty(org.apache.axis2.context.MessageContext.TRANSPORT_HEADERS));
return newMC;
}
代码示例来源:origin: wso2/wso2-synapse
private static MessageContext cloneForSend(MessageContext ori, String preserveAddressing)
throws AxisFault {
MessageContext newMC = MessageHelper.clonePartially(ori);
newMC.setEnvelope(ori.getEnvelope());
if (preserveAddressing != null && Boolean.parseBoolean(preserveAddressing)) {
newMC.setMessageID(ori.getMessageID());
} else {
MessageHelper.removeAddressingHeaders(newMC);
}
newMC.setProperty(org.apache.axis2.context.MessageContext.TRANSPORT_HEADERS,
ori.getProperty(org.apache.axis2.context.MessageContext.TRANSPORT_HEADERS));
return newMC;
}
代码示例来源:origin: org.ow2.petals/petals-bc-soap
/**
* Copied from {@link ServiceClient}
*/
protected void fillSOAPEnvelope(final MessageContext messageContext, final OMElement xmlPayload)
throws AxisFault {
messageContext.setServiceContext(getServiceContext());
final SOAPFactory soapFactory = getSOAPFactory();
final SOAPEnvelope envelope = soapFactory.getDefaultEnvelope();
if (xmlPayload != null) {
envelope.getBody().addChild(xmlPayload);
}
addHeadersToEnvelope(envelope);
messageContext.setEnvelope(envelope);
}
代码示例来源:origin: org.apache.axis2/axis2-transport-tcp
private void waitForReply(MessageContext msgContext, Socket socket,
String contentType) throws AxisFault {
if (!(msgContext.getAxisOperation() instanceof OutInAxisOperation) &&
msgContext.getProperty(org.apache.axis2.Constants.PIGGYBACK_MESSAGE) == null) {
return;
}
try {
MessageContext responseMsgCtx = createResponseMessageContext(msgContext);
SOAPEnvelope envelope = TransportUtils.createSOAPMessage(msgContext,
socket.getInputStream(), contentType);
responseMsgCtx.setEnvelope(envelope);
AxisEngine.receive(responseMsgCtx);
} catch (Exception e) {
handleException("Error while processing response", e);
}
}
代码示例来源:origin: apache/axis2-java
private void waitForReply(MessageContext msgContext, Socket socket,
String contentType) throws AxisFault {
if (!(msgContext.getAxisOperation() instanceof OutInAxisOperation) &&
msgContext.getProperty(org.apache.axis2.Constants.PIGGYBACK_MESSAGE) == null) {
return;
}
try {
MessageContext responseMsgCtx = createResponseMessageContext(msgContext);
SOAPEnvelope envelope = TransportUtils.createSOAPMessage(msgContext,
socket.getInputStream(), contentType);
responseMsgCtx.setEnvelope(envelope);
AxisEngine.receive(responseMsgCtx);
} catch (Exception e) {
handleException("Error while processing response", e);
}
}
代码示例来源:origin: wso2/wso2-synapse
public void testSOAP11To12Conversion() throws Exception {
MessageContext msgCtx = TestUtils.getAxis2MessageContext("<test/>", null).
getAxis2MessageContext();
msgCtx.setEnvelope(getSOAP11Envelope());
SOAPUtils.convertSOAP11toSOAP12(msgCtx);
assertXMLEqual(getSOAP12Envelope().toString(), msgCtx.getEnvelope().toString());
}
代码示例来源:origin: wso2/wso2-synapse
public void testSOAP12To11Conversion() throws Exception {
MessageContext msgCtx = TestUtils.getAxis2MessageContext("<test/>", null).
getAxis2MessageContext();
msgCtx.setEnvelope(getSOAP12Envelope());
SOAPUtils.convertSOAP12toSOAP11(msgCtx);
assertXMLEqual(getSOAP11Envelope().toString(), msgCtx.getEnvelope().toString());
}
代码示例来源:origin: org.apache.airavata/messagebroker
protected MessageContext createOutputMessageContext(MessageContext inMsg, ProcessingContext processingContext)
throws AxisFault {
MessageContext outMsgContext = MessageContextBuilder.createOutMessageContext(inMsg);
outMsgContext.getOperationContext().addMessageContext(outMsgContext);
SOAPEnvelope outputEnvelope = getSOAPFactory(inMsg).getDefaultEnvelope();
if (processingContext.getRespMessage() != null) {
outputEnvelope.getBody().addChild(processingContext.getRespMessage());
if (processingContext.getResponseMsgNamespaces() != null) {
declareResponseMsgNamespace(outputEnvelope, processingContext.getResponseMsgNamespaces());
}
}
outMsgContext.setEnvelope(outputEnvelope);
return outMsgContext;
}
代码示例来源:origin: org.apache.airavata/airavata-message-broker
protected MessageContext createOutputMessageContext(MessageContext inMsg, ProcessingContext processingContext)
throws AxisFault {
MessageContext outMsgContext = MessageContextBuilder.createOutMessageContext(inMsg);
outMsgContext.getOperationContext().addMessageContext(outMsgContext);
SOAPEnvelope outputEnvelope = getSOAPFactory(inMsg).getDefaultEnvelope();
if (processingContext.getRespMessage() != null) {
outputEnvelope.getBody().addChild(processingContext.getRespMessage());
if (processingContext.getResponseMsgNamespaces() != null) {
declareResponseMsgNamespace(outputEnvelope, processingContext.getResponseMsgNamespaces());
}
}
outMsgContext.setEnvelope(outputEnvelope);
return outMsgContext;
}
代码示例来源:origin: wso2-attic/esb-connectors
private void fillSOAPEnvelope(MessageContext messageContext, OMElement xmlPayload)
throws AxisFault {
messageContext.setServiceContext(getServiceContext());
SOAPFactory soapFactory = getSOAPFactory();
SOAPEnvelope envelope = soapFactory.getDefaultEnvelope();
if (xmlPayload != null) {
envelope.getBody().addChild(xmlPayload);
}
addHeadersToEnvelope(envelope);
messageContext.setEnvelope(envelope);
}
内容来源于网络,如有侵权,请联系作者删除!