|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of RMMessageContext in org.apache.sandesha |
Methods in org.apache.sandesha that return RMMessageContext | |
RMMessageContext |
IStorageManager.getNextMessageToProcess(java.lang.Object seq)
|
RMMessageContext |
IStorageManager.getNextMessageToSend()
|
RMMessageContext |
IStorageManager.checkForResponseMessage(java.lang.String sequenceId,
java.lang.String requestMsgId)
|
Methods in org.apache.sandesha with parameters of type RMMessageContext | |
void |
RMMessageContext.copyContents(RMMessageContext rmMsgContext)
|
void |
IStorageManager.addCreateSequenceResponse(RMMessageContext rmMessageContext)
|
void |
IStorageManager.addCreateSequenceRequest(RMMessageContext rmMessageContext)
|
void |
IStorageManager.addAcknowledgement(RMMessageContext rmMessageContext)
|
void |
IStorageManager.insertOutgoingMessage(RMMessageContext rmMessageContext)
|
void |
IStorageManager.insertIncomingMessage(RMMessageContext rmMessageContext)
|
void |
IStorageManager.insertTerminateSeqMessage(RMMessageContext terminateSeqMessage)
|
void |
IStorageManager.insertFault(RMMessageContext rmMsgCtx)
|
java.lang.String |
IStorageManager.getOutgoingSeqenceIdOfIncomingMsg(RMMessageContext msg)
|
static SOAPEnvelope |
EnvelopeCreator.createCreateSequenceResponseEnvelope(java.lang.String seqId,
RMMessageContext rmMessageContext,
boolean hasOffer,
boolean offerAccepted)
|
static SOAPEnvelope |
EnvelopeCreator.createCreateSequenceEnvelope(RMMessageContext rmMsgCtx)
|
static SOAPEnvelope |
EnvelopeCreator.createAcknowledgementEnvelope(RMMessageContext rmMessageContext,
java.lang.String toAddress,
java.util.List ackRangeList)
|
static SOAPEnvelope |
EnvelopeCreator.createServiceResponseEnvelope(RMMessageContext rmMessageContext)
|
static SOAPEnvelope |
EnvelopeCreator.createServiceRequestEnvelope(RMMessageContext rmMessageContext)
|
static SOAPEnvelope |
EnvelopeCreator.createTerminatSeqMessage(RMMessageContext rmMessageContext)
|
Uses of RMMessageContext in org.apache.sandesha.client |
Methods in org.apache.sandesha.client that return RMMessageContext | |
RMMessageContext |
ClientStorageManager.getNextMessageToProcess(java.lang.Object seq)
|
RMMessageContext |
ClientStorageManager.getNextMessageToSend()
This will be used by the sender. |
RMMessageContext |
ClientStorageManager.checkForResponseMessage(java.lang.String sequenceId,
java.lang.String requestMsgId)
|
static RMMessageContext |
ClientPropertyValidator.validate(Call call)
|
Methods in org.apache.sandesha.client with parameters of type RMMessageContext | |
void |
ClientStorageManager.addCreateSequenceResponse(RMMessageContext rmMessageContext)
This will be used both by the Sender and the SimpleAxisServer to set the create sequence responses. |
void |
ClientStorageManager.addCreateSequenceRequest(RMMessageContext rmMessageContext)
This will be used by the RMSender to add the create sequence request. |
void |
ClientStorageManager.addAcknowledgement(RMMessageContext rmMessageContext)
SimpleAxisServer will use this method to add acks for the application responses received from the server side. |
void |
ClientStorageManager.insertOutgoingMessage(RMMessageContext msg)
|
void |
ClientStorageManager.insertIncomingMessage(RMMessageContext rmMessageContext)
|
void |
ClientStorageManager.insertTerminateSeqMessage(RMMessageContext terminateSeqMessage)
|
void |
ClientStorageManager.insertFault(RMMessageContext rmMsgCtx)
|
java.lang.String |
ClientStorageManager.getOutgoingSeqenceIdOfIncomingMsg(RMMessageContext msg)
|
Uses of RMMessageContext in org.apache.sandesha.server |
Methods in org.apache.sandesha.server that return RMMessageContext | |
RMMessageContext |
ServerStorageManager.getNextMessageToProcess(java.lang.Object seq)
A very important method. |
RMMessageContext |
ServerStorageManager.getNextMessageToSend()
This is used to get a random message from the out queue Basically server sender will use this. |
RMMessageContext |
ServerStorageManager.checkForResponseMessage(java.lang.String sequenceId,
java.lang.String requestMsgId)
|
Methods in org.apache.sandesha.server with parameters of type RMMessageContext | |
void |
ServerStorageManager.addCreateSequenceResponse(RMMessageContext rmMessageContext)
|
void |
ServerStorageManager.addCreateSequenceRequest(RMMessageContext rmMessageContext)
|
void |
ServerStorageManager.addAcknowledgement(RMMessageContext rmMessageContext)
|
void |
ServerStorageManager.insertOutgoingMessage(RMMessageContext msg)
|
void |
ServerStorageManager.insertIncomingMessage(RMMessageContext rmMessageContext)
|
void |
ServerStorageManager.insertTerminateSeqMessage(RMMessageContext terminateSeqMessage)
|
void |
ServerStorageManager.insertFault(RMMessageContext rmMsgCtx)
|
java.lang.String |
ServerStorageManager.getOutgoingSeqenceIdOfIncomingMsg(RMMessageContext msg)
|
static IRMMessageProcessor |
RMMessageProcessorIdentifier.getMessageProcessor(RMMessageContext rmMessageContext,
IStorageManager storageManager)
This method will identify the messages. |
protected void |
RMInvokerWork.doWork(RMMessageContext rmMessageContext)
|
static void |
MessageValidator.validate(RMMessageContext rmMsgContext,
boolean client)
|
Uses of RMMessageContext in org.apache.sandesha.server.msgprocessors |
Methods in org.apache.sandesha.server.msgprocessors with parameters of type RMMessageContext | |
boolean |
TerminateSequenceProcessor.processMessage(RMMessageContext rmMessageContext)
|
boolean |
IRMMessageProcessor.processMessage(RMMessageContext rmMessageContext)
|
boolean |
FaultProcessor.processMessage(RMMessageContext rmMessageContext)
|
boolean |
FaultProcessor.sendFault(RMMessageContext rmMessageContext)
|
boolean |
CreateSequenceResponseProcessor.processMessage(RMMessageContext rmMessageContext)
|
boolean |
CreateSequenceProcessor.processMessage(RMMessageContext rmMessageContext)
|
boolean |
CompositeProcessor.processMessage(RMMessageContext rmMessageContext)
|
boolean |
AcknowledgementProcessor.processMessage(RMMessageContext rmMessageContext)
|
boolean |
AcknowledgementProcessor.sendAcknowledgement(RMMessageContext rmMessageContext)
|
Uses of RMMessageContext in org.apache.sandesha.storage.dao |
Methods in org.apache.sandesha.storage.dao that return RMMessageContext | |
RMMessageContext |
SandeshaQueueDAO.getNextPriorityMessageContextToSend()
|
RMMessageContext |
SandeshaQueueDAO.getNextMsgContextToProcess(java.lang.Object sequence)
|
RMMessageContext |
SandeshaQueueDAO.getNextOutgoingMsgContextToSend()
|
RMMessageContext |
SandeshaQueueDAO.checkForResponseMessage(java.lang.String requestId,
java.lang.String seqId)
|
RMMessageContext |
SandeshaQueueDAO.getNextLowPriorityMessageContextToSend()
|
RMMessageContext |
SandeshaDatabaseDAO.getNextPriorityMessageContextToSend()
|
RMMessageContext |
SandeshaDatabaseDAO.getNextMsgContextToProcess(java.lang.Object seq)
|
RMMessageContext |
SandeshaDatabaseDAO.getNextOutgoingMsgContextToSend()
|
RMMessageContext |
SandeshaDatabaseDAO.checkForResponseMessage(java.lang.String requestId,
java.lang.String seqId)
|
RMMessageContext |
SandeshaDatabaseDAO.getNextLowPriorityMessageContextToSend()
|
RMMessageContext |
ISandeshaDAO.getNextPriorityMessageContextToSend()
This checks the priority messages to see weather there is any one to be sent (either for the first time or a retransmission) |
RMMessageContext |
ISandeshaDAO.getNextMsgContextToProcess(java.lang.Object seq)
This tries to get the next message to be sent from the given outgoing sequence If these is no message to be sent in the given sequence, null will be returned. |
RMMessageContext |
ISandeshaDAO.getNextOutgoingMsgContextToSend()
Gets the next possible message to be sent from the queue. |
RMMessageContext |
ISandeshaDAO.checkForResponseMessage(java.lang.String requestId,
java.lang.String seqId)
When the messageId of therequest message (e.g. |
RMMessageContext |
ISandeshaDAO.getNextLowPriorityMessageContextToSend()
Asks the storage for the next low priority message (if there is any) |
Methods in org.apache.sandesha.storage.dao with parameters of type RMMessageContext | |
boolean |
SandeshaQueueDAO.addPriorityMessage(RMMessageContext msg)
|
boolean |
SandeshaQueueDAO.addMessageToIncomingSequence(java.lang.String sequenceId,
java.lang.Long msgNo,
RMMessageContext rmMessageContext)
|
boolean |
SandeshaQueueDAO.addMessageToOutgoingSequence(java.lang.String sequenceId,
RMMessageContext rmMessageContext)
|
void |
SandeshaQueueDAO.addLowPriorityMessage(RMMessageContext msg)
|
boolean |
SandeshaDatabaseDAO.addPriorityMessage(RMMessageContext message)
|
boolean |
SandeshaDatabaseDAO.addMessageToIncomingSequence(java.lang.String sequenceId,
java.lang.Long msgNo,
RMMessageContext rmMessageContext)
|
boolean |
SandeshaDatabaseDAO.addMessageToOutgoingSequence(java.lang.String sequenceId,
RMMessageContext rmMessageContext)
|
void |
SandeshaDatabaseDAO.addLowPriorityMessage(RMMessageContext msg)
|
boolean |
ISandeshaDAO.addPriorityMessage(RMMessageContext message)
Adds a priority message (e.g. |
boolean |
ISandeshaDAO.addMessageToIncomingSequence(java.lang.String sequenceId,
java.lang.Long msgNo,
RMMessageContext rmMessageContext)
This adds a incoming message to a area belonging to the given sequence in the queue. |
boolean |
ISandeshaDAO.addMessageToOutgoingSequence(java.lang.String sequenceId,
RMMessageContext rmMessageContext)
This adds the given message to the given sequence. |
void |
ISandeshaDAO.addLowPriorityMessage(RMMessageContext msg)
Adds a low priority message to the storage (e.g. |
Uses of RMMessageContext in org.apache.sandesha.storage.queue |
Methods in org.apache.sandesha.storage.queue that return RMMessageContext | |
RMMessageContext |
SandeshaQueue.nextIncomingMessageToProcess(java.lang.Object sequence)
|
RMMessageContext |
SandeshaQueue.nextOutgoingMessageToSend()
|
RMMessageContext |
SandeshaQueue.nextPriorityMessageToSend()
|
RMMessageContext |
SandeshaQueue.checkForResponseMessage(java.lang.String requestId,
java.lang.String seqId)
|
RMMessageContext |
SandeshaQueue.getLowPriorityMessageIfAcked()
|
RMMessageContext |
OutgoingSequence.getNextMessageToSend()
Returns the next deliverable message if has any. |
RMMessageContext |
OutgoingSequence.deleteMessage(java.lang.Long msgId)
|
RMMessageContext |
IncomingSequence.getNextMessageToProcess()
|
RMMessageContext |
IncomingSequence.getMessageRelatingTo(java.lang.String relatesTo)
|
Methods in org.apache.sandesha.storage.queue with parameters of type RMMessageContext | |
boolean |
SandeshaQueue.addMessageToIncomingSequence(java.lang.String seqId,
java.lang.Long messageNo,
RMMessageContext msgCon)
|
boolean |
SandeshaQueue.addMessageToOutgoingSequence(java.lang.String seqId,
RMMessageContext msgCon)
|
void |
SandeshaQueue.addPriorityMessage(RMMessageContext msg)
Adds a new message to the responses queue. |
void |
SandeshaQueue.addLowPriorityMessage(RMMessageContext msg)
|
java.lang.Object |
OutgoingSequence.putNewMessage(RMMessageContext msg)
adds the message to map. |
java.lang.Object |
IncomingSequence.putNewMessage(java.lang.Long key,
RMMessageContext value)
adds the message to map. |
Uses of RMMessageContext in org.apache.sandesha.util |
Methods in org.apache.sandesha.util that return RMMessageContext | |
static RMMessageContext |
RMMessageCreator.createCreateSeqMsg(RMMessageContext rmMsgCtx,
byte endPoint,
java.lang.String msgID,
java.lang.String offer)
|
static RMMessageContext |
RMMessageCreator.createCreateSeqResponseMsg(RMMessageContext rmMsgCtx)
|
static RMMessageContext |
RMMessageCreator.createTerminateSeqMsg(RMMessageContext rmMsgCtx,
byte endPoint)
|
static RMMessageContext |
RMMessageCreator.createAcknowledgementMsg(RMMessageContext rmMessageContext)
|
static RMMessageContext |
RMMessageCreator.createServiceResponseMessage(RMMessageContext rmMsgCtx)
|
static RMMessageContext |
RMMessageCreator.createServiceRequestMessage(RMMessageContext rmMsgCtx)
|
Methods in org.apache.sandesha.util with parameters of type RMMessageContext | |
static RMMessageContext |
RMMessageCreator.createCreateSeqMsg(RMMessageContext rmMsgCtx,
byte endPoint,
java.lang.String msgID,
java.lang.String offer)
|
static RMMessageContext |
RMMessageCreator.createCreateSeqResponseMsg(RMMessageContext rmMsgCtx)
|
static RMMessageContext |
RMMessageCreator.createTerminateSeqMsg(RMMessageContext rmMsgCtx,
byte endPoint)
|
static RMMessageContext |
RMMessageCreator.createAcknowledgementMsg(RMMessageContext rmMessageContext)
|
static RMMessageContext |
RMMessageCreator.createServiceResponseMessage(RMMessageContext rmMsgCtx)
|
static RMMessageContext |
RMMessageCreator.createServiceRequestMessage(RMMessageContext rmMsgCtx)
|
|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |