org.apache.sandesha2.storage.inmemory
Class InMemoryRMSBeanMgr

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

public class InMemoryRMSBeanMgr
extends java.lang.Object
implements RMSBeanMgr


Field Summary
protected  InMemoryStorageManager mgr
           
protected  java.util.concurrent.ConcurrentHashMap<java.lang.String,T> table
           
 
Constructor Summary
InMemoryRMSBeanMgr(InMemoryStorageManager mgr, org.apache.axis2.context.AbstractContext context)
           
 
Method Summary
protected  T delete(java.lang.Object key)
           
 boolean delete(java.lang.String msgId)
           
 java.util.List<RMSBean> find(RMSBean bean)
           
protected  java.util.List<T> findNoLock(T matchInfo)
           
 RMSBean findUnique(RMSBean bean)
           
protected  T findUniqueNoLock(RMBean matchInfo)
           
 boolean insert(RMSBean bean)
           
protected  boolean insert(java.lang.String key, T bean)
           
protected  T retrieve(java.lang.Object key)
           
 RMSBean retrieve(java.lang.String msgId)
           
 RMSBean retrieveByInternalSequenceID(java.lang.String internalSeqId)
           
 RMSBean retrieveBySequenceID(java.lang.String seqId)
           
 boolean update(RMSBean bean)
           
protected  boolean update(java.lang.String key, T 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<java.lang.String,T extends RMBean> table

mgr

protected InMemoryStorageManager mgr
Constructor Detail

InMemoryRMSBeanMgr

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

insert

public boolean insert(RMSBean bean)
               throws SandeshaStorageException
Specified by:
insert in interface RMSBeanMgr
Throws:
SandeshaStorageException

delete

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

retrieve

public RMSBean retrieve(java.lang.String msgId)
                 throws SandeshaStorageException
Specified by:
retrieve in interface RMSBeanMgr
Throws:
SandeshaStorageException

update

public boolean update(RMSBean bean)
               throws SandeshaStorageException
Specified by:
update in interface RMSBeanMgr
Throws:
SandeshaStorageException

find

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

findUnique

public RMSBean findUnique(RMSBean bean)
                   throws SandeshaStorageException
Specified by:
findUnique in interface RMSBeanMgr
Throws:
SandeshaStorageException

retrieveBySequenceID

public RMSBean retrieveBySequenceID(java.lang.String seqId)
                             throws SandeshaStorageException
Specified by:
retrieveBySequenceID in interface RMSBeanMgr
Throws:
SandeshaStorageException

retrieveByInternalSequenceID

public RMSBean retrieveByInternalSequenceID(java.lang.String internalSeqId)
                                     throws SandeshaStorageException
Specified by:
retrieveByInternalSequenceID in interface RMSBeanMgr
Throws:
SandeshaStorageException

insert

protected boolean insert(java.lang.String key,
                         T bean)
                  throws SandeshaStorageException
Throws:
SandeshaStorageException

delete

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

retrieve

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

update

protected boolean update(java.lang.String key,
                         T bean)
                  throws SandeshaStorageException
Throws:
SandeshaStorageException

findNoLock

protected java.util.List<T> findNoLock(T matchInfo)
                                               throws SandeshaStorageException
Throws:
SandeshaStorageException

findUniqueNoLock

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


Copyright © The Apache Software Foundation. All Rights Reserved.