ome.smuggler.providers.q

Class QueueConnector

java.lang.Object

ome.smuggler.providers.q.QueueConnector

public class QueueConnector
extends java.lang.Object

Provides access to an Artemis queue.

Constructor Summary

Constructors

Constructor and Description
QueueConnector(org.apache.activemq.artemis.core.config.CoreQueueConfiguration config, org.apache.activemq.artemis.api.core.client.ClientSession session) Creates a new instance to access the specified queue.

Method Summary

Modifier and Type	Method and Description
org.apache.activemq.artemis.core.config.CoreQueueConfiguration	getConfig()
org.apache.activemq.artemis.api.core.client.ClientSession	getSession()
org.apache.activemq.artemis.api.core.client.ClientConsumer	newBrowser() Creates a new consumer to receive messages from the queue without removing them.
org.apache.activemq.artemis.api.core.client.ClientConsumer	newConsumer() Creates a new consumer to fetch messages from the queue.
org.apache.activemq.artemis.api.core.client.ClientMessage	newDurableMessage() Creates a new durable message.
org.apache.activemq.artemis.api.core.client.ClientProducer	newProducer() Creates a new producer to put messages on the queue.

Methods inherited from class java.lang.Object

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

Constructor Detail

QueueConnector

public QueueConnector(org.apache.activemq.artemis.core.config.CoreQueueConfiguration config,
                      org.apache.activemq.artemis.api.core.client.ClientSession session)

Creates a new instance to access the specified queue.

Parameters:

config - the queue to access.

session - the session to use to access the queue.

Throws:

java.lang.NullPointerException - if any argument is null.

Method Detail

newConsumer

public org.apache.activemq.artemis.api.core.client.ClientConsumer newConsumer()
                                                                       throws org.apache.activemq.artemis.api.core.ActiveMQException

Creates a new consumer to fetch messages from the queue.

Returns:

the consumer.

Throws:

org.apache.activemq.artemis.api.core.ActiveMQException - if the consumer could not be created.

newBrowser

public org.apache.activemq.artemis.api.core.client.ClientConsumer newBrowser()
                                                                      throws org.apache.activemq.artemis.api.core.ActiveMQException

Creates a new consumer to receive messages from the queue without removing them.

Returns:

the consumer.

Throws:

org.apache.activemq.artemis.api.core.ActiveMQException - if the consumer could not be created.

newProducer

public org.apache.activemq.artemis.api.core.client.ClientProducer newProducer()
                                                                       throws org.apache.activemq.artemis.api.core.ActiveMQException

Creates a new producer to put messages on the queue.

Returns:

the producer.

Throws:

org.apache.activemq.artemis.api.core.ActiveMQException - if the producer could not be created.

newDurableMessage

public org.apache.activemq.artemis.api.core.client.ClientMessage newDurableMessage()

Creates a new durable message.

Returns:

the message.

getSession

public org.apache.activemq.artemis.api.core.client.ClientSession getSession()

Returns:

the session in use to access the queue.

getConfig

public org.apache.activemq.artemis.core.config.CoreQueueConfiguration getConfig()

Returns:

configuration of the queue to access.