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

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 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.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.