org.jboss.messaging.core.client.impl
Class ClientSessionImpl

java.lang.Object
  org.jboss.messaging.core.client.impl.ClientSessionImpl

All Implemented Interfaces:

javax.transaction.xa.XAResource, ClientSession, ClientSessionInternal

public class ClientSessionImpl
extends java.lang.Object
implements ClientSessionInternal

Version:

$Revision: 3603 $ $Id: ClientSessionImpl.java 3603 2008-01-21 18:49:20Z timfox $

Author:

Tim Fox, Ovidiu Feodorov, Clebert Suconic, Jeff Mesnil

Field Summary

Fields inherited from interface javax.transaction.xa.XAResource

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

Constructor Summary

ClientSessionImpl(ClientConnectionInternal connection, long serverTargetID, int lazyAckBatchSize, boolean cacheProducers, boolean autoCommitSends, boolean autoCommitAcks, boolean blockOnAcknowledge, boolean sendNonPersistentMessagesBlocking, boolean sendPersistentMessagesBlocking, int defaultConsumerWindowSize, int defaultConsumerMaxRate, int defaultProducerWindowSize, int defaultProducerMaxRate)

Method Summary

void	acknowledge()
void	addDestination(SimpleString address, boolean temporary)
SessionBindingQueryResponseMessage	bindingQuery(SimpleString address)
void	close()
void	commit()
void	commit(javax.transaction.xa.Xid xid, boolean onePhase)
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	createProducer(SimpleString address, int windowSize, int maxRate)
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)
void	delivered(long deliverID, boolean expired)
void	end(javax.transaction.xa.Xid xid, int flags)
void	forget(javax.transaction.xa.Xid xid)
ClientConnectionInternal	getConnection()
int	getLazyAckBatchSize()
long	getServerTargetID()
int	getTransactionTimeout()
javax.transaction.xa.XAResource	getXAResource()
boolean	isAutoCommitAcks()
boolean	isAutoCommitSends()
boolean	isClosed()
boolean	isSameRM(javax.transaction.xa.XAResource xares)
int	prepare(javax.transaction.xa.Xid xid)
SessionQueueQueryResponseMessage	queueQuery(SimpleString queueName)
javax.transaction.xa.Xid[]	recover(int flag)
void	removeBrowser(ClientBrowser browser)
void	removeConsumer(ClientConsumerInternal consumer)
void	removeDestination(SimpleString address, boolean temporary)
void	removeProducer(ClientProducerInternal producer)
void	rollback()
void	rollback(javax.transaction.xa.Xid xid)
void	setForceNotSameRM(boolean force)
boolean	setTransactionTimeout(int seconds)
void	start(javax.transaction.xa.Xid xid, int flags)

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientSessionImpl

public ClientSessionImpl(ClientConnectionInternal connection,
                         long serverTargetID,
                         int lazyAckBatchSize,
                         boolean cacheProducers,
                         boolean autoCommitSends,
                         boolean autoCommitAcks,
                         boolean blockOnAcknowledge,
                         boolean sendNonPersistentMessagesBlocking,
                         boolean sendPersistentMessagesBlocking,
                         int defaultConsumerWindowSize,
                         int defaultConsumerMaxRate,
                         int defaultProducerWindowSize,
                         int defaultProducerMaxRate)
                  throws MessagingException

Throws:

MessagingException

Method Detail

createQueue

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

Specified by:

createQueue in interface ClientSession

Throws:

MessagingException

deleteQueue

public void deleteQueue(SimpleString queueName)
                 throws MessagingException

Specified by:

deleteQueue in interface ClientSession

Throws:

MessagingException

queueQuery

public SessionQueueQueryResponseMessage queueQuery(SimpleString queueName)
                                            throws MessagingException

Specified by:

queueQuery in interface ClientSession

Throws:

MessagingException

bindingQuery

public SessionBindingQueryResponseMessage bindingQuery(SimpleString address)
                                                throws MessagingException

Specified by:

bindingQuery in interface ClientSession

Throws:

MessagingException

addDestination

public void addDestination(SimpleString address,
                           boolean temporary)
                    throws MessagingException

Specified by:

addDestination in interface ClientSession

Throws:

MessagingException

removeDestination

public void removeDestination(SimpleString address,
                              boolean temporary)
                       throws MessagingException

Specified by:

removeDestination in interface ClientSession

Throws:

MessagingException

createConsumer

public ClientConsumer createConsumer(SimpleString queueName)
                              throws MessagingException

Specified by:

createConsumer in interface ClientSession

Throws:

MessagingException

createConsumer

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

Specified by:

createConsumer in interface ClientSession

Throws:

MessagingException

createBrowser

public ClientBrowser createBrowser(SimpleString queueName)
                            throws MessagingException

Specified by:

createBrowser in interface ClientSession

Throws:

MessagingException

createBrowser

public ClientBrowser createBrowser(SimpleString queueName,
                                   SimpleString filterString)
                            throws MessagingException

Specified by:

createBrowser in interface ClientSession

Throws:

MessagingException

createProducer

