org.projectodd.wunderboss.messaging.hornetq

Class HQMessaging

java.lang.Object

org.projectodd.wunderboss.messaging.hornetq.HQMessaging

All Implemented Interfaces:

Component, Messaging

public class HQMessaging
extends Object
implements Messaging

Nested Class Summary

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

Messaging.CreateContextOption, Messaging.CreateOption, Messaging.CreateQueueOption, Messaging.CreateTopicOption

Field Summary

Fields

Modifier and Type	Field and Description
static String	REMOTE_TYPE_STANDALONE
static String	REMOTE_TYPE_WILDFLY
protected EmbeddedServer	server
protected boolean	started

Constructor Summary

Constructors

Constructor and Description
HQMessaging(String name, Options<Messaging.CreateOption> options)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	addCloseable(AutoCloseable closeable)
protected void	addCloseableForDestination(HQDestination dest, AutoCloseable c)
protected void	closeCloseables()
Context	createContext(Map<Messaging.CreateContextOption,Object> options)
protected javax.jms.Queue	createQueue(String name, String selector, boolean durable)
protected javax.jms.Topic	createTopic(String name)
protected boolean	destroyDestination(HQDestination dest)
protected void	destroyQueue(String name)
protected void	destroyTopic(String name)
Queue	findOrCreateQueue(String name, Map<Messaging.CreateQueueOption,Object> options)
Topic	findOrCreateTopic(String name, Map<Messaging.CreateTopicOption,Object> options)
boolean	isRunning()
org.hornetq.jms.server.JMSServerManager	jmsServerManager()
protected Object	lookupJNDI(List<String> jndiNames)
protected Object	lookupJNDI(String jndiName)
protected javax.jms.Queue	lookupQueue(String name)
protected javax.jms.Topic	lookupTopic(String name)
String	name()
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Field Detail

REMOTE_TYPE_WILDFLY

public static final String REMOTE_TYPE_WILDFLY

See Also:

Constant Field Values

REMOTE_TYPE_STANDALONE

public static final String REMOTE_TYPE_STANDALONE

See Also:

Constant Field Values

started

protected boolean started

server

protected EmbeddedServer server

Constructor Detail

HQMessaging

public HQMessaging(String name,
           Options<Messaging.CreateOption> options)

Method Detail

start

public void start()
           throws Exception

Specified by:

start in interface Component

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface Component

Throws:

Exception

isRunning

public boolean isRunning()

Specified by:

isRunning in interface Component

jmsServerManager

public org.hornetq.jms.server.JMSServerManager jmsServerManager()

name

public String name()

Specified by:

name in interface Component

createContext

public Context createContext(Map<Messaging.CreateContextOption,Object> options)
                      throws Exception

Specified by:

createContext in interface Messaging

Throws:

Exception

findOrCreateQueue

public Queue findOrCreateQueue(String name,
                      Map<Messaging.CreateQueueOption,Object> options)
                        throws Exception

Specified by:

findOrCreateQueue in interface Messaging

Throws:

Exception

findOrCreateTopic

public Topic findOrCreateTopic(String name,
                      Map<Messaging.CreateTopicOption,Object> options)
                        throws Exception

Specified by:

findOrCreateTopic in interface Messaging

Throws:

Exception

addCloseable

protected void addCloseable(AutoCloseable closeable)

closeCloseables

protected void closeCloseables()
                        throws Exception

Throws:

Exception

createTopic

protected javax.jms.Topic createTopic(String name)
                               throws Exception

Throws:

Exception

createQueue

protected javax.jms.Queue createQueue(String name,
                          String selector,
                          boolean durable)
                               throws Exception

Throws:

Exception

destroyDestination

protected boolean destroyDestination(HQDestination dest)
                              throws Exception

Throws:

Exception

destroyQueue

protected void destroyQueue(String name)
                     throws Exception

Throws:

Exception

destroyTopic

protected void destroyTopic(String name)
                     throws Exception

Throws:

Exception

addCloseableForDestination

protected void addCloseableForDestination(HQDestination dest,
                              AutoCloseable c)

lookupTopic

protected javax.jms.Topic lookupTopic(String name)

lookupQueue

protected javax.jms.Queue lookupQueue(String name)

lookupJNDI

protected Object lookupJNDI(String jndiName)

lookupJNDI

protected Object lookupJNDI(List<String> jndiNames)