本文整理了Java中org.apache.axis2.context.MessageContext.getAxisService()
方法的一些代码示例,展示了MessageContext.getAxisService()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。MessageContext.getAxisService()
方法的具体详情如下:
包路径:org.apache.axis2.context.MessageContext
类名称: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());
}
}
}
内容来源于网络,如有侵权,请联系作者删除!