org.jboss.messaging.core.client
Interface ClientSession

All Superinterfaces:

javax.transaction.xa.XAResource

All Known Subinterfaces:

ClientSessionInternal

All Known Implementing Classes:

ClientSessionImpl

public interface ClientSession
extends javax.transaction.xa.XAResource

Author:

Tim Fox, Clebert Suconic

Field Summary

Fields inherited from interface javax.transaction.xa.XAResource

TMENDRSCAN, TMFAIL, TMJOIN, TMNOFLAGS, TMONEPHASE, TMRESUME, TMSTARTRSCAN, TMSUCCESS, TMSUSPEND, XA_OK, XA_RDONLY

Method Summary

void	acknowledge()
void	addDestination(SimpleString address, boolean temporary)
SessionBindingQueryResponseMessage	bindingQuery(SimpleString address)
void	close()
void	commit()
ClientBrowser	createBrowser(SimpleString queueName)
ClientBrowser	createBrowser(SimpleString queueName, SimpleString filterString)
ClientConsumer	createConsumer(SimpleString queueName)
ClientConsumer	createConsumer(SimpleString queueName, SimpleString filterString, boolean noLocal, boolean autoDeleteQueue, boolean direct)
ClientProducer	createProducer(SimpleString address)
ClientProducer	createProducerWithWindowSize(SimpleString address, int windowSize)
void	createQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable, boolean temporary)
ClientProducer	createRateLimitedProducer(SimpleString address, int rate)
void	deleteQueue(SimpleString queueName)
int	getLazyAckBatchSize()
javax.transaction.xa.XAResource	getXAResource()
boolean	isAutoCommitAcks()
boolean	isAutoCommitSends()
boolean	isClosed()
SessionQueueQueryResponseMessage	queueQuery(SimpleString queueName)
void	removeDestination(SimpleString address, boolean temporary)
void	rollback()

Methods inherited from interface javax.transaction.xa.XAResource

commit, end, forget, getTransactionTimeout, isSameRM, prepare, recover, rollback, setTransactionTimeout, start

Method Detail

createQueue

void createQueue(SimpleString address,
                 SimpleString queueName,
                 SimpleString filterString,
                 boolean durable,
                 boolean temporary)
                 throws MessagingException

Throws:

MessagingException

deleteQueue

void deleteQueue(SimpleString queueName)
                 throws MessagingException

Throws:

MessagingException

addDestination

void addDestination(SimpleString address,
                    boolean temporary)
                    throws MessagingException

Throws:

MessagingException

removeDestination

void removeDestination(SimpleString address,
                       boolean temporary)
                       throws MessagingException

Throws:

MessagingException

queueQuery

SessionQueueQueryResponseMessage queueQuery(SimpleString queueName)
                                            throws MessagingException

Throws:

MessagingException

bindingQuery

SessionBindingQueryResponseMessage bindingQuery(SimpleString address)
                                                throws MessagingException

Throws:

MessagingException

createConsumer

ClientConsumer createConsumer(SimpleString queueName,
                              SimpleString filterString,
                              boolean noLocal,
                              boolean autoDeleteQueue,
                              boolean direct)
                              throws MessagingException

Throws:

MessagingException

createConsumer

ClientConsumer createConsumer(SimpleString queueName)
                              throws MessagingException

Throws:

MessagingException

createBrowser

ClientBrowser createBrowser(SimpleString queueName,
                            SimpleString filterString)
                            throws MessagingException

Throws:

MessagingException

createBrowser

ClientBrowser createBrowser(SimpleString queueName)
                            throws MessagingException

Throws:

MessagingException

createProducer

ClientProducer createProducer(SimpleString address)
                              throws MessagingException

Throws:

MessagingException

createRateLimitedProducer

ClientProducer createRateLimitedProducer(SimpleString address,
                                         int rate)
                                         throws MessagingException

Throws:

MessagingException

createProducerWithWindowSize

ClientProducer createProducerWithWindowSize(SimpleString address,
                                            int windowSize)
                                            throws MessagingException

Throws:

MessagingException

getXAResource

javax.transaction.xa.XAResource getXAResource()

commit

void commit()
            throws MessagingException

Throws:

MessagingException

rollback

void rollback()
              throws MessagingException

Throws:

MessagingException

acknowledge

void acknowledge()
                 throws MessagingException

Throws:

MessagingException

close

void close()
           throws MessagingException

Throws:

MessagingException

isClosed

boolean isClosed()

isAutoCommitSends

boolean isAutoCommitSends()

isAutoCommitAcks

boolean isAutoCommitAcks()

getLazyAckBatchSize

int getLazyAckBatchSize()