public ClientProducer createProducer(SimpleString address)
                              throws MessagingException

Specified by:

createProducer in interface ClientSession

Throws:

MessagingException

createProducer

public ClientProducer createProducer(SimpleString address,
                                     int windowSize,
                                     int maxRate)
                              throws MessagingException

Throws:

MessagingException

createRateLimitedProducer

public ClientProducer createRateLimitedProducer(SimpleString address,
                                                int rate)
                                         throws MessagingException

Specified by:

createRateLimitedProducer in interface ClientSession

Throws:

MessagingException

createProducerWithWindowSize

public ClientProducer createProducerWithWindowSize(SimpleString address,
                                                   int windowSize)
                                            throws MessagingException

Specified by:

createProducerWithWindowSize in interface ClientSession

Throws:

MessagingException

getXAResource

public javax.transaction.xa.XAResource getXAResource()

Specified by:

getXAResource in interface ClientSession

commit

public void commit()
            throws MessagingException

Specified by:

commit in interface ClientSession

Throws:

MessagingException

rollback

public void rollback()
              throws MessagingException

Specified by:

rollback in interface ClientSession

Throws:

MessagingException

acknowledge

public void acknowledge()
                 throws MessagingException

Specified by:

acknowledge in interface ClientSession

Throws:

MessagingException

close

public void close()
           throws MessagingException

Specified by:

close in interface ClientSession

Throws:

MessagingException

isClosed

public boolean isClosed()

Specified by:

isClosed in interface ClientSession

isAutoCommitSends

public boolean isAutoCommitSends()

Specified by:

isAutoCommitSends in interface ClientSession

isAutoCommitAcks

public boolean isAutoCommitAcks()

Specified by:

isAutoCommitAcks in interface ClientSession

getLazyAckBatchSize

public int getLazyAckBatchSize()

Specified by:

getLazyAckBatchSize in interface ClientSession

getServerTargetID

public long getServerTargetID()

Specified by:

getServerTargetID in interface ClientSessionInternal

getConnection

public ClientConnectionInternal getConnection()

Specified by:

getConnection in interface ClientSessionInternal

delivered

public void delivered(long deliverID,
                      boolean expired)

Specified by:

delivered in interface ClientSessionInternal

removeConsumer

public void removeConsumer(ClientConsumerInternal consumer)
                    throws MessagingException

Specified by:

removeConsumer in interface ClientSessionInternal

Throws:

MessagingException

removeProducer

public void removeProducer(ClientProducerInternal producer)

Specified by:

removeProducer in interface ClientSessionInternal

removeBrowser

public void removeBrowser(ClientBrowser browser)

Specified by:

removeBrowser in interface ClientSessionInternal

commit

public void commit(javax.transaction.xa.Xid xid,
                   boolean onePhase)
            throws javax.transaction.xa.XAException

Specified by:

commit in interface javax.transaction.xa.XAResource

Throws:

javax.transaction.xa.XAException

end

public void end(javax.transaction.xa.Xid xid,
                int flags)
         throws javax.transaction.xa.XAException

Specified by:

end in interface javax.transaction.xa.XAResource

Throws:

javax.transaction.xa.XAException

forget

public void forget(javax.transaction.xa.Xid xid)
            throws javax.transaction.xa.XAException

Specified by:

forget in interface javax.transaction.xa.XAResource

Throws:

javax.transaction.xa.XAException

getTransactionTimeout

public int getTransactionTimeout()
                          throws javax.transaction.xa.XAException

Specified by:

getTransactionTimeout in interface javax.transaction.xa.XAResource

Throws:

javax.transaction.xa.XAException

isSameRM

public boolean isSameRM(javax.transaction.xa.XAResource xares)
                 throws javax.transaction.xa.XAException

Specified by:

isSameRM in interface javax.transaction.xa.XAResource

Throws:

javax.transaction.xa.XAException

prepare

public int prepare(javax.transaction.xa.Xid xid)
            throws javax.transaction.xa.XAException

Specified by:

prepare in interface javax.transaction.xa.XAResource

Throws:

javax.transaction.xa.XAException

recover

public javax.transaction.xa.Xid[] recover(int flag)
                                   throws javax.transaction.xa.XAException

Specified by:

recover in interface javax.transaction.xa.XAResource

Throws:

javax.transaction.xa.XAException

rollback

public void rollback(javax.transaction.xa.Xid xid)
              throws javax.transaction.xa.XAException

Specified by:

rollback in interface javax.transaction.xa.XAResource

Throws:

javax.transaction.xa.XAException

setTransactionTimeout

public boolean setTransactionTimeout(int seconds)
                              throws javax.transaction.xa.XAException

Specified by:

setTransactionTimeout in interface javax.transaction.xa.XAResource

Throws:

javax.transaction.xa.XAException

start

public void start(javax.transaction.xa.Xid xid,
                  int flags)
           throws javax.transaction.xa.XAException

Specified by:

start in interface javax.transaction.xa.XAResource

Throws:

javax.transaction.xa.XAException

setForceNotSameRM

public void setForceNotSameRM(boolean force)