List of retrieveMessageContext() Examples

Examples of retrieveMessageContext()

org.apache.sandesha2.storage.StorageManager.retrieveMessageContext()

Examples of org.apache.sandesha2.storage.StorageManager.retrieveMessageContext()

    String storedKey = (String) retransmitterBean.getMessageContextRefKey();


    if (storedKey == null)
      throw new SandeshaException ("Stored Key not present in the retransmittable message");


    MessageContext messageContext = storageManager.retrieveMessageContext(storedKey,configContext);
    RMMsgContext rmMsgCtx = MsgInitializer.initializeMessage(messageContext);
    
    String internalSequenceID = retransmitterBean.getInternalSequenceID();
    String sequenceID = retransmitterBean.getSequenceID();

View Full Code Here

Examples of org.apache.sandesha2.storage.StorageManager.retrieveMessageContext()

        transaction = tran;
      }
      
      InvokerBean invokerBean = invokerBeanMgr.retrieve(messageContextKey);


      msgToInvoke = storageManager.retrieveMessageContext(messageContextKey, configurationContext);
      if(msgToInvoke==null){
        //return since there is nothing to do
        if(log.isDebugEnabled()) log.debug("null msg");
        return false;
      }

View Full Code Here

Examples of org.apache.sandesha2.storage.StorageManager.retrieveMessageContext()

      RMMsgContext   rmMsgCtx = null;
      if(messageToSend != null) {
        msgCtx = messageToSend.getMessageContext();
        rmMsgCtx = messageToSend;
      } else {
        msgCtx = storageManager.retrieveMessageContext(key, configurationContext);
      
        if (msgCtx == null) {
          // This sender bean has already been processed
          
          if(transaction != null && transaction.isActive()) transaction.commit();

View Full Code Here

Examples of org.apache.sandesha2.storage.StorageManager.retrieveMessageContext()

        
        //TODO recheck
        RMSBean rmsBean = storageManager.getRMSBeanMgr().findUnique(findBean);
        if (rmsBean!=null) {          
          //AckManager hs not done the termination. Do the termination here.
          MessageContext requestSideRefMessage = storageManager.retrieveMessageContext(rmsBean.getReferenceMessageStoreKey(),context);
          if (requestSideRefMessage==null) {
            FaultManager.makeCreateSequenceRefusedFault(createSeqRMMsg, 
                SandeshaMessageHelper.getMessage(SandeshaMessageKeys.referencedMessageNotFound, rmsBean.getInternalSequenceID()),
                new Exception(), null);            
            // Return false if an Exception hasn't been thrown.

View Full Code Here

Examples of org.apache.sandesha2.storage.StorageManager.retrieveMessageContext()

        //Storing the referenceMessage of the sending side sequence as the reference message
        //of the receiving side as well.
        //This can be used when creating new outgoing messages.
        
        String referenceMsgStoreKey = rmsBean.getReferenceMessageStoreKey();
        MessageContext referenceMsg = storageManager.retrieveMessageContext(referenceMsgStoreKey, configCtx);
        
        String newMessageStoreKey = SandeshaUtil.getUUID();
        storageManager.storeMessageContext(newMessageStoreKey,referenceMsg);
        
        rMDBean.setReferenceMessageKey(newMessageStoreKey);

View Full Code Here

Examples of org.apache.sandesha2.storage.StorageManager.retrieveMessageContext()

                //we use replay model)
                String storageKey = retransmitterBean.getMessageContextRefKey();


                boolean syncResponseNeeded = false;
                if (anonReplyTo) {
                  MessageContext applicationMessage = storageManager.retrieveMessageContext(storageKey, configCtx);
                  AxisOperation operation = applicationMessage.getAxisOperation();
                  if(operation!= null) {
                    int mep = operation.getAxisSpecificMEPConstant();
                    syncResponseNeeded = (mep == WSDLConstants.MEP_CONSTANT_OUT_IN);
                  }

View Full Code Here

Examples of org.apache.sandesha2.storage.StorageManager.retrieveMessageContext()

      
        EndpointReference toEPR = new EndpointReference (outgoingSideTerminateBean.getToAddress());
        if (toEPR.hasAnonymousAddress()) {
          String messageKey = outgoingSideTerminateBean
              .getMessageContextRefKey();
          MessageContext message = storageManager
              .retrieveMessageContext(messageKey, context);


          RMMsgContext rmMessage = MsgInitializer.initializeMessage(message);
          
          // attaching the this outgoing terminate message as the

View Full Code Here

Examples of org.apache.sandesha2.storage.StorageManager.retrieveMessageContext()

      InvokerBean invokerBean = invokerBeanMgr.retrieve(messageContextKey);
      
      String sequenceId = invokerBean.getSequenceID();
      long messageNo = invokerBean.getMsgNo();
      
      msgToInvoke = storageManager.retrieveMessageContext(messageContextKey, configurationContext);
      RMMsgContext rmMsg = MsgInitializer.initializeMessage(msgToInvoke);


      String sequencePropertyKey = SandeshaUtil.getSequencePropertyKey(rmMsg);
      
      //endint the transaction before invocation.

View Full Code Here

Examples of org.apache.sandesha2.storage.StorageManager.retrieveMessageContext()

      // exception get thrown in invocation
      // the service will not be invoked again.
      invokerBeanMgr.delete(messageContextKey);


      // removing the corresponding message context as well.
      MessageContext msgCtx = storageManager.retrieveMessageContext(messageContextKey, configurationContext);
      if (msgCtx != null) {
        storageManager.removeMessageContext(messageContextKey);
      }


      // updating the next msg to invoke

View Full Code Here

Examples of org.apache.sandesha2.storage.StorageManager.retrieveMessageContext()

        if (log.isDebugEnabled())
          log.debug(SandeshaMessageHelper.getMessage(SandeshaMessageKeys.workNotPresent,workId));
        return;
      }
      String key = senderBean.getMessageContextRefKey();
      MessageContext msgCtx = storageManager.retrieveMessageContext(key, configurationContext);
      msgCtx.setProperty(Sandesha2Constants.WITHIN_TRANSACTION, Sandesha2Constants.VALUE_TRUE);


      RMMsgContext rmMsgCtx = MsgInitializer.initializeMessage(msgCtx);


      boolean continueSending = MessageRetransmissionAdjuster.adjustRetransmittion(rmMsgCtx, senderBean, configurationContext,

View Full Code Here

0 1 2

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.