public class DelegatingSession extends Object implements ClientSessionInternal
ClientSession.BindingQuery, ClientSession.QueueQuery
Modifier and Type | Field and Description |
---|---|
static boolean |
debug |
TMENDRSCAN, TMFAIL, TMJOIN, TMNOFLAGS, TMONEPHASE, TMRESUME, TMSTARTRSCAN, TMSUCCESS, TMSUSPEND, XA_OK, XA_RDONLY
Constructor and Description |
---|
DelegatingSession(ClientSessionInternal session) |
Modifier and Type | Method and Description |
---|---|
void |
acknowledge(long consumerID,
long messageID) |
void |
addConsumer(ClientConsumerInternal consumer) |
void |
addFailoverListener(FailoverEventListener listener)
Adds a FailoverEventListener to the session which is notified if a failover event occurs on the session.
|
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 |
addProducer(ClientProducerInternal producer) |
void |
addUniqueMetaData(String key,
String data)
Attach any metadata to the session.
|
ClientSession.BindingQuery |
bindingQuery(SimpleString address)
Queries information on a binding.
|
void |
cleanUp(boolean failingOver) |
void |
close()
Closes the session.
|
void |
commit()
Commits the current transaction.
|
void |
commit(Xid xid,
boolean onePhase) |
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 filterString)
Creates a ClientConsumer to consume messages matching the filter from the queue with the given name.
|
ClientConsumer |
createConsumer(SimpleString queueName,
SimpleString filterString,
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 filterString,
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 filterString)
Creates a ClientConsumer to consume messages matching the filter from the queue with the given name.
|
ClientConsumer |
createConsumer(String queueName,
String filterString,
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 filterString,
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 filterString,
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 filterString,
boolean durable)
Creates a non-temporaryqueue.
|
void |
createSharedQueue(SimpleString address,
SimpleString queueName,
boolean durable)
Creates a transient queue.
|
void |
createSharedQueue(SimpleString address,
SimpleString queueName,
SimpleString filter,
boolean durable)
Creates a transient queue.
|
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.
|
static void |
dumpSessionCreationStacks() |
void |
end(Xid xid,
int flags) |
void |
endCall() |
void |
expire(long consumerID,
long messageID) |
protected void |
finalize() |
void |
forceDelivery(long consumerID,
long sequence) |
void |
forget(Xid xid) |
Channel |
getChannel() |
RemotingConnection |
getConnection() |
ClientProducerCredits |
getCredits(SimpleString address,
boolean anon) |
ClientSessionInternal |
getInternalSession() |
int |
getMinLargeMessageSize() |
String |
getName() |
ClientProducerCreditManager |
getProducerCreditManager() |
ClientSessionFactoryInternal |
getSessionFactory() |
int |
getTransactionTimeout() |
int |
getVersion()
Returns the server's incrementingVersion.
|
XAResource |
getXAResource()
Returns the XAResource associated to the session.
|
void |
handleConsumerDisconnect(long consumerID) |
void |
handleFailover(CoreRemotingConnection backupConnection) |
void |
handleReceiveContinuation(long consumerID,
SessionReceiveContinuationMessage continuation) |
void |
handleReceiveLargeMessage(long consumerID,
SessionReceiveLargeMessage message) |
void |
handleReceiveMessage(long consumerID,
SessionReceiveMessage message) |
void |
handleReceiveProducerCredits(SimpleString address,
int credits) |
void |
handleReceiveProducerFailCredits(SimpleString address,
int credits) |
void |
individualAcknowledge(long consumerID,
long messageID) |
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 |
isCacheLargeMessageClient() |
boolean |
isClosed()
Returns whether the session is closed or not.
|
boolean |
isCompressLargeMessages() |
boolean |
isConfirmationWindowEnabled() |
boolean |
isRollbackOnly()
Returns
true if the current transaction has been flagged to rollback, false else. |
boolean |
isSameRM(XAResource xares) |
boolean |
isXA()
Return
true if the session supports XA, false else. |
void |
preHandleFailover(CoreRemotingConnection connection) |
int |
prepare(Xid xid) |
ClientSession.QueueQuery |
queueQuery(SimpleString queueName)
Queries information on a queue.
|
Xid[] |
recover(int flag) |
void |
removeConsumer(ClientConsumerInternal consumer) |
boolean |
removeFailoverListener(FailoverEventListener listener)
Removes a FailoverEventListener to the session.
|
boolean |
removeFailureListener(SessionFailureListener listener)
Removes a FailureListener to the session.
|
void |
removeProducer(ClientProducerInternal producer) |
void |
resetIfNeeded() |
void |
returnBlocking() |
void |
returnCredits(SimpleString address) |
void |
rollback()
Rolls back the current transaction.
|
void |
rollback(boolean considerLastMessageAsDelivered)
Rolls back the current transaction.
|
void |
rollback(Xid xid) |
void |
scheduleConfirmation(SendAcknowledgementHandler handler,
Message msg) |
void |
sendProducerCreditsMessage(int credits,
SimpleString address) |
void |
setAddress(Message message,
SimpleString address) |
void |
setForceNotSameRM(boolean force) |
void |
setPacketSize(int packetSize) |
void |
setSendAcknowledgementHandler(SendAcknowledgementHandler handler)
Sets a
SendAcknowledgementHandler for this session. |
void |
setStopSignal()
Sets a stop signal to true.
|
boolean |
setTransactionTimeout(int seconds) |
void |
start()
Starts the session.
|
void |
start(Xid xid,
int flags) |
void |
startCall()
This is used internally to control and educate the user
about using the thread boundaries properly.
|
void |
stop()
Stops the session.
|
String |
toString() |
void |
workDone() |
public DelegatingSession(ClientSessionInternal session)
public static void dumpSessionCreationStacks()
public ClientSessionInternal getInternalSession()
protected void finalize() throws Throwable
public void acknowledge(long consumerID, long messageID) throws HornetQException
acknowledge
in interface ClientSessionInternal
HornetQException
public void individualAcknowledge(long consumerID, long messageID) throws HornetQException
individualAcknowledge
in interface ClientSessionInternal
HornetQException
public void addConsumer(ClientConsumerInternal consumer)
addConsumer
in interface ClientSessionInternal
public void addFailureListener(SessionFailureListener listener)
ClientSession
addFailureListener
in interface ClientSession
listener
- the listener to addpublic void addFailoverListener(FailoverEventListener listener)
ClientSession
addFailoverListener
in interface ClientSession
listener
- the listener to addpublic void addProducer(ClientProducerInternal producer)
addProducer
in interface ClientSessionInternal
public ClientSession.BindingQuery bindingQuery(SimpleString address) throws HornetQException
ClientSession
bindingQuery
in interface ClientSession
address
- the address of the biding to queryHornetQException
- if an exception occurs while querying the bindingpublic void forceDelivery(long consumerID, long sequence) throws HornetQException
forceDelivery
in interface ClientSessionInternal
HornetQException
public void cleanUp(boolean failingOver) throws HornetQException
cleanUp
in interface ClientSessionInternal
HornetQException
public void close() throws HornetQException
ClientSession
close
in interface AutoCloseable
close
in interface ClientSession
HornetQException
- if an exception occurs while closing the sessionpublic void commit() throws HornetQException
ClientSession
commit
in interface ClientSession
HornetQException
- if an exception occurs while committing the transactionpublic void commit(Xid xid, boolean onePhase) throws XAException
commit
in interface XAResource
XAException
public ClientMessage createMessage(boolean durable)
ClientSession
createMessage
in interface ClientSession
durable
- whether the created message is durable or notpublic ClientMessage createMessage(byte type, boolean durable, long expiration, long timestamp, byte priority)
ClientSession
createMessage
in interface ClientSession
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)public ClientMessage createMessage(byte type, boolean durable)
ClientSession
createMessage
in interface ClientSession
type
- type of the messagedurable
- whether the created message is durable or notpublic ClientConsumer createConsumer(SimpleString queueName, SimpleString filterString, boolean browseOnly) throws HornetQException
ClientSession
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). Note
that paged messages will not be in the queue, and will therefore not be visible if
browseOnly
is true
.
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.createConsumer
in interface ClientSession
queueName
- name of the queue to consume messages fromfilterString
- 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 ClientConsumerpublic ClientConsumer createConsumer(SimpleString queueName, SimpleString filterString, int windowSize, int maxRate, boolean browseOnly) throws HornetQException
ClientSession
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). Note
that paged messages will not be in the queue, and will therefore not be visible if
browseOnly
is true
.
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.createConsumer
in interface ClientSession
queueName
- name of the queue to consume messages fromfilterString
- 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 ClientConsumerpublic ClientConsumer createConsumer(SimpleString queueName, SimpleString filterString) throws HornetQException
ClientSession
createConsumer
in interface ClientSession
queueName
- name of the queue to consume messages fromfilterString
- only messages which match this filter will be consumedHornetQException
- if an exception occurs while creating the ClientConsumerpublic ClientConsumer createConsumer(SimpleString queueName) throws HornetQException
ClientSession
createConsumer
in interface ClientSession
queueName
- name of the queue to consume messages fromHornetQException
- if an exception occurs while creating the ClientConsumerpublic ClientConsumer createConsumer(String queueName, String filterString, boolean browseOnly) throws HornetQException
ClientSession
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). Note
that paged messages will not be in the queue, and will therefore not be visible if
browseOnly
is true
.
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.createConsumer
in interface ClientSession
queueName
- name of the queue to consume messages fromfilterString
- 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 ClientConsumerpublic ClientConsumer createConsumer(String queueName, String filterString, int windowSize, int maxRate, boolean browseOnly) throws HornetQException
ClientSession
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). Note
that paged messages will not be in the queue, and will therefore not be visible if
browseOnly
is true
.
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.createConsumer
in interface ClientSession
queueName
- name of the queue to consume messages fromfilterString
- 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 ClientConsumerpublic ClientConsumer createConsumer(String queueName, String filterString) throws HornetQException
ClientSession
createConsumer
in interface ClientSession
queueName
- name of the queue to consume messages fromfilterString
- only messages which match this filter will be consumedHornetQException
- if an exception occurs while creating the ClientConsumerpublic ClientConsumer createConsumer(String queueName) throws HornetQException
ClientSession
createConsumer
in interface ClientSession
queueName
- name of the queue to consume messages fromHornetQException
- if an exception occurs while creating the ClientConsumerpublic ClientConsumer createConsumer(SimpleString queueName, boolean browseOnly) throws HornetQException
ClientSession
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). Note
that paged messages will not be in the queue, and will therefore not be visible if
browseOnly
is true
.
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.createConsumer
in interface ClientSession
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 ClientConsumerpublic ClientConsumer createConsumer(String queueName, boolean browseOnly) throws HornetQException
ClientSession
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). Note
that paged messages will not be in the queue, and will therefore not be visible if
browseOnly
is true
.
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.createConsumer
in interface ClientSession
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 ClientConsumerpublic ClientProducer createProducer() throws HornetQException
ClientSession
createProducer
in interface ClientSession
HornetQException
ClientProducer.send(SimpleString, org.hornetq.api.core.Message)
public ClientProducer createProducer(SimpleString address, int rate) throws HornetQException
ClientSession
createProducer
in interface ClientSession
address
- the address to send messages torate
- the producer rateHornetQException
- if an exception occurs while creating the ClientProducerpublic ClientProducer createProducer(SimpleString address) throws HornetQException
ClientSession
createProducer
in interface ClientSession
address
- the address to send messages toHornetQException
- if an exception occurs while creating the ClientProducerpublic ClientProducer createProducer(String address) throws HornetQException
ClientSession
createProducer
in interface ClientSession
address
- the address to send messages toHornetQException
- if an exception occurs while creating the ClientProducerpublic void createQueue(String address, String queueName) throws HornetQException
ClientSession
createQueue
in interface ClientSession
address
- the queue will be bound to this addressqueueName
- the name of the queueHornetQException
- in an exception occurs while creating the queuepublic void createQueue(SimpleString address, SimpleString queueName) throws HornetQException
ClientSession
createQueue
in interface ClientSession
address
- the queue will be bound to this addressqueueName
- the name of the queueHornetQException
- in an exception occurs while creating the queuepublic void createQueue(SimpleString address, SimpleString queueName, boolean durable) throws HornetQException
ClientSession
createQueue
in interface ClientSession
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 queuepublic void createSharedQueue(SimpleString address, SimpleString queueName, boolean durable) throws HornetQException
ClientSession
createSharedQueue
in interface ClientSession
address
- the queue will be bound to this addressqueueName
- the name of the queuedurable
- if the queue is durableHornetQException
- in an exception occurs while creating the queuepublic void createSharedQueue(SimpleString address, SimpleString queueName, SimpleString filter, boolean durable) throws HornetQException
ClientSession
createSharedQueue
in interface ClientSession
address
- the queue will be bound to this addressqueueName
- the name of the queuefilter
- whether the queue is durable or notdurable
- if the queue is durableHornetQException
- in an exception occurs while creating the queuepublic void createQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable) throws HornetQException
ClientSession
createQueue
in interface ClientSession
address
- the queue will be bound to this addressqueueName
- the name of the queuefilterString
- only messages which match this filter will be put in the queuedurable
- whether the queue is durable or notHornetQException
- in an exception occurs while creating the queuepublic void createQueue(String address, String queueName, boolean durable) throws HornetQException
ClientSession
createQueue
in interface ClientSession
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 queuepublic void createQueue(String address, String queueName, String filterString, boolean durable) throws HornetQException
ClientSession
createQueue
in interface ClientSession
address
- the queue will be bound to this addressqueueName
- the name of the queuefilterString
- only messages which match this filter will be put in the queuedurable
- whether the queue is durable or notHornetQException
- in an exception occurs while creating the queuepublic void createTemporaryQueue(SimpleString address, SimpleString queueName, SimpleString filter) throws HornetQException
ClientSession
createTemporaryQueue
in interface ClientSession
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 queuepublic void createTemporaryQueue(SimpleString address, SimpleString queueName) throws HornetQException
ClientSession
createTemporaryQueue
in interface ClientSession
address
- the queue will be bound to this addressqueueName
- the name of the queueHornetQException
- in an exception occurs while creating the queuepublic void createTemporaryQueue(String address, String queueName, String filter) throws HornetQException
ClientSession
createTemporaryQueue
in interface ClientSession
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 queuepublic void createTemporaryQueue(String address, String queueName) throws HornetQException
ClientSession
createTemporaryQueue
in interface ClientSession
address
- the queue will be bound to this addressqueueName
- the name of the queueHornetQException
- in an exception occurs while creating the queuepublic void deleteQueue(SimpleString queueName) throws HornetQException
ClientSession
deleteQueue
in interface ClientSession
queueName
- the name of the queue to deleteHornetQException
- if there is no queue for the given name or if the queue has consumerspublic void deleteQueue(String queueName) throws HornetQException
ClientSession
deleteQueue
in interface ClientSession
queueName
- the name of the queue to deleteHornetQException
- if there is no queue for the given name or if the queue has consumerspublic void end(Xid xid, int flags) throws XAException
end
in interface XAResource
XAException
public void expire(long consumerID, long messageID) throws HornetQException
expire
in interface ClientSessionInternal
HornetQException
public void forget(Xid xid) throws XAException
forget
in interface XAResource
XAException
public RemotingConnection getConnection()
getConnection
in interface ClientSessionInternal
public int getMinLargeMessageSize()
getMinLargeMessageSize
in interface ClientSessionInternal
public String getName()
getName
in interface ClientSessionInternal
public int getTransactionTimeout() throws XAException
getTransactionTimeout
in interface XAResource
XAException
public int getVersion()
ClientSession
getVersion
in interface ClientSession
incrementingVersion
public XAResource getXAResource()
ClientSession
getXAResource
in interface ClientSession
public void preHandleFailover(CoreRemotingConnection connection)
preHandleFailover
in interface ClientSessionInternal
public void handleFailover(CoreRemotingConnection backupConnection)
handleFailover
in interface ClientSessionInternal
public void handleReceiveContinuation(long consumerID, SessionReceiveContinuationMessage continuation) throws Exception
handleReceiveContinuation
in interface ClientSessionInternal
Exception
public void handleReceiveLargeMessage(long consumerID, SessionReceiveLargeMessage message) throws Exception
handleReceiveLargeMessage
in interface ClientSessionInternal
Exception
public void handleReceiveMessage(long consumerID, SessionReceiveMessage message) throws Exception
handleReceiveMessage
in interface ClientSessionInternal
Exception
public void handleConsumerDisconnect(long consumerID) throws HornetQException
handleConsumerDisconnect
in interface ClientSessionInternal
HornetQException
public boolean isAutoCommitAcks()
ClientSession
false
elseisAutoCommitAcks
in interface ClientSession
true
if the session automatically commit its transaction every time a message is acknowledged, false
elsepublic boolean isAutoCommitSends()
ClientSession
false
elseisAutoCommitSends
in interface ClientSession
true
if the session automatically commit its transaction every time a message is sent, false
elsepublic boolean isBlockOnAcknowledge()
ClientSession
isBlockOnAcknowledge
in interface ClientSession
true
if the session's ClientConsumer block when they acknowledge a message, false
elsepublic boolean isCacheLargeMessageClient()
isCacheLargeMessageClient
in interface ClientSessionInternal
public boolean isClosed()
ClientSession
isClosed
in interface ClientSession
true
if the session is closed, false
elsepublic boolean isSameRM(XAResource xares) throws XAException
isSameRM
in interface XAResource
XAException
public boolean isXA()
ClientSession
true
if the session supports XA, false
else.isXA
in interface ClientSession
true
if the session supports XA, false
else.public int prepare(Xid xid) throws XAException
prepare
in interface XAResource
XAException
public ClientSession.QueueQuery queueQuery(SimpleString queueName) throws HornetQException
ClientSession
queueQuery
in interface ClientSession
queueName
- the name of the queue to queryHornetQException
- if an exception occurs while querying the queuepublic Xid[] recover(int flag) throws XAException
recover
in interface XAResource
XAException
public void removeConsumer(ClientConsumerInternal consumer) throws HornetQException
removeConsumer
in interface ClientSessionInternal
HornetQException
public boolean removeFailureListener(SessionFailureListener listener)
ClientSession
removeFailureListener
in interface ClientSession
listener
- the listener to removetrue
if the listener was removed, false
elsepublic boolean removeFailoverListener(FailoverEventListener listener)
ClientSession
removeFailoverListener
in interface ClientSession
listener
- the listener to removetrue
if the listener was removed, false
elsepublic void removeProducer(ClientProducerInternal producer)
removeProducer
in interface ClientSessionInternal
public void returnBlocking()
returnBlocking
in interface ClientSessionInternal
public void rollback() throws HornetQException
ClientSession
rollback
in interface ClientSession
HornetQException
- if an exception occurs while rolling back the transactionpublic boolean isRollbackOnly()
ClientSession
true
if the current transaction has been flagged to rollback, false
else.isRollbackOnly
in interface ClientSession
true
if the current transaction has been flagged to rollback, false
else.public void rollback(boolean considerLastMessageAsDelivered) throws HornetQException
ClientSession
rollback
in interface ClientSession
considerLastMessageAsDelivered
- the first message on deliveringMessage Buffer is considered as deliveredHornetQException
- if an exception occurs while rolling back the transactionpublic void rollback(Xid xid) throws XAException
rollback
in interface XAResource
XAException
public void setSendAcknowledgementHandler(SendAcknowledgementHandler handler)
ClientSession
SendAcknowledgementHandler
for this session.setSendAcknowledgementHandler
in interface ClientSession
handler
- a SendAcknowledgementHandlerpublic boolean setTransactionTimeout(int seconds) throws XAException
setTransactionTimeout
in interface XAResource
XAException
public void resetIfNeeded() throws HornetQException
resetIfNeeded
in interface ClientSessionInternal
HornetQException
public void start() throws HornetQException
ClientSession
start
in interface ClientSession
HornetQException
- if an exception occurs while starting the sessionpublic void start(Xid xid, int flags) throws XAException
start
in interface XAResource
XAException
public void stop() throws HornetQException
ClientSession
stop
in interface ClientSession
HornetQException
- if an exception occurs while stopping the sessionpublic ClientSessionFactoryInternal getSessionFactory()
getSessionFactory
in interface ClientSessionInternal
public void setForceNotSameRM(boolean force)
setForceNotSameRM
in interface ClientSessionInternal
public void workDone()
workDone
in interface ClientSessionInternal
public void sendProducerCreditsMessage(int credits, SimpleString address)
sendProducerCreditsMessage
in interface ClientSessionInternal
public ClientProducerCredits getCredits(SimpleString address, boolean anon)
getCredits
in interface ClientSessionInternal
public void returnCredits(SimpleString address)
returnCredits
in interface ClientSessionInternal
public void handleReceiveProducerCredits(SimpleString address, int credits)
handleReceiveProducerCredits
in interface ClientSessionInternal
public void handleReceiveProducerFailCredits(SimpleString address, int credits)
handleReceiveProducerFailCredits
in interface ClientSessionInternal
public ClientProducerCreditManager getProducerCreditManager()
getProducerCreditManager
in interface ClientSessionInternal
public void setAddress(Message message, SimpleString address)
setAddress
in interface ClientSessionInternal
public void setPacketSize(int packetSize)
setPacketSize
in interface ClientSessionInternal
public void addMetaData(String key, String data) throws HornetQException
ClientSession
addMetaData
in interface ClientSession
HornetQException
public boolean isCompressLargeMessages()
isCompressLargeMessages
in interface ClientSessionInternal
public Channel getChannel()
getChannel
in interface ClientSessionInternal
public void addUniqueMetaData(String key, String data) throws HornetQException
ClientSession
addUniqueMetaData
in interface ClientSession
HornetQException
public void startCall()
ClientSessionInternal
startCall
in interface ClientSessionInternal
public void endCall()
endCall
in interface ClientSessionInternal
ClientSessionInternal.startCall()
public void setStopSignal()
ClientSessionInternal
setStopSignal
in interface ClientSessionInternal
public boolean isConfirmationWindowEnabled()
isConfirmationWindowEnabled
in interface ClientSessionInternal
public void scheduleConfirmation(SendAcknowledgementHandler handler, Message msg)
scheduleConfirmation
in interface ClientSessionInternal
Copyright © 2014 JBoss, a division of Red Hat. All rights reserved.