Package org.apache.sandesha2.storage.beanmanagers

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

227
228
229
230
231
232
233
234
235
236
237
            transportIn = org.apache.axis2.Constants.TRANSPORT_HTTP;
          ListenerManager.makeSureStarted(transportIn, context);
        } else if (acksTo == null && serverSide) {
          String incomingSequencId = SandeshaUtil
              .getServerSideIncomingSeqIdFromInternalSeqId(internalSequenceId);
          SequencePropertyBean bean = seqPropMgr.retrieve(
              incomingSequencId,
              Sandesha2Constants.SequenceProperties.REPLY_TO_EPR);
          if (bean != null) {
            EndpointReference acksToEPR = (EndpointReference) bean
                .getValue();
View Full Code Here
409
410
411
412
413
414
415
416
417
418
419
        .getSequencePropretyBeanMgr();

    SenderBeanMgr retransmitterMgr = storageManager
        .getRetransmitterBeanMgr();

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

    //again - looks weird in the client side - but consistent
View Full Code Here
411
412
413
414
415
416
417
418
419
420
421
    SenderBeanMgr retransmitterMgr = storageManager
        .getRetransmitterBeanMgr();

    SequencePropertyBean toBean = sequencePropertyMgr.retrieve(
        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,
View Full Code Here
415
416
417
418
419
420
421
422
423
424
425
        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)
      throw new SandeshaException("To is null");
View Full Code Here
577
578
579
580
581
582
583
584
585
586
587
    StorageManager storageManager = SandeshaUtil
        .getSandeshaStorageManager(context);

    SequencePropertyBeanMgr seqPropMgr = storageManager
        .getSequencePropretyBeanMgr();
    SequencePropertyBean nextMsgNoBean = seqPropMgr.retrieve(
        internalSequenceId,
        Sandesha2Constants.SequenceProperties.NEXT_MESSAGE_NUMBER);
    long nextMsgNo = 1;
    boolean update = false;
    if (nextMsgNoBean != null) {
View Full Code Here
237
238
239
240
241
242
243
244
245
246
247
      SequenceManager.updateLastActivatedTime(newSequenceId, storageManager);

      AxisEngine engine = new AxisEngine(context);
      engine.send(outMessage);

      SequencePropertyBean toBean = seqPropMgr.retrieve(newSequenceId,
          Sandesha2Constants.SequenceProperties.TO_EPR);
      if (toBean == null) {
        String message = SandeshaMessageHelper.getMessage(SandeshaMessageKeys.toEPRNotValid, null);
        log.debug(message);
        throw new SandeshaException(message);
View Full Code Here
194
195
196
197
198
199
200
201
202
203
204
            .getSequencePropertyBeanMgr();

        transaction = storageManager.getTransaction();

        // Getting the incomingSequenceIdList
        SequencePropertyBean allSequencesBean = sequencePropMgr
            .retrieve(
                Sandesha2Constants.SequenceProperties.ALL_SEQUENCES,
                Sandesha2Constants.SequenceProperties.INCOMING_SEQUENCE_LIST);

        if (allSequencesBean == null) {
View Full Code Here
100
101
102
103
104
105
106
107
108
109
110
    ConfigurationContext context = terminateSeqMsg.getConfigurationContext();
    StorageManager storageManager = SandeshaUtil.getSandeshaStorageManager(context,context.getAxisConfiguration());
    SequencePropertyBeanMgr sequencePropertyBeanMgr = storageManager.getSequencePropertyBeanMgr();
   
    // Check that the sender of this TerminateSequence holds the correct token
    SequencePropertyBean tokenBean = sequencePropertyBeanMgr.retrieve(sequencePropertyKey, Sandesha2Constants.SequenceProperties.SECURITY_TOKEN);
    if(tokenBean != null) {
      SecurityManager secManager = SandeshaUtil.getSecurityManager(context);
      OMElement body = terminateSeqRMMsg.getSOAPEnvelope().getBody();
      SecurityToken token = secManager.recoverSecurityToken(tokenBean.getValue());
      secManager.checkProofOfPossession(token, body, terminateSeqRMMsg.getMessageContext());
View Full Code Here
193
194
195
196
197
198
199
200
201
202
203
     
      String propertyKey = SandeshaUtil.getSequencePropertyKey(rmMsgContext);

      if (propertyKey != null && msgNo > 0) {
        SequencePropertyBeanMgr seqPropMgr = storageManager.getSequencePropertyBeanMgr();
        SequencePropertyBean receivedMsgsBean = seqPropMgr.retrieve(propertyKey,
            Sandesha2Constants.SequenceProperties.SERVER_COMPLETED_MESSAGES);
        if (receivedMsgsBean != null) {
          String receivedMsgStr = receivedMsgsBean.getValue();
          ArrayList msgNoArrList = SandeshaUtil.getSplittedMsgNoArraylist(receivedMsgStr);
View Full Code Here
304
305
306
307
308
309
310
311
312
313
314
      if (sequence != null) {
        sequenceId = sequence.getIdentifier().getIdentifier();
      }

      SequencePropertyBeanMgr seqPropMgr = storageManager.getSequencePropertyBeanMgr();
      SequencePropertyBean receivedMsgsBean = seqPropMgr.retrieve(sequenceId,
          Sandesha2Constants.SequenceProperties.SERVER_COMPLETED_MESSAGES);
      String receivedMsgStr = receivedMsgsBean.getValue();

      ApplicationMsgProcessor ackProcessor = new ApplicationMsgProcessor();
      // Even though the duplicate message is dropped, hv to send the ack
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.