Uses of Class
org.apache.sandesha2.RMMsgContext

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

Uses of RMMsgContext in org.apache.sandesha2
 

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

Uses of RMMsgContext in org.apache.sandesha2.msgprocessors
 

Methods in org.apache.sandesha2.msgprocessors with parameters of type RMMsgContext
static MsgProcessor MsgProcessorFactory.getMessageProcessor(RMMsgContext rmMessageContext)
           
 boolean CloseSequenceProcessor.processInMessage(RMMsgContext rmMsgCtx, Transaction transaction)
           
 boolean CloseSequenceProcessor.processOutMessage(RMMsgContext rmMsgCtx)
           
 boolean MakeConnectionProcessor.processInMessage(RMMsgContext rmMsgCtx, Transaction transaction)
          Prosesses incoming MakeConnection request messages.
static void MakeConnectionProcessor.replyToPoll(RMMsgContext pollMessage, SenderBean matchingMessage, StorageManager storageManager, boolean pending, java.lang.String makeConnectionNamespace, Transaction transaction)
           
 boolean MakeConnectionProcessor.processOutMessage(RMMsgContext rmMsgCtx)
           
 boolean ApplicationMsgProcessor.processInMessage(RMMsgContext rmMsgCtx, Transaction transaction)
           
 boolean ApplicationMsgProcessor.processOutMessage(RMMsgContext rmMsgCtx)
           
 void MessagePendingProcessor.processMessagePendingHeaders(RMMsgContext message)
           
 boolean TerminateSeqMsgProcessor.processInMessage(RMMsgContext terminateSeqRMMsg, Transaction transaction)
           
 boolean TerminateSeqMsgProcessor.processOutMessage(RMMsgContext rmMsgCtx)
           
 org.apache.axis2.engine.Handler.InvocationResponse SequenceProcessor.processSequenceHeader(RMMsgContext rmMsgCtx, Transaction transaction)
           
 org.apache.axis2.engine.Handler.InvocationResponse SequenceProcessor.processReliableMessage(RMMsgContext rmMsgCtx, Transaction transaction)
           
 boolean LastMessageProcessor.processInMessage(RMMsgContext rmMsgCtx, Transaction transaction)
           
 boolean LastMessageProcessor.processOutMessage(RMMsgContext rmMsgCtx)
           
static void LastMessageProcessor.processLastMessage(RMMsgContext rmMsgCtx)
           
 boolean TerminateSeqResponseMsgProcessor.processInMessage(RMMsgContext terminateResRMMsg, Transaction transaction)
           
 boolean TerminateSeqResponseMsgProcessor.processOutMessage(RMMsgContext rmMsgCtx)
           
 void AcknowledgementProcessor.processAckHeaders(RMMsgContext message)
           
 boolean MsgProcessor.processInMessage(RMMsgContext rmMsgCtx, Transaction transaction)
           
 boolean MsgProcessor.processOutMessage(RMMsgContext rmMsgCtx)
           
 boolean CreateSeqMsgProcessor.processInMessage(RMMsgContext createSeqRMMsg, Transaction transaction)
           
 boolean CreateSeqMsgProcessor.processOutMessage(RMMsgContext rmMsgCtx)
           
 boolean CreateSeqResponseMsgProcessor.processInMessage(RMMsgContext createSeqResponseRMMsgCtx, Transaction transaction)
           
 boolean CreateSeqResponseMsgProcessor.processOutMessage(RMMsgContext rmMsgCtx)
           
 boolean AckRequestedProcessor.processAckRequestedHeaders(RMMsgContext message)
           
 boolean AckRequestedProcessor.processAckRequestedHeader(RMMsgContext rmMsgCtx, org.apache.axiom.om.OMElement soapHeader, AckRequested ackRequested)
           
 boolean AckRequestedProcessor.processOutgoingAckRequestMessage(RMMsgContext ackRequestRMMsg)
          This is used to capture AckRequest messages send by the SandeshaClient.
 

