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()

         (makeConnection == null || !makeConnection.booleanValue()) &&
         (t == null || !t.getStatus().equals(RequestResponseTransportStatus.WAITING))) {
        
        // Mark this sender bean so that we know that the transport is unavailable, if the
        // bean is still stored.
        SenderBean bean = senderBeanMgr.retrieve(senderBean.getMessageID());
        if(bean != null && bean.isTransportAvailable()) {
          bean.setTransportAvailable(false);
          senderBeanMgr.update(bean);
        }

View Full Code Here

      }
      // Establish the transaction for post-send processing
      transaction = storageManager.getTransaction();


      // update or delete only if the object is still present.
      SenderBean bean1 = senderBeanMgr
          .retrieve(senderBean.getMessageID());
      if (bean1 != null) {
        if (senderBean.isReSend()) {
          bean1.setTimeToSend(senderBean.getTimeToSend());
          senderBeanMgr.update(bean1);

View Full Code Here

        rmdBeanMgr.insert(rMDBean);
        SandeshaUtil.startWorkersForSequence(configCtx, rMDBean);
      }
      
      // Get the CreateSeqBean based on the message id to take a lock on the bean
        SenderBean createSeqBean = retransmitterMgr.retrieve(createSeqMsgId);
        
      // deleting the create sequence sender bean entry.
      retransmitterMgr.delete(createSeqBean.getMessageID());
        
      // Remove the create sequence message

View Full Code Here

        for (int rangeIndex=0; rangeIndex < newRanges.length; rangeIndex++) {
          //now work on each newly acked message in this range
          for(long messageNo = newRanges[rangeIndex].lowerValue; messageNo<=newRanges[rangeIndex].upperValue; messageNo++){


            numberOfNewMessagesAcked++;
            SenderBean retransmitterBean = retransmitterMgr.retrieve(outSequenceId, messageNo);
            if (retransmitterBean != null && retransmitterBean.getMessageType()==Sandesha2Constants.MessageTypes.APPLICATION) {
              // Check we haven't got an Ack for an application message that hasn't been sent yet !
              if (retransmitterBean.getSentCount() == 0 ) {
                //invalid ack range
                if(!ackNeedsToSendInvalidFault){

View Full Code Here

      StorageManager storageManager = SandeshaUtil.getSandeshaStorageManager(configurationContext, configurationContext.getAxisConfiguration());
      SenderBeanMgr senderBeanMgr = storageManager.getSenderBeanMgr();
      
      transaction = storageManager.getTransaction();


      SenderBean senderBean = senderBeanMgr.retrieve(messageId);
      if (senderBean==null) {
        //the work is not present. May be invalid now. So should return.
        if (log.isDebugEnabled())
          log.debug(SandeshaMessageHelper.getMessage(SandeshaMessageKeys.workNotPresent,workId));
        return;

View Full Code Here

        msgCtx.setProperty(Sandesha2Constants.WITHIN_TRANSACTION,
            Sandesha2Constants.VALUE_TRUE);
      }


      // update or delete only if the object is still present.
      SenderBean bean1 = senderBeanMgr
          .retrieve(senderBean.getMessageID());
      if (bean1 != null) {
        if (senderBean.isReSend()) {
          bean1.setSentCount(senderBean.getSentCount());
          bean1.setTimeToSend(senderBean.getTimeToSend());

View Full Code Here

    id.setIndentifer(sequenceId);
    sequenceAck.setIdentifier(id);


    SequencePropertyBeanMgr seqPropMgr = storageManager.getSequencePropertyBeanMgr();


    SequencePropertyBean seqBean = seqPropMgr.retrieve(sequencePropertyKey,
        Sandesha2Constants.SequenceProperties.SERVER_COMPLETED_MESSAGES);
    String msgNoList = (String) seqBean.getValue();


    ArrayList ackRangeArrayList = SandeshaUtil.getAckRangeArrayList(msgNoList, factory, rmNamespaceValue);
    Iterator iterator = ackRangeArrayList.iterator();

View Full Code Here

    while (iterator.hasNext()) {
      AcknowledgementRange ackRange = (AcknowledgementRange) iterator.next();
      sequenceAck.addAcknowledgementRanges(ackRange);
    }


    SequencePropertyBean sequenceClosedBean = seqPropMgr.retrieve(sequencePropertyKey,
        Sandesha2Constants.SequenceProperties.SEQUENCE_CLOSED);


    if (sequenceClosedBean != null && Sandesha2Constants.VALUE_TRUE.equals(sequenceClosedBean.getValue())) {
      // sequence is closed. so add the 'Final' part.
      if (SpecSpecificConstants.isAckFinalAllowed(rmVersion)) {

View Full Code Here

      throws SandeshaException {
    // Transaction lastActivatedTransaction =
    // storageManager.getTransaction();
    SequencePropertyBeanMgr sequencePropertyBeanMgr = storageManager.getSequencePropertyBeanMgr();


    SequencePropertyBean lastActivatedBean = sequencePropertyBeanMgr.retrieve(sequencePropertyKey,
        Sandesha2Constants.SequenceProperties.LAST_ACTIVATED_TIME);


    boolean added = false;


    if (lastActivatedBean == null) {

View Full Code Here


  public static long getLastActivatedTime(String propertyKey, StorageManager storageManager) throws SandeshaException {


    SequencePropertyBeanMgr seqPropBeanMgr = storageManager.getSequencePropertyBeanMgr();


    SequencePropertyBean lastActivatedBean = seqPropBeanMgr.retrieve(propertyKey,
        Sandesha2Constants.SequenceProperties.LAST_ACTIVATED_TIME);


    long lastActivatedTime = -1;


    if (lastActivatedBean != null) {

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.