Uses of Class
org.apache.sandesha2.RMMsgContext

Packages that use RMMsgContext
org.apache.sandesha2   
org.apache.sandesha2.msgprocessors   
org.apache.sandesha2.util   
 

Uses of RMMsgContext in org.apache.sandesha2
 

Methods in org.apache.sandesha2 with parameters of type RMMsgContext
static void MessageValidator.validateMessage(RMMsgContext rmMsg, StorageManager storageManager)
           
 

Uses of RMMsgContext in org.apache.sandesha2.msgprocessors
 

Methods in org.apache.sandesha2.msgprocessors with parameters of type RMMsgContext
 boolean TerminateSeqResponseMsgProcessor.processInMessage(RMMsgContext terminateResRMMsg)
           
 boolean TerminateSeqResponseMsgProcessor.processOutMessage(RMMsgContext rmMsgCtx)
           
 boolean CreateSeqMsgProcessor.processInMessage(RMMsgContext createSeqRMMsg)
           
 boolean CreateSeqMsgProcessor.processOutMessage(RMMsgContext rmMsgCtx)
           
 boolean ApplicationMsgProcessor.processInMessage(RMMsgContext rmMsgCtx)
           
 void ApplicationMsgProcessor.sendAckIfNeeded(RMMsgContext rmMsgCtx, java.lang.String messagesStr, StorageManager storageManager)
           
 boolean ApplicationMsgProcessor.processOutMessage(RMMsgContext rmMsgCtx)
           
 void ApplicationMsgProcessor.addCreateSequenceMessage(RMMsgContext referenceRMMsg, java.lang.String sequencePropertyKey, java.lang.String internalSequenceId, org.apache.axis2.addressing.EndpointReference acksTo, StorageManager storageManager)
           
 org.apache.axis2.addressing.EndpointReference ApplicationMsgProcessor.resolveAcksToValue(RMMsgContext rmMsgCtx, java.lang.String addressingAnonymousURI)
           
static MsgProcessor MsgProcessorFactory.getMessageProcessor(RMMsgContext rmMessageContext)
           
 boolean AckRequestedProcessor.processOutgoingAckRequestMessage(RMMsgContext ackRequestRMMsg)
          This is used to capture AckRequest messages send by the SandeshaClient.
 boolean CloseSequenceProcessor.processInMessage(RMMsgContext rmMsgCtx)
           
 boolean CloseSequenceProcessor.processOutMessage(RMMsgContext rmMsgCtx)
           
 boolean MsgProcessor.processInMessage(RMMsgContext rmMsgCtx)
           
 boolean MsgProcessor.processOutMessage(RMMsgContext rmMsgCtx)
           
 boolean CreateSeqResponseMsgProcessor.processInMessage(RMMsgContext createSeqResponseRMMsgCtx)
           
 boolean CreateSeqResponseMsgProcessor.processOutMessage(RMMsgContext rmMsgCtx)
           
 boolean MakeConnectionProcessor.processInMessage(RMMsgContext rmMsgCtx)
          Prosesses incoming MakeConnection request messages.
 boolean MakeConnectionProcessor.processOutMessage(RMMsgContext rmMsgCtx)
           
 boolean TerminateSeqMsgProcessor.processInMessage(RMMsgContext terminateSeqRMMsg)
           
 boolean TerminateSeqMsgProcessor.processOutMessage(RMMsgContext rmMsgCtx)
           
 void UsesSequenceSTRProcessor.processUseSequenceSTRHeader(RMMsgContext rmMsgContext)
           
 

Uses of RMMsgContext in org.apache.sandesha2.util
 

Methods in org.apache.sandesha2.util that return RMMsgContext
static RMMsgContext AcknowledgementManager.generateAckMessage(RMMsgContext referenceRMMessage, java.lang.String sequencePropertyKey, java.lang.String sequenceId, StorageManager storageManager)
           
static RMMsgContext RMMsgCreator.createCreateSeqMsg(RMMsgContext applicationRMMsg, java.lang.String sequencePropertyKey, org.apache.axis2.addressing.EndpointReference acksToEPR, StorageManager storageManager)
          Create a new CreateSeqnence message.
static RMMsgContext RMMsgCreator.createTerminateSequenceMessage(RMMsgContext referenceRMMessage, java.lang.String sequenceId, java.lang.String sequencePropertyKey, StorageManager storageManager)
          Creates a new TerminateSequence message.
static RMMsgContext RMMsgCreator.createCreateSeqResponseMsg(RMMsgContext createSeqMessage, org.apache.axis2.context.MessageContext outMessage, java.lang.String newSequenceID, StorageManager storageManager)
          Create a new CreateSequenceResponse message.
static RMMsgContext RMMsgCreator.createTerminateSeqResponseMsg(RMMsgContext terminateSeqRMMsg, org.apache.axis2.context.MessageContext outMessage, StorageManager storageManager)
           
static RMMsgContext RMMsgCreator.createCloseSeqResponseMsg(RMMsgContext closeSeqRMMsg, org.apache.axis2.context.MessageContext outMessage, StorageManager storageManager)
           
