org.apache.sandesha2.storage.jdbc
Class PersistentSenderBeanMgr

java.lang.Object
  extended by org.apache.sandesha2.storage.jdbc.PersistentBeanMgr
      extended by org.apache.sandesha2.storage.jdbc.PersistentSenderBeanMgr
All Implemented Interfaces:
RMBeanManager, SenderBeanMgr

public class PersistentSenderBeanMgr
extends PersistentBeanMgr
implements SenderBeanMgr

Manages Sender Beans


Constructor Summary
PersistentSenderBeanMgr(PersistentStorageManager pmgr)
           
 
Method Summary
 boolean delete(java.lang.String messageID)
           
 java.util.List<SenderBean> find(SenderBean bean)
           
 java.util.List<SenderBean> find(java.lang.String internalSequenceId)
           
 SenderBean findUnique(SenderBean bean)
           
 SenderBean getNextMsgToSend(java.lang.String sequenceId)
           
 boolean insert(SenderBean bean)
           
 SenderBean retrieve(java.lang.String messageID)
           
 SenderBean retrieve(java.lang.String sequnceId, long messageNumber)
           
 SenderBean retrieveFromMessageRefKey(java.lang.String messageContextRefKey)
           
 boolean update(SenderBean bean)
           
 
Methods inherited from class org.apache.sandesha2.storage.jdbc.PersistentBeanMgr
getDbConnection, getObject, serialize
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

PersistentSenderBeanMgr

public PersistentSenderBeanMgr(PersistentStorageManager pmgr)
Method Detail

delete

public boolean delete(java.lang.String messageID)
               throws SandeshaStorageException
Specified by:
delete in interface SenderBeanMgr
Throws:
SandeshaStorageException

find

public java.util.List<SenderBean> find(SenderBean bean)
                                throws SandeshaStorageException
Specified by:
find in interface SenderBeanMgr
Throws:
SandeshaStorageException

find

public java.util.List<SenderBean> find(java.lang.String internalSequenceId)
                                throws SandeshaStorageException
Specified by:
find in interface SenderBeanMgr
Throws:
SandeshaStorageException

getNextMsgToSend

public SenderBean getNextMsgToSend(java.lang.String sequenceId)
                            throws SandeshaStorageException
Specified by:
getNextMsgToSend in interface SenderBeanMgr
Throws:
SandeshaStorageException

insert

public boolean insert(SenderBean bean)
               throws SandeshaStorageException
Specified by:
insert in interface SenderBeanMgr
Throws:
SandeshaStorageException

retrieve

public SenderBean retrieve(java.lang.String messageID)
                    throws SandeshaStorageException
Specified by:
retrieve in interface SenderBeanMgr
Throws:
SandeshaStorageException

update

public boolean update(SenderBean bean)
               throws SandeshaStorageException
Specified by:
update in interface SenderBeanMgr
Throws:
SandeshaStorageException

findUnique

public SenderBean findUnique(SenderBean bean)
                      throws SandeshaStorageException
Specified by:
findUnique in interface SenderBeanMgr
Throws:
SandeshaStorageException

retrieveFromMessageRefKey

public SenderBean retrieveFromMessageRefKey(java.lang.String messageContextRefKey)
Specified by:
retrieveFromMessageRefKey in interface SenderBeanMgr
Returns:

retrieve

public SenderBean retrieve(java.lang.String sequnceId,
                           long messageNumber)
                    throws SandeshaStorageException
Specified by:
retrieve in interface SenderBeanMgr
Throws:
SandeshaStorageException


Copyright © The Apache Software Foundation. All Rights Reserved.