Uses of RMMsgContext in org.apache.sandesha2.util
 

Methods in org.apache.sandesha2.util that return RMMsgContext
static RMMsgContext MsgInitializer.initializeMessage(org.apache.axis2.context.MessageContext ctx)
          Called to create a rmMessageContext out of an message context.
static RMMsgContext FaultManager.checkForMessageNumberRoleover(org.apache.axis2.context.MessageContext messageContext)
           
static RMMsgContext RMMsgCreator.createCreateSeqMsg(RMSBean rmsBean, RMMsgContext applicationRMMsg)
          Create a new CreateSequence message.
static RMMsgContext RMMsgCreator.createTerminateSequenceMessage(RMMsgContext referenceRMMessage, RMSBean rmsBean, StorageManager storageManager)
          Creates a new TerminateSequence message.
static RMMsgContext RMMsgCreator.createCreateSeqResponseMsg(RMMsgContext createSeqMessage, RMSequenceBean rmSequenceBean)
          Create a new CreateSequenceResponse message.
static RMMsgContext RMMsgCreator.createTerminateSeqResponseMsg(RMMsgContext terminateSeqRMMsg, RMSequenceBean rmSequenceBean)
           
static RMMsgContext RMMsgCreator.createCloseSeqResponseMsg(RMMsgContext closeSeqRMMsg, RMSequenceBean rmSequenceBean)
           
static RMMsgContext RMMsgCreator.createMakeConnectionMessage(RMMsgContext referenceRMMessage, RMSequenceBean bean, java.lang.String makeConnectionSeqId, java.lang.String makeConnectionAnonURI, StorageManager storageManager)
           
static RMMsgContext AcknowledgementManager.generateAckMessage(RMMsgContext referenceRMMessage, RMDBean rmdBean, java.lang.String sequenceId, StorageManager storageManager, boolean serverSide)
           
 

Methods in org.apache.sandesha2.util with parameters of type RMMsgContext
protected  void WSRMMessageSender.setupOutMessage(RMMsgContext rmMsgCtx)
          Extracts information from the rmMsgCtx specific for processing out messages
protected  void WSRMMessageSender.sendOutgoingMessage(RMMsgContext rmMsgCtx, int msgType, long delay)
           
static boolean MessageRetransmissionAdjuster.adjustRetransmittion(RMMsgContext rmMsgCtx, SenderBean retransmitterBean, org.apache.axis2.context.ConfigurationContext configContext, StorageManager storageManager)
           
static void FaultManager.checkForLastMsgNumberExceeded(RMMsgContext applicationRMMessage, StorageManager storageManager)
          Check weather the LastMessage number has been exceeded and generate the fault if it is.
static boolean FaultManager.checkForUnknownSequence(RMMsgContext rmMessageContext, java.lang.String sequenceID, StorageManager storageManager, boolean piggybackedMessage)
          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)
static boolean FaultManager.checkForInvalidAcknowledgement(RMMsgContext ackRMMessageContext, SequenceAcknowledgement sequenceAcknowledgement, StorageManager storageManager, RMSBean rmsBean, boolean piggybackedMessage)
          Check weather the Acknowledgement is invalid and generate a fault if it is.
static void FaultManager.makeInvalidAcknowledgementFault(RMMsgContext rmMsgCtx, SequenceAcknowledgement sequenceAcknowledgement, AcknowledgementRange acknowledgementRange, StorageManager storageManager, boolean piggybackedMessage)
          Makes an InvalidAcknowledgement fault.
static void FaultManager.makeCreateSequenceRefusedFault(RMMsgContext rmMessageContext, java.lang.String detail, java.lang.Exception e)
          Makes a Create sequence refused fault
static boolean FaultManager.checkForSequenceTerminated(RMMsgContext referenceRMMessage, java.lang.String sequenceID, RMSequenceBean bean, boolean piggybackedMessage)
          Checks if a sequence is terminated and returns a SequenceTerminated fault.
