org.apache.axis2.context.MessageContext.getOperationContext()方法的使用及代码示例

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

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

MessageContext.getOperationContext介绍

暂无

代码示例

代码示例来源：origin: org.apache.axis2/axis2-transport-base

/**
 * Should the transport sender wait for a synchronous response to be received?
 * @param msgCtx the outgoing message context
 * @return true if a sync response is expected
 */
protected boolean waitForSynchronousResponse(MessageContext msgCtx) {
  return
    msgCtx.getOperationContext() != null &&
    WSDL2Constants.MEP_URI_OUT_IN.equals(
      msgCtx.getOperationContext().getAxisOperation().getMessageExchangePattern());
}

代码示例来源：origin: stackoverflow.com

//this is the incoming message context
 MessageContext inMessageContext  = MessageContext.getCurrentMessageContext();
 OperationContext operationContext = inMessageContext.getOperationContext();
 //this is the outgoing message context
 MessageContext outMessageContext =     operationContext.getMessageContext(WSDLConstants.MESSAGE_LABEL_OUT_VALUE);

代码示例来源：origin: wso2/wso2-synapse

public void awaitResponse() throws InterruptedException, AxisFault {
  if (log.isDebugEnabled()) {
    log.debug("Returning thread but keeping socket open -- awaiting response");
  }
  status = RequestResponseTransportStatus.WAITING;
  msgContext.getOperationContext().setProperty(Constants.RESPONSE_WRITTEN, "SKIP");
}

代码示例来源：origin: apache/axis2-java

/**
 * Should the transport sender wait for a synchronous response to be received?
 * @param msgCtx the outgoing message context
 * @return true if a sync response is expected
 */
protected boolean waitForSynchronousResponse(MessageContext msgCtx) {
  return
    msgCtx.getOperationContext() != null &&
    WSDL2Constants.MEP_URI_OUT_IN.equals(
      msgCtx.getOperationContext().getAxisOperation().getMessageExchangePattern());
}

代码示例来源：origin: org.apache.synapse/synapse-core

public void setProperty(String key, Object value) {
  if (value == null) {
    return;
  }
  
  properties.put(key, value);
  // do not commit response by default in the server process
  if (SynapseConstants.RESPONSE.equals(key) &&
      getAxis2MessageContext().getOperationContext() != null) {
    getAxis2MessageContext().getOperationContext().setProperty(
      org.apache.axis2.Constants.RESPONSE_WRITTEN, "SKIP");
  }
}

代码示例来源：origin: org.apache.synapse/synapse-core

private boolean isOutOnly(MessageContext messageIn,
             org.apache.axis2.context.MessageContext axis2Ctx) {
  return "true".equals(messageIn.getProperty(SynapseConstants.OUT_ONLY)) ||
      axis2Ctx.getOperationContext() != null && WSDL2Constants.MEP_URI_IN_ONLY.equals(
          axis2Ctx.getOperationContext().getAxisOperation().getMessageExchangePattern());
}

代码示例来源：origin: wso2/wso2-synapse

private boolean isOutOnly(MessageContext messageIn,
             org.apache.axis2.context.MessageContext axis2Ctx) {
  return "true".equals(messageIn.getProperty(SynapseConstants.OUT_ONLY)) ||
      axis2Ctx.getOperationContext() != null &&
      WSDL2Constants.MEP_URI_IN_ONLY.equals(axis2Ctx.getOperationContext().
          getAxisOperation().getMessageExchangePattern());
}

代码示例来源：origin: wso2/wso2-synapse

public void setProperty(String key, Object value) {
  if (value == null) {
    return;
  }
  properties.put(key, value);
  // do not commit response by default in the server process
  if (SynapseConstants.RESPONSE.equals(key) &&
    getAxis2MessageContext().getOperationContext() != null) {
    getAxis2MessageContext().getOperationContext().setProperty(
        org.apache.axis2.Constants.RESPONSE_WRITTEN, "SKIP");
  }
}

代码示例来源：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.apache.airavata/airavata-message-box

protected String getOperationName(MessageContext inMsg) throws AxisFault {
  AxisOperation op = inMsg.getOperationContext().getAxisOperation();
  if (op == null) {
    throw new AxisFault(
        "Operation is not located, if this is doclit style the SOAP-ACTION should specified via the SOAP Action to use the RawXMLProvider");
  }
  String operationName = null;
  if ((op.getName() == null) || ((operationName = JavaUtils.xmlNameToJava(op.getName().getLocalPart())) == null)) {
    throw new AxisFault("invalid operation found");
  }
  return operationName;
}

代码示例来源：origin: org.apache.airavata/messagebox

