Methods in org.wso2.mercury.persistence that throw PersistenceException |
java.util.List |
PersistenceManager.getBufferReceivedNumbersWithInvokerBufferID(long invokerBufferID)
|
java.util.List |
PersistenceManager.getInternalKey(java.lang.String key,
java.lang.String toAddress)
retrive the internal key object from the underline persintance storage |
InvokerBufferDto |
PersistenceManager.getInvokerBufferWithRMDSequenceID(long rmdSequenceID)
|
java.util.List |
PersistenceManager.getRMDMessagesWithInvokerBufferID(long invokerBufferID)
|
RMDSequenceDto |
PersistenceManager.getRMDSequeceWithSequenceID(java.lang.String sequenceID)
|
java.util.List |
PersistenceManager.getRMSMessagesWithRMSSequenceID(long rmsSequenceID)
|
RMSMessageDto |
PersistenceManager.getRMSMessageWithSequenceID(java.lang.String sequenceID)
|
RMSSequenceDto |
PersistenceManager.getRMSSquenceWithID(long id)
|
java.util.List |
PersistenceManager.getRMSSquenceWithInternalKey(long internalKeyID)
|
java.util.List |
PersistenceManager.getSequenceReceivedNumbersWithRMDSequenceID(long rmdSequenceID)
|
void |
PersistenceManager.save(AcknowledgmentDto acknowledgmentsDto)
|
void |
PersistenceManager.save(BufferReceivedNumberDto bufferReceivedNumberDto)
|
void |
PersistenceManager.save(InternalKeyDto internalKeyDto)
adds a new internal key to persistence storage
underline persistence storage should set the id |
void |
PersistenceManager.save(InvokerBufferDto invokerBufferDto,
RMDSequenceDto rmsRmdSequenceDto)
|
void |
PersistenceManager.save(RMDMessageDto rmdMessageDto)
|
void |
PersistenceManager.save(RMDSequenceDto rmdRmdSequenceDto)
|
void |
PersistenceManager.save(RMSMessageDto rmsMessageDto,
RMSSequenceDto rmsSequenceDto)
|
void |
PersistenceManager.save(RMSSequenceDto rmsSequenceDto)
adds a new RMSSequenceDto to the persistence storage. |
void |
PersistenceManager.save(SequenceReceivedNumberDto sequenceReceivedNumberDto)
|
void |
PersistenceManager.update(InvokerBufferDto invokerBufferDto,
RMDSequenceDto rmsRmdSequenceDto)
|
void |
PersistenceManager.update(RMDMessageDto rmdMessageDto,
InvokerBufferDto invokerBufferDto)
|
void |
PersistenceManager.update(RMSMessageDto rmsMessageDto)
|
void |
PersistenceManager.update(RMSSequenceDto rmsSequenceDto)
|
void |
PersistenceManager.updateMessageDetails(RMDSequenceDto rmdSequenceDto,
InvokerBufferDto invokerBufferDto,
SequenceReceivedNumberDto sequenceReceivedNumberDto,
BufferReceivedNumberDto bufferReceivedNumberDto,
RMDMessageDto rmdMessageDto)
|
void |
PersistenceManager.updateMessagesAsSend(java.util.Set acknowledgedMessageDtos,
RMSSequenceDto rmsSequenceDto)
|
Methods in org.wso2.mercury.persistence.hibernate that throw PersistenceException |
java.util.List |
HibernatePersistenceManager.getBufferReceivedNumbersWithInvokerBufferID(long invokerBufferID)
|
java.util.List |
HibernatePersistenceManager.getInternalKey(java.lang.String key,
java.lang.String toAddress)
|
InvokerBufferDto |
HibernatePersistenceManager.getInvokerBufferWithRMDSequenceID(long rmdSequenceID)
|
java.util.List |
HibernatePersistenceManager.getRMDMessagesWithInvokerBufferID(long invokerBufferID)
|
RMDSequenceDto |
HibernatePersistenceManager.getRMDSequeceWithSequenceID(java.lang.String sequenceID)
|
java.util.List |
HibernatePersistenceManager.getRMSMessagesWithRMSSequenceID(long rmsSequenceID)
|
RMSMessageDto |
HibernatePersistenceManager.getRMSMessageWithSequenceID(java.lang.String sequenceID)
|
RMSSequenceDto |
HibernatePersistenceManager.getRMSSquenceWithID(long id)
|
java.util.List |
HibernatePersistenceManager.getRMSSquenceWithInternalKey(long internalKeyID)
|
java.util.List |
HibernatePersistenceManager.getSequenceReceivedNumbersWithRMDSequenceID(long rmdSequenceID)
|
void |
HibernatePersistenceManager.save(AcknowledgmentDto acknowledgmentsDto)
|
void |
HibernatePersistenceManager.save(BufferReceivedNumberDto bufferReceivedNumberDto)
|
void |
HibernatePersistenceManager.save(InternalKeyDto internalKeyDto)
|
void |
HibernatePersistenceManager.save(InvokerBufferDto invokerBufferDto,
RMDSequenceDto rmdSequenceDto)
|
void |
HibernatePersistenceManager.save(RMDMessageDto rmdMessageDto)
|
void |
HibernatePersistenceManager.save(RMDSequenceDto rmdSequenceDto)
|
void |
HibernatePersistenceManager.save(RMSMessageDto rmsMessageDto,
RMSSequenceDto rmsSequenceDto)
|
void |
HibernatePersistenceManager.save(RMSSequenceDto rmsSequenceDto)
|
void |
HibernatePersistenceManager.save(SequenceReceivedNumberDto sequenceReceivedNumberDto)
|
void |
HibernatePersistenceManager.update(InvokerBufferDto invokerBufferDto,
RMDSequenceDto rmdSequenceDto)
|
void |
HibernatePersistenceManager.update(RMDMessageDto rmdMessageDto,
InvokerBufferDto invokerBufferDto)
|
void |
HibernatePersistenceManager.update(RMSMessageDto rmsMessageDto)
|
void |
HibernatePersistenceManager.update(RMSSequenceDto rmsSequenceDto)
|
void |
HibernatePersistenceManager.updateMessageDetails(RMDSequenceDto rmdSequenceDto,
InvokerBufferDto invokerBufferDto,
SequenceReceivedNumberDto sequenceReceivedNumberDto,
BufferReceivedNumberDto bufferReceivedNumberDto,
RMDMessageDto rmdMessageDto)
|
void |
HibernatePersistenceManager.updateMessagesAsSend(java.util.Set acknowledgedMessageDtos,
RMSSequenceDto rmsSequenceDto)
|
Methods in org.wso2.mercury.state that throw PersistenceException |
void |
RMSSequence.addRMMessageContext(RMApplicationMessage message,
org.apache.axis2.context.MessageContext messageContext)
|
void |
InvokerBuffer.applicatinMessageReceived(long messageNumber,
MercuryMessageContext mercuryMessageContext,
RMDSequenceDto rmdSequenceDto)
|
boolean |
RMDSequence.applicationMessageReceived(long messageNumber,
MercuryMessageContext mercuryMessageContext)
this message should not be a last message |
void |
RMSSequence.applicationMessageReceivedFromClient(RMApplicationMessage message,
org.apache.axis2.context.MessageContext messageContext)
|
void |
RMSSequence.createSequenceResponseReceived()
create sequence message received event has occured do the necessary state changes accordingly. |
boolean |
RMDSequence.lastMessageReceived(long messageNumber,
MercuryMessageContext mercuryMessageContext)
|
void |
InvokerBuffer.lastMessageReceived(long messageNumber,
MercuryMessageContext mercuryMessageContext,
RMDSequenceDto rmdSequenceDto)
|
void |
RMSSequence.lastMessageReceivedFromClient(RMApplicationMessage message,
org.apache.axis2.context.MessageContext messageContext)
|
void |
InvokerBuffer.loadInvokerBufferDetails(org.apache.axis2.context.MessageContext messageContext)
|
void |
RMDSequence.loadRMDSequenceDetails(org.apache.axis2.context.MessageContext messageContext)
|
void |
RMDContext.loadRMDSequenceFromPersistanceStorage(java.lang.String sequenceID,
org.apache.axis2.context.MessageContext messageContext)
|
void |
RMSSequence.populatePersistnaceData(org.apache.axis2.context.MessageContext messageContext,
RMSSequenceDto rmsSequenceDto)
|
void |
RMSContext.resumeSequence(InternalSequenceKey key,
org.apache.axis2.context.MessageContext msgContext)
|
void |
RMDSequence.save()
|
void |
RMSSequence.save(long internalKeyID)
|
void |
InvokerBuffer.save(RMDSequenceDto rmdSequenceDto)
saves both RMD Sequence and Invoker buffer objects at once. |
void |
RMSSequence.sequenceAcknowledgmentReceived(java.util.List acknowledgmentRanges)
|
void |
InvokerBuffer.terminateMessageReceived(RMDSequenceDto rmdSequenceDto)
|
void |
RMSSequence.terminateMessageReceivedFromClient()
|
void |
RMDSequence.terminateSequenceMessageReceived()
|