Package org.apache.sandesha2.storage.beanmanagers

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

203
204
205
206
207
208
209
210
211
212
213
    else
      seqPropMgr.update(noOfMsgsAckedBean);
   
   
    //setting the completed_messages list. This gives all the messages of the sequence that were acked.
    SequencePropertyBean allCompletedMsgsBean = seqPropMgr.retrieve(internalSequenceId,Sandesha2Constants.SequenceProperties.CLIENT_COMPLETED_MESSAGES);
    if (allCompletedMsgsBean==null) {
      allCompletedMsgsBean = new SequencePropertyBean ();
      allCompletedMsgsBean.setSequenceID(internalSequenceId);
      allCompletedMsgsBean.setName(Sandesha2Constants.SequenceProperties.CLIENT_COMPLETED_MESSAGES);
     
View Full Code Here
646
647
648
649
650
651
652
653
654
655
656
      ConfigurationContext configurationContext) throws SandeshaException {

    StorageManager storageManager = getSandeshaStorageManager(configurationContext);
    SequencePropertyBeanMgr sequencePropertyBeanMgr = storageManager.getSequencePropretyBeanMgr();

    SequencePropertyBean outSequenceBean = sequencePropertyBeanMgr.retrieve(internalSequenceID,
        Sandesha2Constants.SequenceProperties.OUT_SEQUENCE_ID);

    String sequeunceID = null;
    if (outSequenceBean != null)
      sequeunceID = outSequenceBean.getValue();
View Full Code Here
774
775
776
777
778
779
780
781
782
783
784
  public static String getRMVersion(String propertyKey, ConfigurationContext configurationContext)
      throws SandeshaException {
    StorageManager storageManager = getSandeshaStorageManager(configurationContext);

    SequencePropertyBeanMgr sequencePropertyBeanMgr = storageManager.getSequencePropretyBeanMgr();
    SequencePropertyBean specVersionBean = sequencePropertyBeanMgr.retrieve(propertyKey,
        Sandesha2Constants.SequenceProperties.RM_SPEC_VERSION);

    if (specVersionBean == null)
      return null;
View Full Code Here
788
789
790
791
792
793
794
795
796
797
798
  public static String getSequenceProperty(String id, String name, ConfigurationContext context)
      throws SandeshaException {
    StorageManager storageManager = SandeshaUtil.getSandeshaStorageManager(context);
    SequencePropertyBeanMgr sequencePropertyBeanMgr = storageManager.getSequencePropretyBeanMgr();

    SequencePropertyBean sequencePropertyBean = sequencePropertyBeanMgr.retrieve(id, name);
    if (sequencePropertyBean == null)
      return null;
    else
      return sequencePropertyBean.getValue();
  }
View Full Code Here
209
210
211
212
213
214
215
216
217
218
219
    String propertyKey = null;
    if (rmMsgCtx.getMessageContext().getFLOW()==MessageContext.IN_FLOW) {
      propertyKey = sequenceID;
    } else {
      SequencePropertyBean internalSequenceIDBean = sequencePropertyBeanMgr.retrieve(sequenceID,Sandesha2Constants.SequenceProperties.INTERNAL_SEQUENCE_ID);
      if (internalSequenceIDBean!=null) {
        propertyKey = internalSequenceIDBean.getValue();
      }
    }
   
View Full Code Here
161
162
163
164
165
166
167
168
169
170
171
   
    //processing for accept (offer has been sent)
    Accept accept = createSeqResponsePart.getAccept();
    if (accept != null) {
      //Find offered sequence from internal sequence id.
      SequencePropertyBean offeredSequenceBean = sequencePropMgr
          .retrieve(internalSequenceId,
              Sandesha2Constants.SequenceProperties.OFFERED_SEQUENCE);

      //TODO this should be detected in the Fault manager.
      if (offeredSequenceBean == null) {
View Full Code Here
193
194
195
196
197
198
199
200
201
202
203
    ConfigurationContext configurationContext = referenceRMMessage.getMessageContext().getConfigurationContext();
    StorageManager storageManager = SandeshaUtil.getSandeshaStorageManager(configurationContext);
    SequencePropertyBeanMgr seqPropMgr = storageManager.getSequencePropretyBeanMgr();
   
    //Setting the ack depending on AcksTo.
    SequencePropertyBean acksToBean = seqPropMgr.retrieve(sequenceID,
        Sandesha2Constants.SequenceProperties.ACKS_TO_EPR);

    EndpointReference acksTo = new EndpointReference(acksToBean.getValue());
    String acksToStr = acksTo.getAddress();
View Full Code Here
96
97
98
99
100
101
102
103
104
105
106
    while (iterator.hasNext()) {
      InvokerBean storageMapBean = (InvokerBean) iterator.next();
      storageMapBeanMgr.delete(storageMapBean.getKey());
    }
   
    SequencePropertyBean allSequenceBean = sequencePropertyBeanMgr.retrieve(Sandesha2Constants.SequenceProperties.ALL_SEQUENCES,Sandesha2Constants.SequenceProperties.INCOMING_SEQUENCE_LIST);
    ArrayList allSequenceList = (ArrayList) allSequenceBean.getValue();
   
    allSequenceList.remove(sequenceID);
  }
 
View Full Code Here
127
128
129
130
131
132
133
134
135
136
137
    StorageManager storageManager = SandeshaUtil.getSandeshaStorageManager(configContext);
    SequencePropertyBeanMgr sequencePropertyBeanMgr = storageManager.getSequencePropretyBeanMgr();
    SenderBeanMgr retransmitterBeanMgr = storageManager.getRetransmitterBeanMgr();
    CreateSeqBeanMgr createSeqBeanMgr = storageManager.getCreateSeqBeanMgr();
   
    SequencePropertyBean internalSequenceBean = sequencePropertyBeanMgr.retrieve(sequenceID,Sandesha2Constants.SequenceProperties.INTERNAL_SEQUENCE_ID);
    if (internalSequenceBean==null)
      throw new SandeshaException ("TempSequence entry not found");
   
    String internalSequenceId = (String) internalSequenceBean.getValue();
   
View Full Code Here
65
66
67
68
69
70
71
72
73
74
75
      throw new SandeshaException(
          "Application message does not contain a sequence part");

    String sequenceId = sequence.getIdentifier().getIdentifier();

    SequencePropertyBean internalSequenceBean = sequencePropertyBeanMgr
        .retrieve(sequenceId,
            Sandesha2Constants.SequenceProperties.INTERNAL_SEQUENCE_ID);
    if (internalSequenceBean == null)
      throw new SandeshaException("Temp Sequence is not set");
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.