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

Package org.apache.sandesha2.storage.beanmanagers

Class org.apache.sandesha2.storage.beanmanagers.CreateSeqBeanMgr

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

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

      StorageManager storageManager = SandeshaUtil
          .getSandeshaStorageManager(rmMsgContext.getMessageContext()
              .getConfigurationContext());
      SequencePropertyBeanMgr seqPropMgr = storageManager
          .getSequencePropretyBeanMgr();
      SequencePropertyBean receivedMsgsBean = seqPropMgr.retrieve(
          sequenceId, Sandesha2Constants.SequenceProperties.SERVER_COMPLETED_MESSAGES);
      String receivedMsgStr = (String) receivedMsgsBean.getValue();


      ApplicationMsgProcessor ackProcessor = new ApplicationMsgProcessor();
      //Even though the duplicate message is dropped, hv to send the ack if needed.

View Full Code Here

            .getSequencePropretyBeanMgr();


        Transaction preInvocationTransaction = storageManager.getTransaction();
        
        //Getting the incomingSequenceIdList
        SequencePropertyBean allSequencesBean = (SequencePropertyBean) sequencePropMgr
            .retrieve(
                Sandesha2Constants.SequenceProperties.ALL_SEQUENCES,
                Sandesha2Constants.SequenceProperties.INCOMING_SEQUENCE_LIST);
        if (allSequencesBean == null)
          continue;

View Full Code Here

      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);
        throw new SandeshaException (message);
      }

View Full Code Here

  }


  private static void removeReceivingSideProperties (ConfigurationContext configContext, String sequenceID) throws SandeshaException {
    StorageManager storageManager = SandeshaUtil.getSandeshaStorageManager(configContext);
    SequencePropertyBeanMgr sequencePropertyBeanMgr = storageManager.getSequencePropretyBeanMgr();
    SequencePropertyBean allSequenceBean = sequencePropertyBeanMgr.retrieve(Sandesha2Constants.SequenceProperties.ALL_SEQUENCES,Sandesha2Constants.SequenceProperties.INCOMING_SEQUENCE_LIST);
    
    if (allSequenceBean!=null) {
      log.debug("AllSequence bean is null");
      
      ArrayList allSequenceList = SandeshaUtil.getArrayListFromString(allSequenceBean.getValue());

View Full Code Here

    
    String outSequenceID = SandeshaUtil.getSequenceProperty(internalSequenceID,Sandesha2Constants.SequenceProperties.OUT_SEQUENCE_ID,configContext);
    
    if (!serverSide) {
      boolean stopListnerForAsyncAcks = false;
      SequencePropertyBean acksToBean = sequencePropertyBeanMgr.retrieve(internalSequenceID,Sandesha2Constants.SequenceProperties.ACKS_TO_EPR);
        
      String addressingNamespace = SandeshaUtil.getSequenceProperty(internalSequenceID,Sandesha2Constants.SequenceProperties.ADDRESSING_NAMESPACE_VALUE,configContext);
      String anonymousURI = SpecSpecificConstants.getAddressingAnonymousURI(addressingNamespace);
        
      if (acksToBean!=null) {

View Full Code Here

    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

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.