com.arjuna.ats.internal.arjuna.objectstore.hornetq

Class HornetqJournalStore

java.lang.Object

com.arjuna.ats.internal.arjuna.objectstore.hornetq.HornetqJournalStore

public class HornetqJournalStore
extends Object

Implementation of the tx store backed by HornetQ's journal. This is a bean suitable for hooking into the app server lifecycle.

Author:

Jonathan Halliday (jonathan.halliday@redhat.com), 2010-03

Constructor Summary

Constructors

Constructor and Description
HornetqJournalStore(HornetqJournalEnvironmentBean envBean)

Method Summary

Modifier and Type	Method and Description
boolean	contains(Uid uid, String typeName)
String[]	getKnownTypes()
String	getStoreName()
Uid[]	getUidsForType(String typeName)
InputObjectState	read_committed(Uid uid, String typeName) Read the object's committed state.
boolean	remove_committed(Uid uid, String typeName) Remove the object's committed state.
void	start()
void	stop()
boolean	write_committed(Uid uid, String typeName, OutputObjectState txData) Write a new copy of the object's committed state.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HornetqJournalStore

public HornetqJournalStore(HornetqJournalEnvironmentBean envBean)
                    throws IOException

Throws:

IOException

Method Detail

stop

public void stop()
          throws Exception

Throws:

Exception

start

public void start()
           throws Exception

Throws:

Exception

remove_committed

public boolean remove_committed(Uid uid,
                                String typeName)
                         throws ObjectStoreException

Remove the object's committed state.

Parameters:

uid - The object to work on.

typeName - The type of the object to work on.

Returns:

true if no errors occurred, false otherwise.

Throws:

ObjectStoreException - if things go wrong.

write_committed

public boolean write_committed(Uid uid,
                               String typeName,
                               OutputObjectState txData)
                        throws ObjectStoreException

Write a new copy of the object's committed state.

Parameters:

uid - The object to work on.

typeName - The type of the object to work on.

txData - The state to write.

Returns:

true if no errors occurred, false otherwise.

Throws:

ObjectStoreException - if things go wrong.

read_committed

public InputObjectState read_committed(Uid uid,
                                       String typeName)
                                throws ObjectStoreException

Read the object's committed state.

Parameters:

uid - The object to work on.

typeName - The type of the object to work on.

Returns:

the state of the object.

Throws:

ObjectStoreException - if things go wrong.

contains

public boolean contains(Uid uid,
                        String typeName)

getStoreName

public String getStoreName()

Returns:

the "name" of the object store. Where in the hierarchy it appears, e.g., /ObjectStore/MyName/...

getKnownTypes

public String[] getKnownTypes()

getUidsForType

public Uid[] getUidsForType(String typeName)