org.projectodd.wunderboss.messaging.hornetq

Class HQContext

java.lang.Object

org.projectodd.wunderboss.messaging.hornetq.HQContext

All Implemented Interfaces:

AutoCloseable, Context, HQSpecificContext

Direct Known Subclasses:

HQXAContext

public class HQContext
extends Object
implements HQSpecificContext

Nested Class Summary

Nested classes/interfaces inherited from interface org.projectodd.wunderboss.messaging.Context

Context.Mode

Field Summary

Fields

Modifier and Type	Field and Description
static ThreadLocal<HQSpecificContext>	currentContext

Constructor Summary

Constructors

Constructor and Description
HQContext(javax.jms.JMSContext jmsContext, Messaging broker, Context.Mode mode, boolean remote)
HQContext(javax.jms.JMSContext jmsContext, Messaging broker, Context.Mode mode, boolean remote, HQSpecificContext parent)

Method Summary

Methods

Modifier and Type	Method and Description
void	acknowledge()
void	addCloseable(AutoCloseable closeable)
HQSpecificContext	asNonCloseable()
Messaging	broker()
void	close()
void	commit()
HQSpecificContext	createChildContext(Context.Mode mode)
boolean	enlist()
boolean	isChild()
boolean	isRemote()
boolean	isXAEnabled()
javax.jms.JMSContext	jmsContext()
Context.Mode	mode()
static int	modeToJMSMode(Context.Mode mode)
void	rollback()

Methods inherited from class java.lang.Object

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

Field Detail

currentContext

public static ThreadLocal<HQSpecificContext> currentContext

Constructor Detail

HQContext

public HQContext(javax.jms.JMSContext jmsContext,
         Messaging broker,
         Context.Mode mode,
         boolean remote)

HQContext

public HQContext(javax.jms.JMSContext jmsContext,
         Messaging broker,
         Context.Mode mode,
         boolean remote,
         HQSpecificContext parent)

Method Detail

modeToJMSMode

public static int modeToJMSMode(Context.Mode mode)

mode

public Context.Mode mode()

Specified by:

mode in interface Context

commit

public void commit()

Specified by:

commit in interface Context

rollback

public void rollback()

Specified by:

rollback in interface Context

acknowledge

public void acknowledge()

Specified by:

acknowledge in interface Context

enlist

public boolean enlist()
               throws Exception

Specified by:

enlist in interface Context

Throws:

Exception

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

addCloseable

public void addCloseable(AutoCloseable closeable)

Specified by:

addCloseable in interface Context

isRemote

public boolean isRemote()

Specified by:

isRemote in interface Context

jmsContext

public javax.jms.JMSContext jmsContext()

Specified by:

jmsContext in interface HQSpecificContext

broker

public Messaging broker()

Specified by:

broker in interface HQSpecificContext

isXAEnabled

public boolean isXAEnabled()

Specified by:

isXAEnabled in interface HQSpecificContext

isChild

public boolean isChild()

Specified by:

isChild in interface HQSpecificContext

asNonCloseable

public HQSpecificContext asNonCloseable()

Specified by:

asNonCloseable in interface HQSpecificContext

createChildContext

public HQSpecificContext createChildContext(Context.Mode mode)

Specified by:

createChildContext in interface HQSpecificContext