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

MessageContext.getTransportIn介绍

暂无

代码示例

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

void receive(MessageContext messageCtx) throws AxisFault {
  log.debug("MessageReceiver has been invoked");
  final AxisMessage messageData;
  try {
    Assert.assertTrue(messageCtx.isServerSide());
    
    TransportInDescription transportIn = messageCtx.getTransportIn();
    Assert.assertNotNull("transportIn not set on message context", transportIn);
    Assert.assertEquals(context.getTransportName(), transportIn.getName());
    
    Assert.assertEquals(context.getTransportName(), messageCtx.getIncomingTransportName());
    
    for (MessageContextValidator validator : validators) {
      validator.validate(messageCtx, false);
    }
    messageData = new AxisMessage(messageCtx);
  }
  catch (Throwable ex) {
    support.putException(ex);
    return;
  }
  support.putMessage(null, messageData);
}

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

void receive(MessageContext messageCtx) throws AxisFault {
  log.debug("MessageReceiver has been invoked");
  final AxisMessage messageData;
  try {
    Assert.assertTrue(messageCtx.isServerSide());
    
    TransportInDescription transportIn = messageCtx.getTransportIn();
    Assert.assertNotNull("transportIn not set on message context", transportIn);
    Assert.assertEquals(context.getTransportName(), transportIn.getName());
    
    Assert.assertEquals(context.getTransportName(), messageCtx.getIncomingTransportName());
    
    for (MessageContextValidator validator : validators) {
      validator.validate(messageCtx, false);
    }
    messageData = new AxisMessage(messageCtx);
  }
  catch (Throwable ex) {
    support.putException(ex);
    return;
  }
  support.putMessage(null, messageData);
}

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

void receive(MessageContext messageCtx) throws AxisFault {
  log.debug("MessageReceiver has been invoked");
  final AxisMessage messageData;
  try {
    Assert.assertTrue(messageCtx.isServerSide());
    
    TransportInDescription transportIn = messageCtx.getTransportIn();
    Assert.assertNotNull("transportIn not set on message context", transportIn);
    Assert.assertEquals(context.getTransportName(), transportIn.getName());
    
    Assert.assertEquals(context.getTransportName(), messageCtx.getIncomingTransportName());
    
    for (MessageContextValidator validator : validators) {
      validator.validate(messageCtx, false);
    }
    messageData = new AxisMessage(messageCtx);
  }
  catch (Throwable ex) {
    support.putException(ex);
    return;
  }
  support.putMessage(null, messageData);
}

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

private void inferEndpoint(MessageContext msgCtx, AxisService service) {
    if (!msgCtx.isServerSide()) {
      return;
    }
    String transport = null;
    TransportInDescription transportIn = msgCtx.getTransportIn();
    if (transportIn != null) {
      transport = transportIn.getName();
      if (transport == null) {
        return;
      }
    }
    AxisEndpoint endpoint = null;
    Map endpointMapping = service.getEndpoints();
    String serviceName = service.getName();

    if (msgCtx.isDoingREST()) {
      endpoint = (AxisEndpoint) endpointMapping.get(WSDLUtil.
          getEndpointName(serviceName, transport));
    }
    if (endpoint != null) {
      msgCtx.setProperty(WSDL2Constants.ENDPOINT_LOCAL_NAME, endpoint);
    }
  }
}

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

((Axis2MessageContext) synCtx).getAxis2MessageContext();
String transport = axis2MsgCtx.getTransportIn().getName();
algorithm.setApplicationMembers(activeMembers);
Member currentMember = algorithm.getNextApplicationMember(algorithmContext);

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

private void inferEndpoint(MessageContext msgCtx, AxisService service) {
    if (!msgCtx.isServerSide()) {
      return;
    }
    String transport = null;
    TransportInDescription transportIn = msgCtx.getTransportIn();
    if (transportIn != null) {
      transport = transportIn.getName();
      if (transport == null) {
        return;
      }
    }
    AxisEndpoint endpoint = null;
    Map endpointMapping = service.getEndpoints();
    String serviceName = service.getName();

    if (msgCtx.isDoingREST()) {
      endpoint = (AxisEndpoint) endpointMapping.get(WSDLUtil.
          getEndpointName(serviceName, transport));
    }
    if (endpoint != null) {
      msgCtx.setProperty(WSDL2Constants.ENDPOINT_LOCAL_NAME, endpoint);
    }
  }
}

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

