Package org.apache.sandesha2.storage.beanmanagers

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

175
176
177
178
179
180
181
182
183
184
185
          //checking weather an outgoing sequence with the given id
          // exists.
          SequencePropertyBeanMgr sequencePropertyBeanMgr = storageManager
              .getSequencePropretyBeanMgr();
          SequencePropertyBean sequencePropertyBean = sequencePropertyBeanMgr
              .retrieve(
                  sequenceId,
                  Sandesha2Constants.SequenceProperties.OUT_SEQUENCE_ID);
          if (sequencePropertyBean != null) {
            String outSequenceId = (String) sequencePropertyBean
View Full Code Here
425
426
427
428
429
430
431
432
433
434
435
            .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 = (EndpointReference) acksToBean
              .getValue();
          if (epr != null)
View Full Code Here
156
157
158
159
160
161
162
163
164
165
166
        offerPart.setIdentifier(identifier);
        createSequencePart.setSequenceOffer(offerPart);
      }
    }

    SequencePropertyBean replyToBean = seqPropMgr.retrieve(internalSequenceId,
        Sandesha2Constants.SequenceProperties.REPLY_TO_EPR);
    SequencePropertyBean toBean = seqPropMgr.retrieve(internalSequenceId,
        Sandesha2Constants.SequenceProperties.TO_EPR);

    if (toBean == null || toBean.getValue() == null)
View Full Code Here
158
159
160
161
162
163
164
165
166
167
168
      }
    }

    SequencePropertyBean replyToBean = seqPropMgr.retrieve(internalSequenceId,
        Sandesha2Constants.SequenceProperties.REPLY_TO_EPR);
    SequencePropertyBean toBean = seqPropMgr.retrieve(internalSequenceId,
        Sandesha2Constants.SequenceProperties.TO_EPR);

    if (toBean == null || toBean.getValue() == null)
      throw new SandeshaException("To EPR is not set.");
View Full Code Here
374
375
376
377
378
379
380
381
382
383
384
    StorageManager storageManager = SandeshaUtil
        .getSandeshaStorageManager(ctx);
    SequencePropertyBeanMgr seqPropMgr = storageManager
        .getSequencePropretyBeanMgr();

    SequencePropertyBean seqBean = seqPropMgr.retrieve(sequenceId,
        Sandesha2Constants.SequenceProperties.RECEIVED_MESSAGES);
    String msgNoList = (String) seqBean.getValue();

    ArrayList ackRangeArrayList = SandeshaUtil.getAckRangeArrayList(msgNoList,factory);
    Iterator iterator = ackRangeArrayList.iterator();
View Full Code Here
94
95
96
97
98
99
100
101
102
103
104
        SequencePropertyBeanMgr sequencePropMgr = storageManager
            .getSequencePropretyBeanMgr();

        //Getting the incomingSequenceIdList
        SequencePropertyBean sequencePropertyBean = (SequencePropertyBean) sequencePropMgr
            .retrieve(
                Sandesha2Constants.SequenceProperties.ALL_SEQUENCES,
                Sandesha2Constants.SequenceProperties.INCOMING_SEQUENCE_LIST);
        if (sequencePropertyBean == null)
          continue;
View Full Code Here
133
134
135
136
137
138
139
140
141
142
143
        StorageManager storageManager = SandeshaUtil
            .getSandeshaStorageManager(rmMsgContext
                .getMessageContext().getConfigurationContext());
        SequencePropertyBeanMgr seqPropMgr = storageManager
            .getSequencePropretyBeanMgr();
        SequencePropertyBean receivedMsgsBean = seqPropMgr.retrieve(
            sequenceId,
            Sandesha2Constants.SequenceProperties.RECEIVED_MESSAGES);
        if (receivedMsgsBean != null) {
          String receivedMsgStr = (String) receivedMsgsBean
              .getValue();
View Full Code Here
221
222
223
224
225
226
227
228
229
230
231
      StorageManager storageManager = SandeshaUtil
          .getSandeshaStorageManager(rmMsgContext.getMessageContext()
              .getConfigurationContext());
      SequencePropertyBeanMgr seqPropMgr = storageManager
          .getSequencePropretyBeanMgr();
      SequencePropertyBean receivedMsgsBean = seqPropMgr.retrieve(
          sequenceId, Sandesha2Constants.SequenceProperties.RECEIVED_MESSAGES);
      String receivedMsgStr = (String) receivedMsgsBean.getValue();

      ApplicationMsgProcessor ackProcessor = new ApplicationMsgProcessor();
      //Even though the duplicate message is dropped, hv to send the ack
View Full Code Here
178
179
180
181
182
183
184
185
186
187
188
    long messageNumber = getNextMsgNo(context, internalSequenceId);

    boolean sendCreateSequence = false;

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

    if (messageNumber == 1) {
      if (outSeqBean == null) {
View Full Code Here
196
197
198
199
200
201
202
203
204
205
206
    }

    //if first message - add create sequence
    if (sendCreateSequence) {

      SequencePropertyBean responseCreateSeqAdded = seqPropMgr.retrieve(
          internalSequenceId,
          Sandesha2Constants.SequenceProperties.OUT_CREATE_SEQUENCE_SENT);

      if (responseCreateSeqAdded == null) {
        responseCreateSeqAdded = new SequencePropertyBean(
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.