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

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

    ConfigurationContext configCtx = rmMsgCtx.getMessageContext()
        .getConfigurationContext();
    if (configCtx == null)
      throw new SandeshaException("Configuration Context is null");


    SequencePropertyBean msgsBean = seqPropMgr.retrieve(sequenceId,
        Sandesha2Constants.SequenceProperties.RECEIVED_MESSAGES);


    long msgNo = sequence.getMessageNumber().getMessageNumber();
    if (msgNo == 0)
      throw new SandeshaException("Wrong message number");

View Full Code Here

      boolean inOrderInvocation = PropertyManager.getInstance().isInOrderInvocation();
      if (inOrderInvocation) {
        //pause the message
        msgCtx.setPausedTrue(new QName(Sandesha2Constants.IN_HANDLER_NAME));


        SequencePropertyBean incomingSequenceListBean = (SequencePropertyBean) seqPropMgr
            .retrieve(
                Sandesha2Constants.SequenceProperties.ALL_SEQUENCES,
                Sandesha2Constants.SequenceProperties.INCOMING_SEQUENCE_LIST);


        if (incomingSequenceListBean == null) {

View Full Code Here

    try {
      MessageContext requestMessage = rmMsgCtx.getMessageContext()
          .getOperationContext().getMessageContext(
              WSDLConstants.MESSAGE_LABEL_IN_VALUE);
      String requestMessageId = requestMessage.getMessageID();
      SequencePropertyBean checkResponseBean = seqPropMgr.retrieve(
          requestMessageId,
          Sandesha2Constants.SequenceProperties.CHECK_RESPONSE);
      if (checkResponseBean != null) {
        checkResponseBean.setValue(msgCtx);
        seqPropMgr.update(checkResponseBean);

View Full Code Here

    AckRequested ackRequested = (AckRequested) rmMsgCtx
        .getMessagePart(Sandesha2Constants.MessageParts.ACK_REQUEST);
    LastMessage lastMessage = (LastMessage) sequence.getLastMessage();


    //Setting the ack depending on AcksTo.
    SequencePropertyBean acksToBean = seqPropMgr.retrieve(sequenceId,
        Sandesha2Constants.SequenceProperties.ACKS_TO_EPR);


    EndpointReference acksTo = (EndpointReference) acksToBean.getValue();
    String acksToStr = acksTo.getAddress();

View Full Code Here

        outSequenceBean.setSequenceId(newSequenceId);
        seqPropMgr.insert(outSequenceBean);


        //Temp sequence id should be set for the server side.
        //If internal sequence id is not set. this implies server side.
        SequencePropertyBean internalSeqBean = seqPropMgr.retrieve(
            outSequenceId,
            Sandesha2Constants.SequenceProperties.INTERNAL_SEQUENCE_ID);
        if (internalSeqBean == null) {
          SequencePropertyBean internalSequenceBean = new SequencePropertyBean();
          internalSequenceBean

View Full Code Here

    Iterator nackIterator = sequenceAck.getNackList().iterator();
    String outSequenceId = sequenceAck.getIdentifier().getIdentifier();
    if (outSequenceId == null || "".equals(outSequenceId))
      throw new SandeshaException("OutSequenceId is null");


    SequencePropertyBean internalSequenceBean = seqPropMgr.retrieve(
        outSequenceId, Sandesha2Constants.SequenceProperties.INTERNAL_SEQUENCE_ID);


    if (internalSequenceBean == null || internalSequenceBean.getValue() == null)
      throw new SandeshaException("TempSequenceId is not set correctly");

View Full Code Here


    //following get called in the SandesaInHandler
    //if (justSendTerminateIfNeeded) {
    //If all messages up to last message have been acknowledged.
    //Add terminate Sequence message.
    SequencePropertyBean lastOutMsgBean = seqPropMgr.retrieve(
        internalSequenceId, Sandesha2Constants.SequenceProperties.LAST_OUT_MESSAGE);
    if (lastOutMsgBean != null) {
      Long lastOutMsgNoLng = (Long) lastOutMsgBean.getValue();
      if (lastOutMsgNoLng == null)
        throw new SandeshaException(

View Full Code Here

            .getConfigurationContext());


    SequencePropertyBeanMgr seqPropMgr = storageManager
        .getSequencePropretyBeanMgr();


    SequencePropertyBean terminated = seqPropMgr.retrieve(outSequenceId,
        Sandesha2Constants.SequenceProperties.TERMINATE_ADDED);


    if (terminated != null && terminated.getValue() != null
        && "true".equals(terminated.getValue())) {
      System.out.println("TERMINATE WAS ADDED PREVIOUSLY....");

View Full Code Here

    }


    RMMsgContext terminateRMMessage = RMMsgCreator
        .createTerminateSequenceMessage(incomingAckRMMsg, outSequenceId);


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


    EndpointReference toEPR = (EndpointReference) toBean.getValue();
    if (toEPR == null)
      throw new SandeshaException("To EPR has an invalid value");

View Full Code Here


    //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

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.