Examples of org.apache.axis2.engine.AxisEngine.send()

Class org.apache.axis2.engine.AxisEngine

Examples of org.apache.axis2.engine.AxisEngine.send()

org.apache.axis2.engine.AxisEngine.send()
This methods represents the outflow of the Axis, this could be either at the server side or the client side. Here the ExecutionChain is created using the Phases. The Handlers at the each Phases is ordered in deployment time by the deployment module @param msgContext @throws AxisFault @see MessageContext @see Phase @see Handler

        .checkForPossibleFaults(msgContext);
    if (faultMessageContext != null) {
      ConfigurationContext configurationContext = msgContext
          .getConfigurationContext();
      AxisEngine engine = new AxisEngine(configurationContext);
      engine.send(faultMessageContext.getMessageContext());
      return;
    }


    RMMsgContext rmMessageContext = MsgInitializer
        .initializeMessage(msgContext);

View Full Code Here

      // commiting tr. before sending the response msg.


      SequenceManager.updateLastActivatedTime(newSequenceId, storageManager);


      AxisEngine engine = new AxisEngine(context);
      engine.send(outMessage);


      SequencePropertyBean toBean = seqPropMgr.retrieve(newSequenceId,
          Sandesha2Constants.SequenceProperties.TO_EPR);
      if (toBean == null) {
        String message = SandeshaMessageHelper.getMessage(SandeshaMessageKeys.toEPRNotValid, null);

View Full Code Here

      
      
      outMessage.setServerSide(true);
      
      
      engine.send(outMessage);


      String addressingNamespaceURI = SandeshaUtil
          .getSequenceProperty(
              sequencePropertyKey,
              Sandesha2Constants.SequenceProperties.ADDRESSING_NAMESPACE_VALUE,

View Full Code Here

      rmMsgCtx.getMessageContext().setProperty(Sandesha2Constants.ACK_WRITTEN, "true");


      ackRMMsgCtx.getMessageContext().setServerSide(true);
      
      AxisEngine engine = new AxisEngine(configCtx);
      engine.send(ackRMMsgCtx.getMessageContext());


    } else {


      // / Transaction asyncAckTransaction =
      // storageManager.getTransaction();

View Full Code Here


        AxisEngine engine =
                new AxisEngine(
                        msgContext.getOperationContext().getServiceContext()
                .getEngineContext());
        engine.send(outMsgContext);
    }
}

View Full Code Here

        final ServerCallback callback = new ServerCallback() {
            public void handleResult(MessageContext result) throws AxisFault {
                AxisEngine engine =
                    new AxisEngine(
                        messgeCtx.getOperationContext().getServiceContext().getEngineContext());
                engine.send(messgeCtx);
            }
            public void handleFault(AxisFault fault) throws AxisFault {
                AxisEngine engine =
                    new AxisEngine(
                        messgeCtx.getOperationContext().getServiceContext().getEngineContext());

View Full Code Here

                //create and set the Operation context
                msgctx.setOperationContext(axisop.findOperationContext(msgctx, serviceContext));
                msgctx.setServiceContext(serviceContext);


                //send the message
                engine.send(msgctx);
            } else {
                //here a bloking invocation happens in a new thrad, so the progamming model is
                //non blocking
                serviceContext.getEngineContext().getThreadPool().addWorker(new NonBlockingInvocationWorker(callback, axisop, msgctx));
            }

View Full Code Here

public class TwoWayTransportBasedSender {
    public static MessageContext send(MessageContext msgctx,
                                      TransportInDescription transportIn) throws AxisFault {


        AxisEngine engine = new AxisEngine(msgctx.getSystemContext());
        engine.send(msgctx);


        //create the response
        MessageContext response =
                new MessageContext(msgctx.getSystemContext(),
                        msgctx.getSessionContext(),

View Full Code Here

        ConfigurationContext sysContext = serviceContext.getEngineContext();
        AxisConfiguration registry = sysContext.getAxisConfiguration();
        msgctx.setOperationContext(axisop.findOperationContext(msgctx, serviceContext));
        
        AxisEngine engine = new AxisEngine(sysContext);
        engine.send(msgctx);
    }


    /**
     * @param action
     */

View Full Code Here

            outMC.setEnvelope(soapEnvelope);
            outMC.getOperationContext().setProperty(Constants.RESPONSE_WRITTEN, Constants.VALUE_TRUE);


            AxisEngine engine =
                new AxisEngine(invCtx.inMessageContext.getOperationContext().getServiceContext().getConfigurationContext());
            engine.send(outMC);
            
            invCtx.doneSignal.countDown();


            service.removeMapping(this.currentCorrelationId);
        } catch (AxisFault e) {

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.