((Axis2MessageContext) synCtx).getAxis2MessageContext();
String transport = axis2MsgCtx.getTransportIn().getName();
algorithm.setApplicationMembers(activeMembers);
Member currentMember = algorithm.getNextApplicationMember(algorithmContext);

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

/**
   * Clone the MessageContext
   * @param oldMsg
   * @return
   * @throws AxisFault
   */
  public static MessageContext cloneMessageContext (MessageContext oldMsg) throws AxisFault {
  MessageContext newMsg = new MessageContext ();
  newMsg.setOptions(new Options (oldMsg.getOptions()));
  
      // Create a copy of the envelope
      SOAPEnvelope oldEnvelope = oldMsg.getEnvelope();
      if (oldEnvelope != null) {
        SOAPEnvelope newEnvelope = copySOAPEnvelope(oldMsg.getEnvelope());
        newMsg.setEnvelope(newEnvelope);
      }
      
  newMsg.setConfigurationContext(oldMsg.getConfigurationContext());
  newMsg.setAxisService(oldMsg.getAxisService());
  newMsg.setTransportOut(oldMsg.getTransportOut());
  newMsg.setTransportIn(oldMsg.getTransportIn());
      //Copy property objects from oldMsg to newMsg
  copyConfiguredProperties(oldMsg,newMsg);
  return newMsg;
  
}

代码示例来源：origin: org.wso2.mercury/mercury-core

private Axis2Info getAxis2Info(MessageContext messageContext,
                String acksToAddress,
                String addressingNamespaceURI) throws AxisFault {
  Axis2Info axis2Info = new Axis2Info();
  axis2Info.setServiceContext(messageContext.getServiceContext());
  axis2Info.setOptions(messageContext.getOptions());
  axis2Info.setTransportIn(messageContext.getTransportIn());
  TransportOutDescription transportOut = ClientUtils.inferOutTransport(
      messageContext.getConfigurationContext().getAxisConfiguration(),
      new EndpointReference(acksToAddress), messageContext);
  axis2Info.setTransportOut(transportOut);
  axis2Info.setServerSide(messageContext.isServerSide());
  axis2Info.setSoapNamespaceURI(messageContext.getEnvelope().getNamespace().getNamespaceURI());
  axis2Info.setAddressingNamespaceURI(addressingNamespaceURI);
  axis2Info.setProperties(messageContext.getProperties());
  return axis2Info;
}

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

String transport = axis2MsgCtx.getTransportIn().getName();
String address = synCtx.getTo().getAddress();
int incomingPort = extractPort(synCtx, transport);

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

TransportListener listener = msgContext.getTransportIn().getReceiver();
sessionContext = listener.getSessionContext(msgContext);
if (sessionContext == null) {

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

TransportListener listener = msgContext.getTransportIn().getReceiver();
sessionContext = listener.getSessionContext(msgContext);
if (sessionContext == null) {

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

&& (msgContext.getTransportIn() != null)
 && (msgContext.getTransportIn().getName().equals(Constants.TRANSPORT_MAIL))){
outMessageContext.setProperty(MessageContext.TRANSPORT_HEADERS, null);

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

newMC.setTransportIn(mc.getTransportIn());
newMC.setTransportOut(mc.getTransportOut());
newMC.setProperty(org.apache.axis2.Constants.OUT_TRANSPORT_INFO,

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

newMC.setTransportIn(mc.getTransportIn());
newMC.setTransportOut(mc.getTransportOut());
newMC.setProperty(org.apache.axis2.Constants.OUT_TRANSPORT_INFO,

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

responseMessageContext.setTransportIn(msgContext.getTransportIn());
responseMessageContext.setTransportOut(msgContext.getTransportOut());
handleResponse(responseMessageContext);

代码示例来源：origin: holodeck-b2b/Holodeck-B2B

responseMessageContext.setTransportIn(msgContext.getTransportIn());
responseMessageContext.setTransportOut(msgContext.getTransportOut());
handleResponse(responseMessageContext);

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

responseMessageContext.setTransportIn(msgContext.getTransportIn());
responseMessageContext.setTransportOut(msgContext.getTransportOut());
handleResponse(responseMessageContext);

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

newmsgCtx.setTransportIn(inMessageContext.getTransportIn());
newmsgCtx.setTransportOut(inMessageContext.getTransportOut());
newmsgCtx.setServerSide(inMessageContext.isServerSide());

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

newmsgCtx.setTransportIn(inMessageContext.getTransportIn());
newmsgCtx.setTransportOut(inMessageContext.getTransportOut());
newmsgCtx.setServerSide(inMessageContext.isServerSide());