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

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

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

MessageContext.getAxisService介绍

暂无

代码示例

代码示例来源:origin: org.wso2.carbon.commons/org.wso2.carbon.event.ws

private boolean isEnabled(MessageContext mc, String operation) {
  if (mc.getAxisService() != null) {
    String operationValue =
        (String) mc.getAxisService().getParameterValue(operation);
    return operationValue == null || !operationValue.toLowerCase().equals(
        Boolean.toString(false));
  }
  return true;
}

代码示例来源:origin: org.wso2.carbon/org.wso2.carbon.bam.lwevent.core

private boolean isEnabled(MessageContext mc, String operation) {
  if (mc.getAxisService() != null) {
    String operationValue =
        (String) mc.getAxisService().getParameterValue(operation);
    return operationValue == null || !operationValue.toLowerCase().equals(
        Boolean.toString(false));
  }
  return true;
}

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

private Boolean getDisableAck(MessageContext msgContext) throws AxisFault {

  // We should send an early ack to the transport whever possible, but some modules need
  // to use the backchannel, so we need to check if they have disabled this code.
  Boolean disableAck = (Boolean) msgContext.getProperty(Constants.Configuration.DISABLE_RESPONSE_ACK);
  if(disableAck == null) {
   disableAck = (Boolean) (msgContext.getAxisService() != null ? msgContext.getAxisService().getParameterValue(Constants.Configuration.DISABLE_RESPONSE_ACK) : null);
  }    
    return disableAck;
}

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

/**
 * Creates the unique (reproducible) id for to hold the context identifier
 * of the message exchange.
 * @return Id to hold the context identifier in the message context
 */
public static String getContextIdentifierKey(MessageContext msgContext) {
  return msgContext.getAxisService().getName();
}

代码示例来源:origin: org.wso2.wsas/wso2wsas-admin

private boolean callToGeneralService() {
    String serviceName = msgContext.getAxisService().getName();
    return serviceName.equals(ServerConstants.GENERAL_SERVICES);
  }
}

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

private static QName getWrapperQName(MessageContext msgContext) {
  QName wrapperQName = BaseConstants.DEFAULT_TEXT_WRAPPER;
  if (msgContext.getAxisService() != null) {
    Parameter wrapperParam
        = msgContext.getAxisService().getParameter(BaseConstants.WRAPPER_PARAM);
    if (wrapperParam != null) {
      wrapperQName = BaseUtils.getQNameFromString(wrapperParam.getValue());
    }
  }
  return wrapperQName;
}

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

@Override
  protected AbstractXMLInputFactory getXMLInputFactory() throws XMLStreamException {
    AxisService service = messageContext.getAxisService();
    if (service == null) {
      throw new XMLStreamException("AxisService not yet set; unable to create namespace map");
    }

    //input factory for "Mapped" convention
    return new MappedXMLInputFactory(JSONUtil.getNS2JNSMap(service));
  }
}

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

private void traceRequestLine(final MessageContext inMessageContext) {
  if (reqResTraceLog.isTraceEnabled()) {
    requestTime = System.currentTimeMillis();
    AxisService axisService = inMessageContext.getAxisService();
    String epName = axisService.getEndpointName();
    epName = axisService.getEndpoint(epName).getEndpointURL();
    reqResTraceLog.trace("To:" + epName +
        ",MessageID:" + inMessageContext.getMessageID() +
        ",Direction:request" +
        ",requestTime:" + requestTime);
  }
}

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

/**
   * If addressing was found and the dispatch failed we SHOULD (and hence will) return a
   * WS-Addressing ActionNotSupported fault. This will make more sense once the
   * AddressingBasedDsipatcher is moved into the addressing module
   */
  private void checkAction(MessageContext msgContext) throws AxisFault {
    if ((msgContext.getAxisService() == null) || (msgContext.getAxisOperation() == null)) {
      AddressingFaultsHelper
          .triggerActionNotSupportedFault(msgContext, msgContext.getWSAAction());
    }
  }
}

代码示例来源:origin: org.apache.airavata/airavata-message-broker

private void validateBrokerWSEventingOperation(MessageContext msgContext) {
  if (msgContext.getAxisOperation() == null) {
    AxisService service = msgContext.getAxisService();
    AxisOperation pubOperation = getPublishOperation(service);
    msgContext.setAxisOperation(pubOperation);
  }
}

代码示例来源:origin: org.apache.airavata/airavata-message-box

private void validateMsgBoxStoreOperation(MessageContext msgContext) {
  if (msgContext.getAxisOperation() == null) {
    AxisService service = msgContext.getAxisService();
    AxisOperation storeMsgOperation = getMessageBoxOperation(service);
    msgContext.setAxisOperation(storeMsgOperation);
  }
}

