public interface ClientSession extends XAResource
Modifier and Type | Interface and Description |
---|---|
static interface |
ClientSession.BindingQuery
Information returned by a binding query
|
static interface |
ClientSession.QueueQuery
Information returned by a queue query
|
TMENDRSCAN, TMFAIL, TMJOIN, TMNOFLAGS, TMONEPHASE, TMRESUME, TMSTARTRSCAN, TMSUCCESS, TMSUSPEND, XA_OK, XA_RDONLY
Modifier and Type | Method and Description |
---|---|
void |
addFailureListener(SessionFailureListener listener)
Adds a FailureListener to the session which is notified if a failure occurs on the session.
|
void |
addMetaData(String key,
String data)
Attach any metadata to the session.
|
void |
addMetaDataV1(String key,
String data)
Deprecated.
|
void |
addUniqueMetaData(String key,
String data)
Attach any metadata to the session.
|
ClientSession.BindingQuery |
bindingQuery(SimpleString address)
Queries information on a binding.
|
void |
close()
Closes the session.
|
void |
commit()
Commits the current transaction.
|
ClientConsumer |
createConsumer(SimpleString queueName)
Creates a ClientConsumer to consume message from the queue with the given name.
|
ClientConsumer |
createConsumer(SimpleString queueName,
boolean browseOnly)
Creates a ClientConsumer to consume or browse messages from the queue with the given name.
|
ClientConsumer |
createConsumer(SimpleString queueName,
SimpleString filter)
Creates a ClientConsumer to consume messages matching the filter from the queue with the given name.
|
ClientConsumer |
createConsumer(SimpleString queueName,
SimpleString filter,
boolean browseOnly)
Creates a ClientConsumer to consume or browse messages matching the filter from the queue with the given name.
|
ClientConsumer |
createConsumer(SimpleString queueName,
SimpleString filter,
int windowSize,
int maxRate,
boolean browseOnly)
Creates a ClientConsumer to consume or browse messages matching the filter from the queue with the given name.
|
ClientConsumer |
createConsumer(String queueName)
Creates a ClientConsumer to consume messages from the queue with the given name.
|
ClientConsumer |
createConsumer(String queueName,
boolean browseOnly)
Creates a ClientConsumer to consume or browse messages from the queue with the given name.
|
ClientConsumer |
createConsumer(String queueName,
String filter)
Creates a ClientConsumer to consume messages matching the filter from the queue with the given name.
|
ClientConsumer |
createConsumer(String queueName,
String filter,
boolean browseOnly)
Creates a ClientConsumer to consume or browse messages matching the filter from the queue with the given name.
|
ClientConsumer |
createConsumer(String queueName,
String filter,
int windowSize,
int maxRate,
boolean browseOnly)
Creates a ClientConsumer to consume or browse messages matching the filter from the queue with the given name.
|
ClientMessage |
createMessage(boolean durable)
Creates a ClientMessage.
|
ClientMessage |
createMessage(byte type,
boolean durable)
Creates a ClientMessage.
|
ClientMessage |
createMessage(byte type,
boolean durable,
long expiration,
long timestamp,
byte priority)
Creates a ClientMessage.
|
ClientProducer |
createProducer()
Creates a producer with no default address.
|
ClientProducer |
createProducer(SimpleString address)
Creates a producer which sends messages to the given address
|
ClientProducer |
createProducer(SimpleString address,
int rate)
Creates a producer which sends messages to the given address
|
ClientProducer |
createProducer(String address)
Creates a producer which sends messages to the given address
|
void |
createQueue(SimpleString address,
SimpleString queueName)
Creates a non-temporary queue non-durable queue.
|
void |
createQueue(SimpleString address,
SimpleString queueName,
boolean durable)
Creates a non-temporary queue.
|
void |
createQueue(SimpleString address,
SimpleString queueName,
SimpleString filter,
boolean durable)
Creates a non-temporary queue.
|
void |
createQueue(String address,
String queueName)
Creates a non-temporary queue non-durable queue.
|
void |
createQueue(String address,
String queueName,
boolean durable)
Creates a non-temporary queue.
|
void |
createQueue(String address,
String queueName,
String filter,
boolean durable)
Creates a non-temporaryqueue.
|
void |
createTemporaryQueue(SimpleString address,
SimpleString queueName)
Creates a temporary queue.
|
void |
createTemporaryQueue(SimpleString address,
SimpleString queueName,
SimpleString filter)
Creates a temporary queue with a filter.
|
void |
createTemporaryQueue(String address,
String queueName)
Creates a temporary queue.
|
void |
createTemporaryQueue(String address,
String queueName,
String filter)
Creates a temporary queue with a filter.
|
void |
deleteQueue(SimpleString queueName)
Deletes the queue.
|
void |
deleteQueue(String queueName)
Deletes the queue.
|
int |
getVersion()
Returns the server's incrementingVersion.
|
XAResource |
getXAResource()
Returns the XAResource associated to the session.
|
boolean |
isAutoCommitAcks()
Returns whether the session will automatically commit its transaction every time a message is acknowledged
by a ClientConsumer created by this session,
false else |
boolean |
isAutoCommitSends()
Returns whether the session will automatically commit its transaction every time a message is sent
by a ClientProducer created by this session,
false else |
boolean |
isBlockOnAcknowledge()
Returns whether the ClientConsumer created by the session will block when they acknowledge a message.
|
boolean |
isClosed()
Returns whether the session is closed or not.
|
boolean |
isRollbackOnly()
Returns
true if the current transaction has been flagged to rollback, false else. |
boolean |
isXA()
Return
true if the session supports XA, false else. |
ClientSession.QueueQuery |
queueQuery(SimpleString queueName)
Queries information on a queue.
|
boolean |
removeFailureListener(SessionFailureListener listener)
Removes a FailureListener to the session.
|
void |
rollback()
Rolls back the current transaction.
|
void |
rollback(boolean considerLastMessageAsDelivered)
Rolls back the current transaction.
|
void |
setSendAcknowledgementHandler(SendAcknowledgementHandler handler)
Sets a
SendAcknowledgementHandler for this session. |
void |
start()
Starts the session.
|
void |
stop()
Stops the session.
|
commit, end, forget, getTransactionTimeout, isSameRM, prepare, recover, rollback, setTransactionTimeout, start
void start() throws HornetQException
HornetQException
- if an exception occurs while starting the sessionvoid stop() throws HornetQException
HornetQException
- if an exception occurs while stopping the sessionvoid close() throws HornetQException
HornetQException
- if an exception occurs while closing the sessionboolean isClosed()
true
if the session is closed, false
elsevoid addFailureListener(SessionFailureListener listener)
listener
- the listener to addboolean removeFailureListener(SessionFailureListener listener)
listener
- the listener to removetrue
if the listener was removed, false
elseint getVersion()
incrementingVersion
void createQueue(SimpleString address, SimpleString queueName, boolean durable) throws HornetQException
address
- the queue will be bound to this addressqueueName
- the name of the queuedurable
- whether the queue is durable or notHornetQException
- in an exception occurs while creating the queuevoid createQueue(String address, String queueName, boolean durable) throws HornetQException
address
- the queue will be bound to this addressqueueName
- the name of the queuedurable
- whether the queue is durable or notHornetQException
- in an exception occurs while creating the queuevoid createQueue(String address, String queueName) throws HornetQException
address
- the queue will be bound to this addressqueueName
- the name of the queueHornetQException
- in an exception occurs while creating the queuevoid createQueue(SimpleString address, SimpleString queueName) throws HornetQException
address
- the queue will be bound to this addressqueueName
- the name of the queueHornetQException
- in an exception occurs while creating the queuevoid createQueue(SimpleString address, SimpleString queueName, SimpleString filter, boolean durable) throws HornetQException
address
- the queue will be bound to this addressqueueName
- the name of the queuedurable
- whether the queue is durable or notfilter
- only messages which match this filter will be put in the queueHornetQException
- in an exception occurs while creating the queuevoid createQueue(String address, String queueName, String filter, boolean durable) throws HornetQException
address
- the queue will be bound to this addressqueueName
- the name of the queuedurable
- whether the queue is durable or notfilter
- only messages which match this filter will be put in the queueHornetQException
- in an exception occurs while creating the queuevoid createTemporaryQueue(SimpleString address, SimpleString queueName) throws HornetQException
address
- the queue will be bound to this addressqueueName
- the name of the queueHornetQException
- in an exception occurs while creating the queuevoid createTemporaryQueue(String address, String queueName) throws HornetQException
address
- the queue will be bound to this addressqueueName
- the name of the queueHornetQException
- in an exception occurs while creating the queuevoid createTemporaryQueue(SimpleString address, SimpleString queueName, SimpleString filter) throws HornetQException
address
- the queue will be bound to this addressqueueName
- the name of the queuefilter
- only messages which match this filter will be put in the queueHornetQException
- in an exception occurs while creating the queuevoid createTemporaryQueue(String address, String queueName, String filter) throws HornetQException
address
- the queue will be bound to this addressqueueName
- the name of the queuefilter
- only messages which match this filter will be put in the queueHornetQException
- in an exception occurs while creating the queuevoid deleteQueue(SimpleString queueName) throws HornetQException
queueName
- the name of the queue to deleteHornetQException
- if there is no queue for the given name or if the queue has consumersvoid deleteQueue(String queueName) throws HornetQException
queueName
- the name of the queue to deleteHornetQException
- if there is no queue for the given name or if the queue has consumersClientConsumer createConsumer(SimpleString queueName) throws HornetQException
queueName
- name of the queue to consume messages fromHornetQException
- if an exception occurs while creating the ClientConsumerClientConsumer createConsumer(String queueName) throws HornetQException
queueName
- name of the queue to consume messages fromHornetQException
- if an exception occurs while creating the ClientConsumerClientConsumer createConsumer(SimpleString queueName, SimpleString filter) throws HornetQException
queueName
- name of the queue to consume messages fromfilter
- only messages which match this filter will be consumedHornetQException
- if an exception occurs while creating the ClientConsumerClientConsumer createConsumer(String queueName, String filter) throws HornetQException
queueName
- name of the queue to consume messages fromfilter
- only messages which match this filter will be consumedHornetQException
- if an exception occurs while creating the ClientConsumerClientConsumer createConsumer(SimpleString queueName, boolean browseOnly) throws HornetQException
browseOnly
is true
, the ClientConsumer will receive the messages from the queue
but they will not be consumed (the messages will remain in the queue).
If browseOnly
is false
, the ClientConsumer will behave like consume the messages from the queue and
the messages will effectively be removed from the queue.queueName
- name of the queue to consume messages frombrowseOnly
- whether the ClientConsumer will only browse the queue or consume messages.HornetQException
- if an exception occurs while creating the ClientConsumerClientConsumer createConsumer(String queueName, boolean browseOnly) throws HornetQException
browseOnly
is true
, the ClientConsumer will receive the messages from the queue
but they will not be consumed (the messages will remain in the queue).
If browseOnly
is false
, the ClientConsumer will behave like consume the messages from the queue and
the messages will effectively be removed from the queue.queueName
- name of the queue to consume messages frombrowseOnly
- whether the ClientConsumer will only browse the queue or consume messages.HornetQException
- if an exception occurs while creating the ClientConsumerClientConsumer createConsumer(String queueName, String filter, boolean browseOnly) throws HornetQException
browseOnly
is true
, the ClientConsumer will receive the messages from the queue
but they will not be consumed (the messages will remain in the queue).
If browseOnly
is false
, the ClientConsumer will behave like consume the messages from the queue and
the messages will effectively be removed from the queue.queueName
- name of the queue to consume messages fromfilter
- only messages which match this filter will be consumedbrowseOnly
- whether the ClientConsumer will only browse the queue or consume messages.HornetQException
- if an exception occurs while creating the ClientConsumerClientConsumer createConsumer(SimpleString queueName, SimpleString filter, boolean browseOnly) throws HornetQException
browseOnly
is true
, the ClientConsumer will receive the messages from the queue
but they will not be consumed (the messages will remain in the queue).
If browseOnly
is false
, the ClientConsumer will behave like consume the messages from the queue and
the messages will effectively be removed from the queue.queueName
- name of the queue to consume messages fromfilter
- only messages which match this filter will be consumedbrowseOnly
- whether the ClientConsumer will only browse the queue or consume messages.HornetQException
- if an exception occurs while creating the ClientConsumerClientConsumer createConsumer(SimpleString queueName, SimpleString filter, int windowSize, int maxRate, boolean browseOnly) throws HornetQException
browseOnly
is true
, the ClientConsumer will receive the messages from the queue
but they will not be consumed (the messages will remain in the queue).
If browseOnly
is false
, the ClientConsumer will behave like consume the messages from the queue and
the messages will effectively be removed from the queue.queueName
- name of the queue to consume messages fromfilter
- only messages which match this filter will be consumedwindowSize
- the consumer window sizemaxRate
- the maximum rate to consume messagesbrowseOnly
- whether the ClientConsumer will only browse the queue or consume messages.HornetQException
- if an exception occurs while creating the ClientConsumerClientConsumer createConsumer(String queueName, String filter, int windowSize, int maxRate, boolean browseOnly) throws HornetQException
browseOnly
is true
, the ClientConsumer will receive the messages from the queue
but they will not be consumed (the messages will remain in the queue).
If browseOnly
is false
, the ClientConsumer will behave like consume the messages from the queue and
the messages will effectively be removed from the queue.queueName
- name of the queue to consume messages fromfilter
- only messages which match this filter will be consumedwindowSize
- the consumer window sizemaxRate
- the maximum rate to consume messagesbrowseOnly
- whether the ClientConsumer will only browse the queue or consume messages.HornetQException
- if an exception occurs while creating the ClientConsumerClientProducer createProducer() throws HornetQException
HornetQException
ClientProducer.send(SimpleString, org.hornetq.api.core.Message)
ClientProducer createProducer(SimpleString address) throws HornetQException
address
- the address to send messages toHornetQException
- if an exception occurs while creating the ClientProducerClientProducer createProducer(String address) throws HornetQException
address
- the address to send messages toHornetQException
- if an exception occurs while creating the ClientProducerClientProducer createProducer(SimpleString address, int rate) throws HornetQException
address
- the address to send messages torate
- the producer rateHornetQException
- if an exception occurs while creating the ClientProducerClientMessage createMessage(boolean durable)
durable
- whether the created message is durable or notClientMessage createMessage(byte type, boolean durable)
type
- type of the messagedurable
- whether the created message is durable or notClientMessage createMessage(byte type, boolean durable, long expiration, long timestamp, byte priority)
type
- type of the messagedurable
- whether the created message is durable or notexpiration
- the message expirationtimestamp
- the message timestamppriority
- the message priority (between 0 and 9 inclusive)ClientSession.QueueQuery queueQuery(SimpleString queueName) throws HornetQException
queueName
- the name of the queue to queryHornetQException
- if an exception occurs while querying the queueClientSession.BindingQuery bindingQuery(SimpleString address) throws HornetQException
address
- the address of the biding to queryHornetQException
- if an exception occurs while querying the bindingXAResource getXAResource()
boolean isXA()
true
if the session supports XA, false
else.true
if the session supports XA, false
else.void commit() throws HornetQException
HornetQException
- if an exception occurs while committing the transactionvoid rollback() throws HornetQException
HornetQException
- if an exception occurs while rolling back the transactionvoid rollback(boolean considerLastMessageAsDelivered) throws HornetQException
considerLastMessageAsDelivered
- the first message on deliveringMessage Buffer is considered as deliveredHornetQException
- if an exception occurs while rolling back the transactionboolean isRollbackOnly()
true
if the current transaction has been flagged to rollback, false
else.true
if the current transaction has been flagged to rollback, false
else.boolean isAutoCommitSends()
false
elsetrue
if the session automatically commit its transaction every time a message is sent, false
elseboolean isAutoCommitAcks()
false
elsetrue
if the session automatically commit its transaction every time a message is acknowledged, false
elseboolean isBlockOnAcknowledge()
true
if the session's ClientConsumer block when they acknowledge a message, false
elsevoid setSendAcknowledgementHandler(SendAcknowledgementHandler handler)
SendAcknowledgementHandler
for this session.handler
- a SendAcknowledgementHandlervoid addMetaData(String key, String data) throws HornetQException
HornetQException
void addUniqueMetaData(String key, String data) throws HornetQException
HornetQException
void addMetaDataV1(String key, String data) throws HornetQException
addMetaData(String, String)
HornetQException
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.