static boolean FaultManager.checkForSequenceClosed(RMMsgContext referenceRMMessage, java.lang.String sequenceID, RMDBean rmdBean, boolean piggybackedMessage)
           
static void FaultManager.getOrSendFault(RMMsgContext referenceRMMsgContext, FaultData data, boolean throwable)
          Adds the necessary Fault elements as properties to the message context.
static org.apache.axis2.engine.Handler.InvocationResponse FaultManager.processMessagesForFaults(RMMsgContext rmMsgCtx, StorageManager storageManager)
           
static boolean FaultManager.checkForMessageRolledOver(RMMsgContext rmMessageContext, java.lang.String sequenceId, long msgNo)
          Checks to see if the message number received is == to the Long.MAX_VALUE Throws and AxisFault, or sends a Fault message if the condition is met.
static RMMsgContext RMMsgCreator.createCreateSeqMsg(RMSBean rmsBean, RMMsgContext applicationRMMsg)
          Create a new CreateSequence message.
static RMMsgContext RMMsgCreator.createTerminateSequenceMessage(RMMsgContext referenceRMMessage, RMSBean rmsBean, StorageManager storageManager)
          Creates a new TerminateSequence message.
static RMMsgContext RMMsgCreator.createCreateSeqResponseMsg(RMMsgContext createSeqMessage, RMSequenceBean rmSequenceBean)
          Create a new CreateSequenceResponse message.
static RMMsgContext RMMsgCreator.createTerminateSeqResponseMsg(RMMsgContext terminateSeqRMMsg, RMSequenceBean rmSequenceBean)
           
static RMMsgContext RMMsgCreator.createCloseSeqResponseMsg(RMMsgContext closeSeqRMMsg, RMSequenceBean rmSequenceBean)
           
static void RMMsgCreator.addAckMessage(RMMsgContext applicationMsg, java.lang.String sequenceId, RMDBean rmdBean)
          Adds an Ack of specific sequence to the given application message.
static RMMsgContext RMMsgCreator.createMakeConnectionMessage(RMMsgContext referenceRMMessage, RMSequenceBean bean, java.lang.String makeConnectionSeqId, java.lang.String makeConnectionAnonURI, 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 void SandeshaUtil.executeAndStore(RMMsgContext rmMsgContext, java.lang.String storageKey)
           
static void TerminateManager.addTerminateSequenceMessage(RMMsgContext referenceMessage, java.lang.String internalSequenceID, java.lang.String outSequenceId, StorageManager storageManager)
           
static RMDBean SequenceManager.setupNewSequence(RMMsgContext createSequenceMsg, StorageManager storageManager, SecurityManager securityManager, SecurityToken token)
          Set up a new inbound sequence, triggered by the arrival of a create sequence message.
static Transaction AcknowledgementManager.piggybackAcksIfPresent(RMMsgContext rmMessageContext, StorageManager storageManager, Transaction transaction)
          Piggybacks any available acks of the same sequence to the given application message.
static RMMsgContext AcknowledgementManager.generateAckMessage(RMMsgContext referenceRMMessage, RMDBean rmdBean, java.lang.String sequenceId, StorageManager storageManager, boolean serverSide)
           
static void AcknowledgementManager.addAckBeanEntry(RMMsgContext ackRMMsgContext, java.lang.String sequenceId, long timeToSend, StorageManager storageManager)
           
static void AcknowledgementManager.sendAckNow(RMMsgContext ackRMMsgContext)
           
 

Uses of RMMsgContext in org.apache.sandesha2.workers
 

Methods in org.apache.sandesha2.workers with parameters of type RMMsgContext
 void SenderWorker.setMessage(RMMsgContext msg)
           
 



Copyright © 2007 Apache Web Services Project. All Rights Reserved.