org.wso2.mercury.persistence.hibernate
Class HibernatePersistenceManager

java.lang.Object
  extended by org.wso2.mercury.persistence.hibernate.HibernatePersistenceManager
All Implemented Interfaces:
PersistenceManager

public class HibernatePersistenceManager
extends java.lang.Object
implements PersistenceManager

Hibernate implementation of the persistence manager


Constructor Summary
HibernatePersistenceManager()
           
 
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 rmdSequenceDto)
           
 void save(RMDMessageDto rmdMessageDto)
           
 void save(RMDSequenceDto rmdSequenceDto)
           
 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 rmdSequenceDto)
           
 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)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

HibernatePersistenceManager

public HibernatePersistenceManager()
Method Detail

save

public void save(InternalKeyDto internalKeyDto)
          throws PersistenceException
Description copied from interface: PersistenceManager
adds a new internal key to persistence storage underline persistence storage should set the id

Specified by:
save in interface PersistenceManager
Throws:
PersistenceException

getInternalKey

public java.util.List getInternalKey(java.lang.String key,
                                     java.lang.String toAddress)
                              throws PersistenceException
Description copied from interface: PersistenceManager
retrive the internal key object from the underline persintance storage

Specified by:
getInternalKey in interface PersistenceManager
Returns:
internal key object
Throws:
PersistenceException

save

public void save(RMSSequenceDto rmsSequenceDto)
          throws PersistenceException
Description copied from interface: PersistenceManager
adds a new RMSSequenceDto to the persistence storage.

Specified by:
save in interface PersistenceManager
Throws:
PersistenceException

update

public void update(RMSSequenceDto rmsSequenceDto)
            throws PersistenceException
Specified by:
update in interface PersistenceManager
Throws:
PersistenceException

getRMSSquenceWithInternalKey

public java.util.List getRMSSquenceWithInternalKey(long internalKeyID)
                                            throws PersistenceException
Specified by:
getRMSSquenceWithInternalKey in interface PersistenceManager
Throws:
PersistenceException

getRMSSquenceWithID

public RMSSequenceDto getRMSSquenceWithID(long id)
                                   throws PersistenceException
Specified by:
getRMSSquenceWithID in interface PersistenceManager
Throws:
PersistenceException

save

public void save(RMSMessageDto rmsMessageDto,
                 RMSSequenceDto rmsSequenceDto)
          throws PersistenceException
Specified by:
save in interface PersistenceManager
Throws:
PersistenceException

updateMessagesAsSend

public void updateMessagesAsSend(java.util.Set acknowledgedMessageDtos,
                                 RMSSequenceDto rmsSequenceDto)
                          throws PersistenceException
Specified by:
updateMessagesAsSend in interface PersistenceManager
Throws:
PersistenceException

getRMSMessageWithSequenceID

public RMSMessageDto getRMSMessageWithSequenceID(java.lang.String sequenceID)
                                          throws PersistenceException
Specified by:
getRMSMessageWithSequenceID in interface PersistenceManager
Throws:
PersistenceException

getRMSMessagesWithRMSSequenceID

public java.util.List getRMSMessagesWithRMSSequenceID(long rmsSequenceID)
                                               throws PersistenceException
Specified by:
getRMSMessagesWithRMSSequenceID in interface PersistenceManager
Throws:
PersistenceException

update

public void update(RMSMessageDto rmsMessageDto)
            throws PersistenceException
Specified by:
update in interface PersistenceManager
Throws:
PersistenceException

save

public void save(AcknowledgmentDto acknowledgmentsDto)
          throws PersistenceException
Specified by:
save in interface PersistenceManager
Throws:
PersistenceException

save

public void save(RMDSequenceDto rmdSequenceDto)
          throws PersistenceException
Specified by:
save in interface PersistenceManager
Throws:
PersistenceException

save

public void save(InvokerBufferDto invokerBufferDto,
                 RMDSequenceDto rmdSequenceDto)
          throws PersistenceException
Specified by:
save in interface PersistenceManager
Throws:
PersistenceException

save

public void save(RMDMessageDto rmdMessageDto)
          throws PersistenceException
Specified by:
save in interface PersistenceManager
Throws:
PersistenceException

save

public void save(SequenceReceivedNumberDto sequenceReceivedNumberDto)
          throws PersistenceException
Specified by:
save in interface PersistenceManager
Throws:
PersistenceException

save

public void save(BufferReceivedNumberDto bufferReceivedNumberDto)
          throws PersistenceException
Specified by:
save in interface PersistenceManager
Throws:
PersistenceException

updateMessageDetails

public void updateMessageDetails(RMDSequenceDto rmdSequenceDto,
                                 InvokerBufferDto invokerBufferDto,
                                 SequenceReceivedNumberDto sequenceReceivedNumberDto,
                                 BufferReceivedNumberDto bufferReceivedNumberDto,
                                 RMDMessageDto rmdMessageDto)
                          throws PersistenceException
Specified by:
updateMessageDetails in interface PersistenceManager
Throws:
PersistenceException

update

public void update(InvokerBufferDto invokerBufferDto,
                   RMDSequenceDto rmdSequenceDto)
            throws PersistenceException
Specified by:
update in interface PersistenceManager
Throws:
PersistenceException

update

public void update(RMDMessageDto rmdMessageDto,
                   InvokerBufferDto invokerBufferDto)
            throws PersistenceException
Specified by:
update in interface PersistenceManager
Throws:
PersistenceException

getRMDSequeceWithSequenceID

public RMDSequenceDto getRMDSequeceWithSequenceID(java.lang.String sequenceID)
                                           throws PersistenceException
Specified by:
getRMDSequeceWithSequenceID in interface PersistenceManager
Throws:
PersistenceException

getSequenceReceivedNumbersWithRMDSequenceID

public java.util.List getSequenceReceivedNumbersWithRMDSequenceID(long rmdSequenceID)
                                                           throws PersistenceException
Specified by:
getSequenceReceivedNumbersWithRMDSequenceID in interface PersistenceManager
Throws:
PersistenceException

getInvokerBufferWithRMDSequenceID

public InvokerBufferDto getInvokerBufferWithRMDSequenceID(long rmdSequenceID)
                                                   throws PersistenceException
Specified by:
getInvokerBufferWithRMDSequenceID in interface PersistenceManager
Throws:
PersistenceException

getBufferReceivedNumbersWithInvokerBufferID

public java.util.List getBufferReceivedNumbersWithInvokerBufferID(long invokerBufferID)
                                                           throws PersistenceException
Specified by:
getBufferReceivedNumbersWithInvokerBufferID in interface PersistenceManager
Throws:
PersistenceException

getRMDMessagesWithInvokerBufferID

public java.util.List getRMDMessagesWithInvokerBufferID(long invokerBufferID)
                                                 throws PersistenceException
Specified by:
getRMDMessagesWithInvokerBufferID in interface PersistenceManager
Throws:
PersistenceException


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