代码示例来源:origin: org.apache.geronimo.modules/geronimo-axis2-ejb

private EndpointDescription getEndpointDescription(MessageContext mc) {
  AxisService axisSvc = mc.getAxisMessageContext().getAxisService();
  Parameter param = axisSvc.getParameter(EndpointDescription.AXIS_SERVICE_PARAMETER);
  EndpointDescription ed = (EndpointDescription) param.getValue();
  return ed;
}

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

private void validateBrokerWSEventingOperation(MessageContext msgContext) {
  if (msgContext.getAxisOperation() == null) {
    AxisService service = msgContext.getAxisService();
    AxisOperation pubOperation = getPublishOperation(service);
    msgContext.setAxisOperation(pubOperation);
  }
}

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

private void validateMsgBoxStoreOperation(MessageContext msgContext) {
  if (msgContext.getAxisOperation() == null) {
    AxisService service = msgContext.getAxisService();
    AxisOperation storeMsgOperation = getMessageBoxOperation(service);
    msgContext.setAxisOperation(storeMsgOperation);
  }
}

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

@Override
  protected XMLStreamWriter getJSONWriter(Writer writer, MessageContext messageContext) throws XMLStreamException {
    return new MappedXMLOutputFactory(JSONUtil.getNS2JNSMap(
        messageContext.getAxisService())).createXMLStreamWriter(writer);
  }
}

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

private static void fillBindingAndRelatedInformation(
    final BPELMessageContext bpelMessageContext) throws AxisFault {
  Binding wsdlBinding = getWSDLBindingOfCurrentMessageFlow(
      bpelMessageContext.getInMessageContext().getAxisService(),
      bpelMessageContext.getInMessageContext());
  if (wsdlBinding == null) {
    throw new NullPointerException("WSDL Binding null for incoming message.");
  }
  bpelMessageContext.setWsdlBindingForCurrentMessageFlow(wsdlBinding);
  setSOAPFactoryAndBindingStyle(bpelMessageContext);
}

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

private void checkAction(MessageContext msgContext) throws AxisFault {
  Phase addPhase = getAddressingPhase(msgContext);
  if (addPhase == null) {
    logger.error("unable to locate addressing phase object");
  }
  if (msgContext != null) {
    if (msgContext.getCurrentPhaseIndex() + 1 == addPhase.getHandlerCount()) {
      if (msgContext.getAxisService() == null || msgContext.getAxisOperation() == null)
        AddressingFaultsHelper.triggerActionNotSupportedFault(msgContext, msgContext.getWSAAction());
    }
  }
}

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

private void checkAction(MessageContext msgContext) throws AxisFault {
  Phase addPhase = getAddressingPhase(msgContext);
  if (addPhase == null) {
    logger.error("unable to locate addressing phase object");
  }
  if (msgContext != null) {
    if (msgContext.getCurrentPhaseIndex() + 1 == addPhase.getHandlerCount()) {
      if (msgContext.getAxisService() == null || msgContext.getAxisOperation() == null)
        AddressingFaultsHelper.triggerActionNotSupportedFault(msgContext, msgContext.getWSAAction());
    }
  }
}

代码示例来源:origin: org.apache.airavata/airavata-message-box

private void checkAction(MessageContext msgContext) throws AxisFault {
  Phase addPhase = getAddressingPhase(msgContext);
  if (addPhase == null) {
    logger.error("unable to locate addressing phase object");
  }
  if (msgContext != null) {
    if (msgContext.getCurrentPhaseIndex() + 1 == addPhase.getHandlerCount()) {
      if (msgContext.getAxisService() == null || msgContext.getAxisOperation() == null)
        AddressingFaultsHelper.triggerActionNotSupportedFault(msgContext, msgContext.getWSAAction());
    }
  }
}

代码示例来源:origin: org.apache.airavata/airavata-message-broker

private void checkAction(MessageContext msgContext) throws AxisFault {
  Phase addPhase = getAddressingPhase(msgContext);
  if (addPhase == null) {
    logger.error("unable to locate addressing phase object");
  }
  if (msgContext != null) {
    if (msgContext.getCurrentPhaseIndex() + 1 == addPhase.getHandlerCount()) {
      if (msgContext.getAxisService() == null || msgContext.getAxisOperation() == null)
        AddressingFaultsHelper.triggerActionNotSupportedFault(msgContext, msgContext.getWSAAction());
    }
  }
}

相关文章

微信公众号

最新文章

更多

MessageContext类方法