Package org.apache.axis2.clientapi

Examples of org.apache.axis2.clientapi.MessageSender.send()


        log.debug("Executed EmptyRMMessageReceiver#receive() and Java Return for RMMediator");

        AxisEngine engine = new AxisEngine(
                messageContext.getOperationContext().getServiceContext().getConfigurationContext());
        engine.send(outMsgContext);

    }
}
View Full Code Here


                            org.apache.synapse.Constants.ISRESPONSE_PROPERTY, Boolean.TRUE);
                    mc.getOperationContext().setProperty(
                            Constants.RESPONSE_WRITTEN, Constants.VALUE_TRUE);
                    // check for addressing is alredy engaged for this message.
                    // if engage we should use the address enable Configuraion context.
                    ae.send(axisOutMsgContext);

                } catch (AxisFault e) {
                    log.error("Axis fault encountered while forwarding message to endpoint : "
                            + targetEndpoint, e);
                }
View Full Code Here

    AxisEngine engine = new AxisEngine (terminateSeqMsg.getConfigurationContext());
   
    EndpointReference toEPR = terminateSeqMsg.getTo();
   
    try {
      engine.send(outMessage);
    } catch (AxisFault e) {
      String message = "Could not send the terminate sequence response";
      throw new SandeshaException (message,e);
    }
   
View Full Code Here

    rmMsgCtx.getMessageContext().setTransportOut(new Sandesha2TransportOutDesc ());
    addTerminateSeqTransaction.commit();
   
      AxisEngine engine = new AxisEngine (configurationContext);
      try {
      engine.send(msgContext);
    } catch (AxisFault e) {
      throw new SandeshaException (e.getMessage());
    }
  }
 
View Full Code Here

      Transaction updateLastActivatedTransaction = storageManager.getTransaction();
      SequenceManager.updateLastActivatedTime(newSequenceId,createSeqRMMsg.getMessageContext().getConfigurationContext());
      updateLastActivatedTransaction.commit();
     
      AxisEngine engine = new AxisEngine(context);
      engine.send(outMessage);
     
      SequencePropertyBean toBean = seqPropMgr.retrieve(newSequenceId,Sandesha2Constants.SequenceProperties.TO_EPR);
      if (toBean==null) {
        String message = "Internal Error: wsa:To value is not set";
        log.debug(message);
View Full Code Here

    terminateRMMessage.getMessageContext().setTransportOut(new Sandesha2TransportOutDesc ());
    addTerminateSeqTransaction.commit();
   
      AxisEngine engine = new AxisEngine (configurationContext);
      try {
      engine.send(terminateRMMessage.getMessageContext());
    } catch (AxisFault e) {
      throw new SandeshaException (e.getMessage());
    }
     
  }
View Full Code Here

    closeSeqResponseRMMsg.addSOAPEnvelope();
   
    AxisEngine engine = new AxisEngine (closeSequenceMsg.getConfigurationContext());
   
    try {
      engine.send(closeSequenceResponseMsg);
    } catch (AxisFault e) {
      String message = "Could not send the terminate sequence response";
      throw new SandeshaException (message,e);
    }
   
View Full Code Here

    if (faultMessageContext != null) {
      ConfigurationContext configurationContext = msgCtx.getConfigurationContext();
      AxisEngine engine = new AxisEngine(configurationContext);
     
      try {
        engine.send(faultMessageContext.getMessageContext());
      } catch (AxisFault e) {
        throw new SandeshaException ("Could not send the fault message",e);
      }
     
      return;
View Full Code Here

     RMMsgContext ackRMMessage = AcknowledgementManager.generateAckMessage(rmMsgCtx,sequenceId);
   
     AxisEngine engine = new AxisEngine (configCtx);
    
     try {
      engine.send(ackRMMessage.getMessageContext());
    } catch (AxisFault e) {
      String message = "Exception thrown while trying to send the ack message";
      throw new SandeshaException (message,e);
    }
  }
View Full Code Here

    createSeqMsg.setTransportOut(sandesha2TransportOutDesc);

    // sending the message once through Sandesha2TransportSender.
    AxisEngine engine = new AxisEngine(createSeqMsg.getConfigurationContext());
     try {
       engine.send(createSeqMsg);
     } catch (AxisFault e) {
       throw new SandeshaException (e.getMessage());
     }
  }
View Full Code Here

TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.