org.wso2.mercury.persistence
Interface PersistenceManager

All Known Implementing Classes:
HibernatePersistenceManager

public interface PersistenceManager

this is the persistence manager that any persistence storage has to implement


Method Summary
 java.util.List getBufferReceivedNumbersWithInvokerBufferID(long invokerBufferID)
           
 java.util.List getInternalKey(java.lang.String key, java.lang.String toAddress)
          retrive the internal key object from the underline persintance storage
 InvokerBufferDto getInvokerBufferWithRMDSequenceID(long rmdSequenceID)
           
 java.util.List getRMDMessagesWithInvokerBufferID(long invokerBufferID)
           
 RMDSequenceDto getRMDSequeceWithSequenceID(java.lang.String sequenceID)
           
 java.util.List getRMSMessagesWithRMSSequenceID(long rmsSequenceID)
           
 RMSMessageDto getRMSMessageWithSequenceID(java.lang.String sequenceID)
           
 RMSSequenceDto getRMSSquenceWithID(long id)
           
 java.util.List getRMSSquenceWithInternalKey(long internalKeyID)
           
 java.util.List getSequenceReceivedNumbersWithRMDSequenceID(long rmdSequenceID)
           
 void save(AcknowledgmentDto acknowledgmentsDto)
           
 void save(BufferReceivedNumberDto bufferReceivedNumberDto)
           
 void save(InternalKeyDto internalKeyDto)
          adds a new internal key to persistence storage underline persistence storage should set the id
 void save(InvokerBufferDto invokerBufferDto, RMDSequenceDto rmsRmdSequenceDto)
           
 void save(RMDMessageDto rmdMessageDto)
           
 void save(RMDSequenceDto rmdRmdSequenceDto)
           
 void save(RMSMessageDto rmsMessageDto, RMSSequenceDto rmsSequenceDto)
           
 void save(RMSSequenceDto rmsSequenceDto)
          adds a new RMSSequenceDto to the persistence storage.
 void save(SequenceReceivedNumberDto sequenceReceivedNumberDto)
           
 void update(InvokerBufferDto invokerBufferDto, RMDSequenceDto rmsRmdSequenceDto)
           
 void update(RMDMessageDto rmdMessageDto, InvokerBufferDto invokerBufferDto)
           
 void update(RMSMessageDto rmsMessageDto)
           
 void update(RMSSequenceDto rmsSequenceDto)
           
 void updateMessageDetails(RMDSequenceDto rmdSequenceDto, InvokerBufferDto invokerBufferDto, SequenceReceivedNumberDto sequenceReceivedNumberDto, BufferReceivedNumberDto bufferReceivedNumberDto, RMDMessageDto rmdMessageDto)
           
 void updateMessagesAsSend(java.util.Set acknowledgedMessageDtos, RMSSequenceDto rmsSequenceDto)
           
 

Method Detail

save

void save(InternalKeyDto internalKeyDto)
          throws PersistenceException
adds a new internal key to persistence storage underline persistence storage should set the id

Parameters:
internalKeyDto -
Throws:
PersistenceException

getInternalKey

java.util.List getInternalKey(java.lang.String key,
                              java.lang.String toAddress)
                              throws PersistenceException
retrive the internal key object from the underline persintance storage

Parameters:
key -
toAddress -
Returns:
internal key object
Throws:
PersistenceException

save

void save(RMSSequenceDto rmsSequenceDto)
          throws PersistenceException
adds a new RMSSequenceDto to the persistence storage.

Parameters:
rmsSequenceDto -
Throws:
PersistenceException

update

void update(RMSSequenceDto rmsSequenceDto)
            throws PersistenceException
Throws:
PersistenceException

getRMSSquenceWithInternalKey

java.util.List getRMSSquenceWithInternalKey(long internalKeyID)
                                            throws PersistenceException
Throws:
PersistenceException

getRMSSquenceWithID

RMSSequenceDto getRMSSquenceWithID(long id)
                                   throws PersistenceException
Throws:
PersistenceException

save

void save(RMSMessageDto rmsMessageDto,
          RMSSequenceDto rmsSequenceDto)
          throws PersistenceException
Throws:
PersistenceException

getRMSMessageWithSequenceID

RMSMessageDto getRMSMessageWithSequenceID(java.lang.String sequenceID)
                                          throws PersistenceException
Throws:
PersistenceException

getRMSMessagesWithRMSSequenceID

java.util.List getRMSMessagesWithRMSSequenceID(long rmsSequenceID)
                                               throws PersistenceException
Throws:
PersistenceException

update

void update(RMSMessageDto rmsMessageDto)
            throws PersistenceException
Throws:
PersistenceException

save

void save(AcknowledgmentDto acknowledgmentsDto)
          throws PersistenceException
Throws:
PersistenceException

updateMessagesAsSend

void updateMessagesAsSend(java.util.Set acknowledgedMessageDtos,
                          RMSSequenceDto rmsSequenceDto)
                          throws PersistenceException
Throws:
PersistenceException

save

void save(RMDSequenceDto rmdRmdSequenceDto)
          throws PersistenceException
Throws:
PersistenceException

save

void save(InvokerBufferDto invokerBufferDto,
          RMDSequenceDto rmsRmdSequenceDto)
          throws PersistenceException
Throws:
PersistenceException

save

void save(RMDMessageDto rmdMessageDto)
          throws PersistenceException
Throws:
PersistenceException

save

void save(SequenceReceivedNumberDto sequenceReceivedNumberDto)
          throws PersistenceException
Throws:
PersistenceException

save

void save(BufferReceivedNumberDto bufferReceivedNumberDto)
          throws PersistenceException
Throws:
PersistenceException

updateMessageDetails

void updateMessageDetails(RMDSequenceDto rmdSequenceDto,
                          InvokerBufferDto invokerBufferDto,
                          SequenceReceivedNumberDto sequenceReceivedNumberDto,
                          BufferReceivedNumberDto bufferReceivedNumberDto,
                          RMDMessageDto rmdMessageDto)
                          throws PersistenceException
Throws:
PersistenceException

update

void update(InvokerBufferDto invokerBufferDto,
            RMDSequenceDto rmsRmdSequenceDto)
            throws PersistenceException
Throws:
PersistenceException

update

void update(RMDMessageDto rmdMessageDto,
            InvokerBufferDto invokerBufferDto)
            throws PersistenceException
Throws:
PersistenceException

getRMDSequeceWithSequenceID

RMDSequenceDto getRMDSequeceWithSequenceID(java.lang.String sequenceID)
                                           throws PersistenceException
Throws:
PersistenceException

getSequenceReceivedNumbersWithRMDSequenceID

java.util.List getSequenceReceivedNumbersWithRMDSequenceID(long rmdSequenceID)
                                                           throws PersistenceException
Throws:
PersistenceException

getInvokerBufferWithRMDSequenceID

InvokerBufferDto getInvokerBufferWithRMDSequenceID(long rmdSequenceID)
                                                   throws PersistenceException
Throws:
PersistenceException

getBufferReceivedNumbersWithInvokerBufferID

java.util.List getBufferReceivedNumbersWithInvokerBufferID(long invokerBufferID)
                                                           throws PersistenceException
Throws:
PersistenceException

getRMDMessagesWithInvokerBufferID

java.util.List getRMDMessagesWithInvokerBufferID(long invokerBufferID)
                                                 throws PersistenceException
Throws:
PersistenceException


~~~~~~~~~~~~~~~~~~~ Mercury ~~~~~~~~~~~~~~~~~~~~~