Package org.apache.sandesha2.storage.beanmanagers

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

844
845
846
847
848
849
850
851
852
853
854
        internalSequenceId,Sandesha2Constants.SequenceProperties.TO_EPR);
    SequencePropertyBean replyToBean = sequencePropertyMgr.retrieve(
        internalSequenceId,Sandesha2Constants.SequenceProperties.REPLY_TO_EPR);

    // again - looks weird in the client side - but consistent
    SequencePropertyBean outSequenceBean = sequencePropertyMgr.retrieve(
        internalSequenceId,Sandesha2Constants.SequenceProperties.OUT_SEQUENCE_ID);

    if (toBean == null) {
      String message = "To is null";
      log.debug(message);
View Full Code Here
932
933
934
935
936
937
938
939
940
941
942
      if (operationContext != null) {
        Object obj = msg.getProperty(SandeshaClientConstants.LAST_MESSAGE);
        if (obj != null && "true".equals(obj)) {
          lastMessage = true;
         
          SequencePropertyBean specVersionBean = sequencePropertyMgr.retrieve(internalSequenceId,Sandesha2Constants.SequenceProperties.RM_SPEC_VERSION);
          if (specVersionBean==null)
            throw new SandeshaException ("Spec version bean is not set");
         
          String specVersion = specVersionBean.getValue();
          if (SpecSpecificConstants.isLastMessageIndicatorRequired(specVersion))
View Full Code Here
1034
1035
1036
1037
1038
1039
1040
1041
1042
1043
1044
    //retrieving the storage managers
    StorageManager storageManager = SandeshaUtil.getSandeshaStorageManager(context);
    SequencePropertyBeanMgr seqPropMgr = storageManager.getSequencePropretyBeanMgr();
   
    SequencePropertyBean nextMsgNoBean = seqPropMgr.retrieve(
        internalSequenceId,Sandesha2Constants.SequenceProperties.NEXT_MESSAGE_NUMBER);
   
    long nextMsgNo = -1;
    if (nextMsgNoBean != null) {
      Long nextMsgNoLng = new Long(nextMsgNoBean.getValue());
View Full Code Here
1057
1058
1059
1060
1061
1062
1063
1064
1065
1066
1067
    }
   
    StorageManager storageManager = SandeshaUtil.getSandeshaStorageManager(context);
    SequencePropertyBeanMgr seqPropMgr = storageManager.getSequencePropretyBeanMgr();
   
    SequencePropertyBean nextMsgNoBean = seqPropMgr.retrieve(
        internalSequenceId,Sandesha2Constants.SequenceProperties.NEXT_MESSAGE_NUMBER);

    boolean update = true;
    if (nextMsgNoBean == null) {
      update = false;
View Full Code Here
496
497
498
499
500
501
502
503
504
505
506
    }
   
    StorageManager storageManager = SandeshaUtil.getSandeshaStorageManager(configurationContext);
    SequencePropertyBeanMgr seqPropMgr = storageManager.getSequencePropretyBeanMgr();
   
    SequencePropertyBean sequenceIDBean = seqPropMgr.retrieve(internalSequenceID,Sandesha2Constants.SequenceProperties.OUT_SEQUENCE_ID);
    if (sequenceIDBean==null)
      throw new SandeshaException ("SequenceIdBean is not set");
   
    String sequenceID = sequenceIDBean.getValue();
    return sequenceID;
View Full Code Here
619
620
621
622
623
624
625
626
627
628
629
    if (sequenceReport.getSequenceStatus()!=SequenceReport.SEQUENCE_STATUS_ESTABLISHED)
      throw new SandeshaException ("Canot close the sequence since it is not active");
   
    StorageManager storageManager = SandeshaUtil.getSandeshaStorageManager(configurationContext);
    SequencePropertyBeanMgr seqPropMgr = storageManager.getSequencePropretyBeanMgr();
    SequencePropertyBean sequenceIDBean = seqPropMgr.retrieve(internalSequenceID,Sandesha2Constants.SequenceProperties.OUT_SEQUENCE_ID);
    if (sequenceIDBean==null)
      throw new SandeshaException ("SequenceIdBean is not set");
   
    String sequenceID = sequenceIDBean.getValue();
View Full Code Here
757
758
759
760
761
762
763
764
765
766
767
 
  private static byte getServerSequenceStatus (String sequenceID,StorageManager storageManager) throws SandeshaException {
   
    SequencePropertyBeanMgr seqPropMgr = storageManager.getSequencePropretyBeanMgr();
   
    SequencePropertyBean terminatedBean = seqPropMgr.retrieve(sequenceID,Sandesha2Constants.SequenceProperties.SEQUENCE_TERMINATED);
    if (terminatedBean!=null) {
      return SequenceReport.SEQUENCE_STATUS_TERMINATED;
    }
   
    SequencePropertyBean timedOutBean = seqPropMgr.retrieve(sequenceID,Sandesha2Constants.SequenceProperties.SEQUENCE_TIMED_OUT);
View Full Code Here
762
763
764
765
766
767
768
769
770
771
772
    SequencePropertyBean terminatedBean = seqPropMgr.retrieve(sequenceID,Sandesha2Constants.SequenceProperties.SEQUENCE_TERMINATED);
    if (terminatedBean!=null) {
      return SequenceReport.SEQUENCE_STATUS_TERMINATED;
    }
   
    SequencePropertyBean timedOutBean = seqPropMgr.retrieve(sequenceID,Sandesha2Constants.SequenceProperties.SEQUENCE_TIMED_OUT);
    if (timedOutBean!=null) {
      return SequenceReport.SEQUENCE_STATUS_TIMED_OUT;
    }
   
    NextMsgBeanMgr nextMsgMgr = storageManager.getNextMsgBeanMgr();
View Full Code Here
840
841
842
843
844
845
846
847
848
849
850
    if (sequenceReport.getSequenceStatus()!=SequenceReport.SEQUENCE_STATUS_ESTABLISHED)
      throw new SandeshaException ("Canot terminate the sequence since it is not active");
   
    StorageManager storageManager = SandeshaUtil.getSandeshaStorageManager(configurationContext);
    SequencePropertyBeanMgr seqPropMgr = storageManager.getSequencePropretyBeanMgr();
    SequencePropertyBean sequenceIDBean = seqPropMgr.retrieve(internalSequenceID,Sandesha2Constants.SequenceProperties.OUT_SEQUENCE_ID);
    if (sequenceIDBean==null)
      throw new SandeshaException ("SequenceIdBean is not set");
   
    String sequenceID = sequenceIDBean.getValue();
View Full Code Here
359
360
361
362
363
364
365
366
367
368
369
  public static void updateLastActivatedTime (String propertyKey, ConfigurationContext configContext) throws SandeshaException {
    StorageManager storageManager = SandeshaUtil.getSandeshaStorageManager(configContext);
    //Transaction lastActivatedTransaction = storageManager.getTransaction();
    SequencePropertyBeanMgr sequencePropertyBeanMgr = storageManager.getSequencePropretyBeanMgr();
   
    SequencePropertyBean lastActivatedBean = sequencePropertyBeanMgr.retrieve(propertyKey, Sandesha2Constants.SequenceProperties.LAST_ACTIVATED_TIME);
   
    boolean added = false;
   
    if (lastActivatedBean==null) {
      added = true;
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.