static RMMsgContext RMMsgCreator.createMakeConnectionMessage(RMMsgContext referenceRMMessage, java.lang.String makeConnectionSeqId, java.lang.String makeConnectionAnonURI, StorageManager storageManager)
           
 RMMsgContext FaultManager.checkForMessageNumberRoleover(org.apache.axis2.context.MessageContext messageContext)
           
static RMMsgContext MsgInitializer.initializeMessage(org.apache.axis2.context.MessageContext ctx)
          Called to create a rmMessageContext out of an message context.
 

Methods in org.apache.sandesha2.util with parameters of type RMMsgContext
static void TerminateManager.addTerminateSequenceMessage(RMMsgContext referenceMessage, java.lang.String outSequenceId, java.lang.String sequencePropertyKey, StorageManager storageManager)
           
static void AcknowledgementManager.piggybackAcksIfPresent(RMMsgContext rmMessageContext, StorageManager storageManager)
          Piggybacks any available acks of the same sequence to the given application message.
static RMMsgContext AcknowledgementManager.generateAckMessage(RMMsgContext referenceRMMessage, java.lang.String sequencePropertyKey, java.lang.String sequenceId, StorageManager storageManager)
           
static org.apache.axis2.context.MessageContext SandeshaUtil.createNewRelatedMessageContext(RMMsgContext referenceRMMessage, org.apache.axis2.description.AxisOperation operation)
           
static java.lang.String SandeshaUtil.getSequenceIDFromRMMessage(RMMsgContext rmMessageContext)
           
static java.lang.String SandeshaUtil.getSequencePropertyKey(RMMsgContext rmMsgContext)
          This returns the Key used when store SequencePropertyBeans for the passed message.
static void SandeshaUtil.executeAndStore(RMMsgContext rmMsgContext, java.lang.String storageKey)
           
static RMMsgContext RMMsgCreator.createCreateSeqMsg(RMMsgContext applicationRMMsg, java.lang.String sequencePropertyKey, org.apache.axis2.addressing.EndpointReference acksToEPR, StorageManager storageManager)
          Create a new CreateSeqnence message.
static RMMsgContext RMMsgCreator.createTerminateSequenceMessage(RMMsgContext referenceRMMessage, java.lang.String sequenceId, java.lang.String sequencePropertyKey, StorageManager storageManager)
          Creates a new TerminateSequence message.
static RMMsgContext RMMsgCreator.createCreateSeqResponseMsg(RMMsgContext createSeqMessage, org.apache.axis2.context.MessageContext outMessage, java.lang.String newSequenceID, StorageManager storageManager)
          Create a new CreateSequenceResponse message.
static RMMsgContext RMMsgCreator.createTerminateSeqResponseMsg(RMMsgContext terminateSeqRMMsg, org.apache.axis2.context.MessageContext outMessage, StorageManager storageManager)
           
static RMMsgContext RMMsgCreator.createCloseSeqResponseMsg(RMMsgContext closeSeqRMMsg, org.apache.axis2.context.MessageContext outMessage, StorageManager storageManager)
           
static void RMMsgCreator.addAckMessage(RMMsgContext applicationMsg, java.lang.String sequencePropertyKey, java.lang.String sequenceId, StorageManager storageManager)
          Adds an ack message to the given application message.
static RMMsgContext RMMsgCreator.createMakeConnectionMessage(RMMsgContext referenceRMMessage, java.lang.String makeConnectionSeqId, java.lang.String makeConnectionAnonURI, StorageManager storageManager)
           
static java.lang.String SequenceManager.setupNewSequence(RMMsgContext createSequenceMsg, StorageManager storageManager)
           
static boolean SequenceManager.hasSequenceTimedOut(java.lang.String propertyKey, RMMsgContext rmMsgCtx, StorageManager storageManager)
           
 SandeshaException FaultManager.checkForLastMsgNumberExceeded(RMMsgContext applicationRMMessage, StorageManager storageManager)
          Check weather the LastMessage number has been exceeded and generate the fault if it is.
 SandeshaException FaultManager.checkForUnknownSequence(RMMsgContext rmMessageContext, java.lang.String sequenceID, StorageManager storageManager)
          Check whether a Sequence message (a) belongs to a unknown sequence (generates an UnknownSequence fault) (b) message number exceeds a predifined limit ( genenrates a Message Number Rollover fault)
 SandeshaException FaultManager.checkForInvalidAcknowledgement(RMMsgContext ackRMMessageContext, StorageManager storageManager)
          Check weather the Acknowledgement is invalid and generate a fault if it is.
 SandeshaException FaultManager.checkForSequenceClosed(RMMsgContext referenceRMMessage, java.lang.String sequenceID, StorageManager storageManager)
           
 SandeshaException FaultManager.getFault(RMMsgContext referenceRMMsgContext, FaultData data, java.lang.String addressingNamespaceURI, StorageManager storageManager)
          Adds the necessary Fault elements as properties to the message context.
static boolean MessageRetransmissionAdjuster.adjustRetransmittion(RMMsgContext rmMsgCtx, SenderBean retransmitterBean, org.apache.axis2.context.ConfigurationContext configContext, StorageManager storageManager)
           
 



Copyright © 2005-2006 Apache Web Services. All Rights Reserved.