org.apache.sandesha2.storage.inmemory
Class InMemorySenderBeanMgr
java.lang.Object
org.apache.sandesha2.storage.inmemory.InMemorySenderBeanMgr
- All Implemented Interfaces:
- RMBeanManager, SenderBeanMgr
public class InMemorySenderBeanMgr
- extends java.lang.Object
- implements SenderBeanMgr
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
mgr
protected InMemoryStorageManager mgr
InMemorySenderBeanMgr
public InMemorySenderBeanMgr(InMemoryStorageManager mgr,
org.apache.axis2.context.AbstractContext context)
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
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 boolean 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
findUnique
protected RMBean findUnique(RMBean matchInfo)
throws SandeshaException
- Throws:
SandeshaException
checkKeys
protected void checkKeys(java.util.List findBeanList)
throws SandeshaStorageException
- This try to find conflicting entries in the current table with the passed findBean list.
Each find bean represents a key.
- Parameters:
findBeanList
-
- Throws:
SandeshaStorageException
Copyright © 2007 Apache Web Services Project. All Rights Reserved.