protected String getOperationName(MessageContext inMsg) throws AxisFault {
  AxisOperation op = inMsg.getOperationContext().getAxisOperation();
  if (op == null) {
    throw new AxisFault(
        "Operation is not located, if this is doclit style the SOAP-ACTION should specified via the SOAP Action to use the RawXMLProvider");
  }
  String operationName = null;
  if ((op.getName() == null) || ((operationName = JavaUtils.xmlNameToJava(op.getName().getLocalPart())) == null)) {
    throw new AxisFault("invalid operation found");
  }
  return operationName;
}

代码示例来源：origin: wso2-attic/esb-connectors

public void connect(MessageContext messageContext) {
  // Set the force login
  String strValue =
      (String) ConnectorUtils.lookupTemplateParamater(messageContext,
          SalesforceUtil.SALESFORCE_LOGIN_FORCE);
  if (strValue != null || "true".equals(strValue)) {
    // Setting Transport Headers
    Axis2MessageContext axis2smc = (Axis2MessageContext) messageContext;
    axis2smc.getAxis2MessageContext().getOperationContext()
        .setProperty(SalesforceUtil.SALESFORCE_LOGIN_DONE, "false");
  }
}

代码示例来源：origin: org.apache.airavata/messagebroker

protected String getOperationName(MessageContext inMsg) throws AxisFault {
  org.apache.axis2.description.AxisOperation op = inMsg.getOperationContext().getAxisOperation();
  if (op == null) {
    throw new AxisFault(
        "Operation is not located, if this is doclit style the SOAP-ACTION should specified via the SOAP Action to use the RawXMLProvider");
  }
  java.lang.String operationName = null;
  if ((op.getName() == null)
      || ((operationName = org.apache.axis2.util.JavaUtils.xmlNameToJava(op.getName().getLocalPart())) == null)) {
    throw new AxisFault("invalid operation found");
  }
  return operationName;
}

代码示例来源：origin: org.wso2.carbon.governance/org.wso2.carbon.governance.list

public void receive(MessageContext requestMessageContext) throws AxisFault {
    String operationName = requestMessageContext.getOperationContext().getAxisOperation().getName().getLocalPart();
    AxisEngine.send(processorMap.get(operationName).process(requestMessageContext));
  }
}

代码示例来源：origin: org.wso2.carbon.business-process/org.wso2.carbon.bpel

private static void setOutMessageContextToBPELMessageContext(
    final BPELMessageContext bpelMessageContext)
    throws AxisFault {
  MessageContext outMessageContext = MessageContextBuilder
      .createOutMessageContext(bpelMessageContext.getInMessageContext());
  outMessageContext.getOperationContext().addMessageContext(outMessageContext);
  bpelMessageContext.setOutMessageContext(outMessageContext);
}

代码示例来源：origin: org.apache.axis2/axis2-kernel

public final void invokeBusinessLogic(MessageContext msgContext) throws AxisFault {
    MessageContext outMsgContext = MessageContextBuilder.createOutMessageContext(msgContext);
    outMsgContext.getOperationContext().addMessageContext(outMsgContext);

    invokeBusinessLogic(msgContext, outMsgContext);
    replicateState(msgContext);

    AxisEngine.send(outMsgContext);
  }
}

代码示例来源：origin: org.apache.axis2/axis2-kernel

public final void invokeBusinessLogic(MessageContext msgContext) throws AxisFault {
    MessageContext outMsgContext = MessageContextBuilder.createOutMessageContext(msgContext);
    outMsgContext.getOperationContext().addMessageContext(outMsgContext);

    invokeBusinessLogic(msgContext, outMsgContext);
    replicateState(msgContext);

    AxisEngine.send(outMsgContext);
  }
}

代码示例来源：origin: apache/axis2-java

public final void invokeBusinessLogic(MessageContext msgContext) throws AxisFault {
    MessageContext outMsgContext = MessageContextBuilder.createOutMessageContext(msgContext);
    outMsgContext.getOperationContext().addMessageContext(outMsgContext);

    invokeBusinessLogic(msgContext, outMsgContext);
    replicateState(msgContext);

    AxisEngine.send(outMsgContext);
  }
}

代码示例来源：origin: apache/axis2-java

public final void invokeBusinessLogic(MessageContext msgContext) throws AxisFault {
    MessageContext outMsgContext = MessageContextBuilder.createOutMessageContext(msgContext);
    outMsgContext.getOperationContext().addMessageContext(outMsgContext);

    invokeBusinessLogic(msgContext, outMsgContext);
    replicateState(msgContext);

    AxisEngine.send(outMsgContext);
  }
}

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

MessageContext

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    MessageContext类方法

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