public class HornetqObjectStoreAdaptor extends Object implements ObjectStoreAPI
Constructor and Description |
---|
HornetqObjectStoreAdaptor() |
HornetqObjectStoreAdaptor(HornetqJournalStore store) |
Modifier and Type | Method and Description |
---|---|
boolean |
allObjUids(String typeName,
InputObjectState foundInstances) |
boolean |
allObjUids(String typeName,
InputObjectState foundInstances,
int matchState)
Obtain all of the Uids for a specified type.
|
boolean |
allTypes(InputObjectState foundTypes)
Obtain all types of objects stored in the object store.
|
boolean |
commit_state(Uid u,
String tn)
Commit the object's state in the object store.
|
int |
currentState(Uid u,
String typeName) |
boolean |
fullCommitNeeded() |
String |
getStoreName() |
boolean |
hide_state(Uid u,
String tn)
Hide the object's state in the object store.
|
boolean |
isType(Uid u,
String tn,
int st)
Is the current state of the object the same as that provided as the last
parameter?
|
InputObjectState |
read_committed(Uid u,
String typeName)
Read the object's committed state.
|
InputObjectState |
read_uncommitted(Uid u,
String tn)
Read the object's shadowed state.
|
boolean |
remove_committed(Uid u,
String typeName)
Remove the object's committed state.
|
boolean |
remove_uncommitted(Uid u,
String tn)
Remove the object's uncommitted state.
|
boolean |
reveal_state(Uid u,
String tn)
Reveal a hidden object's state.
|
void |
start() |
void |
stop() |
void |
sync()
Some object store implementations may be running with automatic
sync disabled.
|
boolean |
write_committed(Uid u,
String typeName,
OutputObjectState buff)
Write a new copy of the object's committed state.
|
boolean |
write_uncommitted(Uid u,
String tn,
OutputObjectState buff)
Write a copy of the object's uncommitted state.
|
public HornetqObjectStoreAdaptor() throws IOException
IOException
public HornetqObjectStoreAdaptor(HornetqJournalStore store)
public InputObjectState read_uncommitted(Uid u, String tn) throws ObjectStoreException
read_uncommitted
in interface ParticipantStore
u
- The object to work on.tn
- The type of the object to work on.ObjectStoreException
public boolean remove_uncommitted(Uid u, String tn) throws ObjectStoreException
remove_uncommitted
in interface ParticipantStore
u
- The object to work on.tn
- The type of the object to work on.true
if no errors occurred, false
otherwise.ObjectStoreException
public InputObjectState read_committed(Uid u, String typeName) throws ObjectStoreException
read_committed
in interface ParticipantStore
read_committed
in interface RecoveryStore
u
- The object to work on.typeName
- The type of the object to work on.ObjectStoreException
public boolean remove_committed(Uid u, String typeName) throws ObjectStoreException
remove_committed
in interface TxLog
u
- The object to work on.typeName
- The type of the object to work on.true
if no errors occurred, false
otherwise.ObjectStoreException
public boolean hide_state(Uid u, String tn) throws ObjectStoreException
hide_state
in interface RecoveryStore
u
- The object to work on.tn
- The type of the object to work on.true
if no errors occurred, false
otherwise.ObjectStoreException
public boolean reveal_state(Uid u, String tn) throws ObjectStoreException
reveal_state
in interface RecoveryStore
u
- The object to work on.tn
- The type of the object to work on.true
if no errors occurred, false
otherwise.ObjectStoreException
public boolean commit_state(Uid u, String tn) throws ObjectStoreException
commit_state
in interface ParticipantStore
u
- The object to work on.tn
- The type of the object to work on.true
if no errors occurred, false
otherwise.ObjectStoreException
public int currentState(Uid u, String typeName) throws ObjectStoreException
currentState
in interface RecoveryStore
u
- The object to query.typeName
- The type of the object to query.ObjectStoreException
public boolean write_uncommitted(Uid u, String tn, OutputObjectState buff) throws ObjectStoreException
write_uncommitted
in interface ParticipantStore
u
- The object to work on.tn
- The type of the object to work on.buff
- The state to write.true
if no errors occurred, false
otherwise.ObjectStoreException
public boolean write_committed(Uid u, String typeName, OutputObjectState buff) throws ObjectStoreException
write_committed
in interface TxLog
u
- The object to work on.typeName
- The type of the object to work on.buff
- The state to write.true
if no errors occurred, false
otherwise.ObjectStoreException
public boolean allObjUids(String typeName, InputObjectState foundInstances) throws ObjectStoreException
allObjUids
in interface RecoveryStore
ObjectStoreException
public boolean allObjUids(String typeName, InputObjectState foundInstances, int matchState) throws ObjectStoreException
allObjUids
in interface RecoveryStore
typeName
- The type to scan for.foundInstances
- The object state in which to store the UidsmatchState
- The file type to look for (e.g., committed, shadowed). [StateStatus]true
if no errors occurred, false
otherwise.ObjectStoreException
public boolean allTypes(InputObjectState foundTypes) throws ObjectStoreException
allTypes
in interface RecoveryStore
foundTypes
- The state in which to store the types.true
if no errors occurred, false
otherwise.ObjectStoreException
public void sync() throws SyncFailedException, ObjectStoreException
sync
in interface TxLog
SyncFailedException
ObjectStoreException
public String getStoreName()
getStoreName
in interface BaseStore
public boolean fullCommitNeeded()
fullCommitNeeded
in interface ParticipantStore
public boolean isType(Uid u, String tn, int st) throws ObjectStoreException
isType
in interface RecoveryStore
u
- The object to work on.tn
- The type of the object.st
- The expected type of the object. [StateType]true
if the current state is as expected,
false
otherwise.ObjectStoreException
Copyright © 2021 JBoss by Red Hat. All rights reserved.