|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |
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)
|
|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |