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

Class org.apache.axis2.client.MessageSender

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

org.apache.axis2.client.MessageSender.send()
Sends a SOAP elvelope created from an OMElement. @param opName @param toSend @throws AxisFault

    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

          Constants.VALUE_TRUE);


      rmMsgCtx.getMessageContext().setProperty(
          Sandesha2Constants.ACK_WRITTEN, "true");
      try {
        engine.send(ackRMMsgCtx.getMessageContext());
      } catch (AxisFault e1) {
        throw new SandeshaException(e1.getMessage());
      }
    } else {

View Full Code Here

      
      ackMsgCtx.setTransportOut(new Sandesha2TransportOutDesc ());
      
      AxisEngine engine = new AxisEngine (configurationContext);
      try {
        engine.send(ackMsgCtx);
      } catch (AxisFault e) {
        throw new SandeshaException (e.getMessage());
      }
      
      SandeshaUtil.startSenderForTheSequence(configurationContext,sequenceID);

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.