org.apache.sandesha2.storage.inmemory
Class InMemorySenderBeanMgr

java.lang.Object
  extended by org.apache.sandesha2.storage.inmemory.InMemorySenderBeanMgr
All Implemented Interfaces:
RMBeanManager, SenderBeanMgr

public class InMemorySenderBeanMgr
extends java.lang.Object
implements SenderBeanMgr


Field Summary
protected  InMemoryStorageManager mgr
           
protected  java.util.concurrent.ConcurrentHashMap table
           
 
Constructor Summary
InMemorySenderBeanMgr(InMemoryStorageManager mgr, org.apache.axis2.context.AbstractContext context)
           
 
Method Summary
protected  RMBean delete(java.lang.Object key)
           
 boolean delete(java.lang.String MessageId)
           
protected  java.util.List find(RMBean matchInfo)
           
 java.util.List find(SenderBean bean)
           
 java.util.List find(java.lang.String internalSequenceID)
           
protected  java.util.List findNoLock(RMBean matchInfo)
           
protected  RMBean findUnique(RMBean matchInfo)
           
 SenderBean findUnique(SenderBean bean)
           
protected  RMBean findUniqueNoLock(RMBean matchInfo)
           
 SenderBean getNextMsgToSend(java.lang.String sequenceId)
           
protected  boolean insert(java.lang.Object key, RMBean bean)
           
 boolean insert(SenderBean bean)
           
protected  RMBean retrieve(java.lang.Object key)
           
 SenderBean retrieve(java.lang.String MessageId)
           
 SenderBean retrieve(java.lang.String sequnceId, long messageNumber)
           
 SenderBean retrieveFromMessageRefKey(java.lang.String messageContextRefKey)
           
protected  boolean update(java.lang.Object key, RMBean bean)
           
 boolean update(SenderBean bean)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

table

protected java.util.concurrent.ConcurrentHashMap table

mgr

protected InMemoryStorageManager mgr
Constructor Detail

InMemorySenderBeanMgr

public InMemorySenderBeanMgr(InMemoryStorageManager mgr,
                             org.apache.axis2.context.AbstractContext context)
Method Detail

delete

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

retrieve

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

retrieve

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

insert

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

find

public java.util.List find(java.lang.String internalSequenceID)
                    throws SandeshaStorageException
Specified by:
find in interface SenderBeanMgr
Throws:
SandeshaStorageException

find

public java.util.List find(SenderBean bean)
                    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

update

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

findUnique

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

retrieveFromMessageRefKey

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

insert

protected boolean insert(java.lang.Object key,
                         RMBean bean)
                  throws SandeshaStorageException
Throws:
SandeshaStorageException

delete

protected RMBean delete(java.lang.Object key)
                 throws SandeshaStorageException
Throws:
SandeshaStorageException

retrieve

protected RMBean retrieve(java.lang.Object key)
                   throws SandeshaStorageException
Throws:
SandeshaStorageException

update

protected boolean update(java.lang.Object key,
                         RMBean bean)
                  throws SandeshaStorageException
Throws:
SandeshaStorageException

find

protected java.util.List find(RMBean matchInfo)
                       throws SandeshaStorageException
Throws:
SandeshaStorageException

findNoLock

protected java.util.List findNoLock(RMBean matchInfo)
                             throws SandeshaStorageException
Throws:
SandeshaStorageException

findUnique

protected RMBean findUnique(RMBean matchInfo)
                     throws SandeshaStorageException
Throws:
SandeshaStorageException

findUniqueNoLock

protected RMBean findUniqueNoLock(RMBean matchInfo)
                           throws SandeshaStorageException
Throws:
SandeshaStorageException


Copyright © 2007 Apache Web Services Project. All Rights Reserved.