Examples of org.apache.sandesha2.storage.beanmanagers.SenderBeanMgr.retrieve()

Package org.apache.sandesha2.storage.beanmanagers

Class org.apache.sandesha2.storage.beanmanagers.SenderBeanMgr

Examples of org.apache.sandesha2.storage.beanmanagers.SenderBeanMgr.retrieve()

org.apache.sandesha2.storage.beanmanagers.SenderBeanMgr.retrieve()

    Transaction addTerminateSeqTransaction = storageManager.getTransaction();
    
    SequencePropertyBeanMgr seqPropMgr = storageManager
        .getSequencePropretyBeanMgr();


    SequencePropertyBean terminated = seqPropMgr.retrieve(outSequenceId,
        Sandesha2Constants.SequenceProperties.TERMINATE_ADDED);


    if (terminated != null && terminated.getValue() != null
        && "true".equals(terminated.getValue())) {
      String message = "Terminate was added previously.";

View Full Code Here

    RMMsgContext terminateRMMessage = RMMsgCreator
        .createTerminateSequenceMessage(referenceMessage, outSequenceId,internalSequenceId);
    terminateRMMessage.setFlow(MessageContext.OUT_FLOW);
    terminateRMMessage.setProperty(Sandesha2Constants.APPLICATION_PROCESSING_DONE,"true");
    
    SequencePropertyBean toBean = seqPropMgr.retrieve(internalSequenceId,
        Sandesha2Constants.SequenceProperties.TO_EPR);


    EndpointReference toEPR = new EndpointReference ( toBean.getValue());
    if (toEPR == null) {
      String message = "To EPR has an invalid value";

View Full Code Here

    if (rmVersion==null)
      throw new SandeshaException ("Cant find the rmVersion of the given message");
    terminateRMMessage.setWSAAction(SpecSpecificConstants.getTerminateSequenceAction(rmVersion));
    terminateRMMessage.setSOAPAction(SpecSpecificConstants.getTerminateSequenceSOAPAction(rmVersion));


    SequencePropertyBean transportToBean = seqPropMgr.retrieve(internalSequenceId,Sandesha2Constants.SequenceProperties.TRANSPORT_TO);
    if (transportToBean!=null) {
      terminateRMMessage.setProperty(MessageContextConstants.TRANSPORT_URL,transportToBean.getValue());
    }
    
    try {

View Full Code Here

    StorageManager storageManager = SandeshaUtil.getSandeshaStorageManager(configCtx);
    SequencePropertyBeanMgr seqPropMgr = storageManager.getSequencePropretyBeanMgr();
    
    boolean lastMessageNumberExceeded = false;
    String reason = null;
    SequencePropertyBean lastMessageBean = seqPropMgr.retrieve(sequenceID,Sandesha2Constants.SequenceProperties.LAST_OUT_MESSAGE_NO);
    if (lastMessageBean!=null) {
      long lastMessageNo = Long.parseLong(lastMessageBean.getValue());
      if (messageNumber>lastMessageNo) {
        lastMessageNumberExceeded = true;
        reason = "The message number of the message '" + messageNumber + "' exceeded the last message number '" + lastMessageNo + "'"+

View Full Code Here

    StorageManager storageManager = SandeshaUtil.getSandeshaStorageManager(configCtx);
    SequencePropertyBeanMgr seqPropMgr = storageManager.getSequencePropretyBeanMgr();
    
    boolean sequenceClosed = false;
    String reason = null;
    SequencePropertyBean sequenceClosedBean = seqPropMgr.retrieve(sequenceID,Sandesha2Constants.SequenceProperties.SEQUENCE_CLOSED);
    if (sequenceClosedBean!=null && Sandesha2Constants.VALUE_TRUE.equals(sequenceClosedBean.getValue()))  {
      sequenceClosed = true;
      reason = "The sequence with the id " + sequenceID + " was closed previously. Cannot accept this message";
    }

View Full Code Here

            .getAddress();
      } else {
        SequencePropertyBeanMgr seqPropMgr = storageManager
            .getSequencePropretyBeanMgr();
        String sequenceId = data.getSequenceId();
        SequencePropertyBean acksToBean = seqPropMgr.retrieve(
            sequenceId, Sandesha2Constants.SequenceProperties.ACKS_TO_EPR);
        if (acksToBean != null) {
          EndpointReference epr = new EndpointReference (acksToBean
              .getValue());
          if (epr != null)

View Full Code Here

    lastUpdatedTimeTransaction.commit();
    
    Transaction updataMsgStringTransaction = storageManager
        .getTransaction();
    
    SequencePropertyBean msgsBean = seqPropMgr.retrieve(sequenceId,
        Sandesha2Constants.SequenceProperties.SERVER_COMPLETED_MESSAGES);


    long msgNo = sequence.getMessageNumber().getMessageNumber();
    if (msgNo == 0) {
      String message = "Wrong message number";

View Full Code Here

    if (inOrderInvocation) {
      
      //pause the message
      rmMsgCtx.pause();
      
      SequencePropertyBean incomingSequenceListBean = (SequencePropertyBean) seqPropMgr
          .retrieve(
              Sandesha2Constants.SequenceProperties.ALL_SEQUENCES,
              Sandesha2Constants.SequenceProperties.INCOMING_SEQUENCE_LIST);


      if (incomingSequenceListBean == null) {

View Full Code Here

      seqPropMgr.insert(responseLastMsgKeyBean);
    }
    
    boolean sendCreateSequence = false;


    SequencePropertyBean outSeqBean = seqPropMgr.retrieve(
        internalSequenceId,
        Sandesha2Constants.SequenceProperties.OUT_SEQUENCE_ID);


    // setting async ack endpoint for the server side. (if present)
    if (serverSide) {

View Full Code Here


    // setting async ack endpoint for the server side. (if present)
    if (serverSide) {
      String incomingSequenceID = SandeshaUtil
          .getServerSideIncomingSeqIdFromInternalSeqId(internalSequenceId);
      SequencePropertyBean incomingToBean = seqPropMgr.retrieve(
          incomingSequenceID,
          Sandesha2Constants.SequenceProperties.TO_EPR);
      if (incomingToBean != null) {
        String incomingTo = incomingToBean.getValue();
        msgContext.setProperty(SandeshaClientConstants.AcksTo, incomingTo);

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.