|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Packages that use RMMsgContext | |
|---|---|
| org.apache.sandesha2.msgprocessors | |
| org.apache.sandesha2.util | |
| org.apache.sandesha2.workers | |
| 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)
|
void |
AcknowledgementProcessor.processAckHeaders(RMMsgContext message)
|
boolean |
AckRequestedProcessor.processAckRequestedHeader(RMMsgContext rmMsgCtx,
org.apache.axiom.om.OMElement soapHeader,
AckRequested ackRequested)
|
boolean |
AckRequestedProcessor.processAckRequestedHeaders(RMMsgContext message)
|
boolean |
TerminateSeqResponseMsgProcessor.processInMessage(RMMsgContext terminateResRMMsg,
Transaction transaction)
|
boolean |
TerminateSeqMsgProcessor.processInMessage(RMMsgContext terminateSeqRMMsg,
Transaction transaction)
|
boolean |
MsgProcessor.processInMessage(RMMsgContext rmMsgCtx,
Transaction transaction)
|
boolean |
MakeConnectionProcessor.processInMessage(RMMsgContext rmMsgCtx,
Transaction transaction)
Prosesses incoming MakeConnection request messages. |
boolean |
LastMessageProcessor.processInMessage(RMMsgContext rmMsgCtx,
Transaction transaction)
|
boolean |
CreateSeqResponseMsgProcessor.processInMessage(RMMsgContext createSeqResponseRMMsgCtx,
Transaction transaction)
|
boolean |
CreateSeqMsgProcessor.processInMessage(RMMsgContext createSeqRMMsg,
Transaction transaction)
|
boolean |
CloseSequenceProcessor.processInMessage(RMMsgContext rmMsgCtx,
Transaction transaction)
|
boolean |
ApplicationMsgProcessor.processInMessage(RMMsgContext rmMsgCtx,
Transaction transaction)
|
static void |
LastMessageProcessor.processLastMessage(RMMsgContext rmMsgCtx)
|
void |
MessagePendingProcessor.processMessagePendingHeaders(RMMsgContext message)
|
boolean |
AckRequestedProcessor.processOutgoingAckRequestMessage(RMMsgContext ackRequestRMMsg)
This is used to capture AckRequest messages send by the SandeshaClient. |
boolean |
TerminateSeqResponseMsgProcessor.processOutMessage(RMMsgContext rmMsgCtx,
Transaction transaction)
|
boolean |
TerminateSeqMsgProcessor.processOutMessage(RMMsgContext rmMsgCtx,
Transaction transaction)
|
boolean |
MsgProcessor.processOutMessage(RMMsgContext rmMsgCtx,
Transaction transaction)
|
boolean |
MakeConnectionProcessor.processOutMessage(RMMsgContext rmMsgCtx,
Transaction transaction)
|
boolean |
LastMessageProcessor.processOutMessage(RMMsgContext rmMsgCtx,
Transaction transaction)
|
boolean |
CreateSeqResponseMsgProcessor.processOutMessage(RMMsgContext rmMsgCtx,
Transaction transaction)
|
boolean |
CreateSeqMsgProcessor.processOutMessage(RMMsgContext rmMsgCtx,
Transaction transaction)
|
boolean |
CloseSequenceProcessor.processOutMessage(RMMsgContext rmMsgCtx,
Transaction transaction)
|
boolean |
ApplicationMsgProcessor.processOutMessage(RMMsgContext rmMsgCtx,
Transaction tran)
|
org.apache.axis2.engine.Handler.InvocationResponse |
SequenceProcessor.processReliableMessage(RMMsgContext rmMsgCtx,
Transaction transaction)
|
org.apache.axis2.engine.Handler.InvocationResponse |
SequenceProcessor.processSequenceHeader(RMMsgContext rmMsgCtx,
Transaction transaction)
|
static void |
MakeConnectionProcessor.replyToPoll(RMMsgContext pollMessage,
SenderBean matchingMessage,
StorageManager storageManager,
boolean pending,
java.lang.String makeConnectionNamespace,
Transaction transaction)
|
| Uses of RMMsgContext in org.apache.sandesha2.util |
|---|
| Methods in org.apache.sandesha2.util that return RMMsgContext | |
|---|---|
static RMMsgContext |
FaultManager.checkForMessageNumberRoleover(org.apache.axis2.context.MessageContext messageContext)
|
static RMMsgContext |
RMMsgCreator.createCloseSeqResponseMsg(RMMsgContext closeSeqRMMsg,
RMSequenceBean rmSequenceBean)
|
static RMMsgContext |
RMMsgCreator.createCreateSeqMsg(RMSBean rmsBean,
RMMsgContext applicationRMMsg)
Create a new CreateSequence message. |
static RMMsgContext |
RMMsgCreator.createCreateSeqResponseMsg(RMMsgContext createSeqMessage,
RMSequenceBean rmSequenceBean)
Create a new CreateSequenceResponse message. |
static RMMsgContext |
RMMsgCreator.createMakeConnectionMessage(RMMsgContext referenceRMMessage,
RMSequenceBean bean,
java.lang.String makeConnectionSeqId,
java.lang.String makeConnectionAnonURI)
|
static RMMsgContext |
RMMsgCreator.createTerminateSeqResponseMsg(RMMsgContext terminateSeqRMMsg,
RMSequenceBean rmSequenceBean)
|
static RMMsgContext |
RMMsgCreator.createTerminateSequenceMessage(RMMsgContext referenceRMMessage,
RMSBean rmsBean,
StorageManager storageManager)
Creates a new TerminateSequence message. |
static RMMsgContext |
AcknowledgementManager.generateAckMessage(RMMsgContext referenceRMMessage,
RMDBean rmdBean,
java.lang.String sequenceId,
StorageManager storageManager,
boolean serverSide)
|
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 |
AcknowledgementManager.addAckBeanEntry(RMMsgContext ackRMMsgContext,
java.lang.String sequenceId,
long timeToSend,
StorageManager storageManager)
|
static void |
RMMsgCreator.addAckMessage(RMMsgContext applicationMsg,
java.lang.String sequenceId,
RMDBean rmdBean,
boolean addToEnvelope,
boolean isPiggybacked)
Adds an Ack of specific sequence to the given application message. |
static void |
RMMsgCreator.addAckRequest(RMMsgContext applicationMsg,
java.lang.String sequenceId,
RMSBean rmsBean)
Adds an Ack Request for a specific sequence to the given application message. |
static void |
TerminateManager.addTerminateSequenceMessage(RMMsgContext referenceMessage,
java.lang.String internalSequenceID,
java.lang.String outSequenceId,
StorageManager storageManager)
|
static boolean |
MessageRetransmissionAdjuster.adjustRetransmittion(RMMsgContext rmMsgCtx,
SenderBean retransmitterBean,
org.apache.axis2.context.ConfigurationContext configContext,
StorageManager storageManager)
|
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.checkForLastMsgNumberExceeded(RMMsgContext applicationRMMessage,
StorageManager storageManager)
Check weather the LastMessage number has been exceeded and generate the fault if it is. |
static boolean |
FaultManager.checkForMessageRolledOver(RMMsgContext rmMessageContext,
java.lang.String sequenceId,
long msgNo,
RMDBean bean)
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 boolean |
FaultManager.checkForSequenceClosed(RMMsgContext referenceRMMessage,
java.lang.String sequenceID,
RMDBean rmdBean,
boolean piggybackedMessage)
|
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.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 RMMsgContext |
RMMsgCreator.createCloseSeqResponseMsg(RMMsgContext closeSeqRMMsg,
RMSequenceBean rmSequenceBean)
|
static RMMsgContext |
RMMsgCreator.createCreateSeqMsg(RMSBean rmsBean,
RMMsgContext applicationRMMsg)
Create a new CreateSequence message. |
static RMMsgContext |
RMMsgCreator.createCreateSeqResponseMsg(RMMsgContext createSeqMessage,
RMSequenceBean rmSequenceBean)
Create a new CreateSequenceResponse message. |
static RMMsgContext |
RMMsgCreator.createMakeConnectionMessage(RMMsgContext referenceRMMessage,
RMSequenceBean bean,
java.lang.String makeConnectionSeqId,
java.lang.String makeConnectionAnonURI)
|
static org.apache.axis2.context.MessageContext |
SandeshaUtil.createNewRelatedMessageContext(RMMsgContext referenceRMMessage,
org.apache.axis2.description.AxisOperation operation)
|
static RMMsgContext |
RMMsgCreator.createTerminateSeqResponseMsg(RMMsgContext terminateSeqRMMsg,
RMSequenceBean rmSequenceBean)
|
static RMMsgContext |
RMMsgCreator.createTerminateSequenceMessage(RMMsgContext referenceRMMessage,
RMSBean rmsBean,
StorageManager storageManager)
Creates a new TerminateSequence message. |
static void |
SandeshaUtil.executeAndStore(RMMsgContext rmMsgContext,
java.lang.String storageKey,
StorageManager manager)
|
static RMMsgContext |
AcknowledgementManager.generateAckMessage(RMMsgContext referenceRMMessage,
RMDBean rmdBean,
java.lang.String sequenceId,
StorageManager storageManager,
boolean serverSide)
|
static void |
FaultManager.getOrSendFault(RMMsgContext referenceRMMsgContext,
FaultData data,
boolean throwable,
org.apache.axis2.addressing.EndpointReference acksToEPR)
Adds the necessary Fault elements as properties to the message context. |
static java.lang.String |
SandeshaUtil.getSequenceIDFromRMMessage(RMMsgContext rmMessageContext)
|
static void |
FaultManager.makeCreateSequenceRefusedFault(RMMsgContext rmMessageContext,
java.lang.String detail,
java.lang.Exception e,
org.apache.axis2.addressing.EndpointReference acksToEPR)
Makes a Create sequence refused fault |
static void |
FaultManager.makeInvalidAcknowledgementFault(RMMsgContext rmMsgCtx,
SequenceAcknowledgement sequenceAcknowledgement,
Range acknowledgementRange,
StorageManager storageManager,
boolean piggybackedMessage,
org.apache.axis2.addressing.EndpointReference acksToEPR)
Makes an InvalidAcknowledgement fault. |
static void |
FaultManager.makeMissingSelectionFault(RMMsgContext rmMessageContext)
Makes WSMC MissingSelectionFault |
static void |
FaultManager.makeUnsupportedSelectionFault(RMMsgContext rmMessageContext,
javax.xml.namespace.QName unsupportedElement)
Makes the WSMC UnsupportedSelectionFault |
static void |
AcknowledgementManager.piggybackAcksIfPresent(RMMsgContext rmMessageContext,
StorageManager storageManager)
Piggybacks any available acks of the same sequence to the given application message. |
static org.apache.axis2.engine.Handler.InvocationResponse |
FaultManager.processMessagesForFaults(RMMsgContext rmMsgCtx,
StorageManager storageManager)
|
static void |
AcknowledgementManager.sendAckNow(RMMsgContext ackRMMsgContext)
|
protected void |
WSRMMessageSender.sendOutgoingMessage(RMMsgContext rmMsgCtx,
int msgType,
long delay,
Transaction transaction)
|
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. |
protected void |
WSRMMessageSender.setupOutMessage(RMMsgContext rmMsgCtx)
Extracts information from the rmMsgCtx specific for processing out messages |
| Uses of RMMsgContext in org.apache.sandesha2.workers |
|---|
| Methods in org.apache.sandesha2.workers with parameters of type RMMsgContext | |
|---|---|
void |
Sender.scheduleAddressableAcknowledgement(java.lang.String sequenceId,
long ackInterval,
RMMsgContext ref)
|
void |
SenderWorker.setMessage(RMMsgContext msg)
|
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||