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


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 addFailureListener(FailureListener listener)
           
 SessionBindingQueryResponseMessage bindingQuery(SimpleString address)
           
 void close()
           
 void commit()
           
 ClientMessage createClientMessage(boolean durable)
           
 ClientMessage createClientMessage(byte type, boolean durable)
           
 ClientMessage createClientMessage(byte type, boolean durable, long expiration, long timestamp, byte priority)
           
 ClientConsumer createConsumer(SimpleString queueName)
           
 ClientConsumer createConsumer(SimpleString queueName, SimpleString filterString)
           
 ClientConsumer createConsumer(SimpleString queueName, SimpleString filterString, boolean browseOnly)
           
 ClientConsumer createConsumer(SimpleString queueName, SimpleString filterString, int windowSize, int maxRate, boolean browseOnly)
           
 ClientConsumer createConsumer(java.lang.String queueName)
           
 ClientConsumer createConsumer(java.lang.String queueName, java.lang.String filterString)
           
 ClientConsumer createConsumer(java.lang.String queueName, java.lang.String filterString, boolean browseOnly)
           
 ClientConsumer createConsumer(java.lang.String queueName, java.lang.String filterString, int windowSize, int maxRate, boolean browseOnly)
           
 ClientProducer createProducer()
          Create a producer with no default address.
 ClientProducer createProducer(SimpleString address)
           
 ClientProducer createProducer(SimpleString address, int rate)
           
 ClientProducer createProducer(SimpleString address, int maxRate, boolean blockOnNonPersistentSend, boolean blockOnPersistentSend)
           
 ClientProducer createProducer(java.lang.String address)
           
 ClientProducer createProducer(java.lang.String address, int rate)
           
 ClientProducer createProducer(java.lang.String address, int maxRate, boolean blockOnNonPersistentSend, boolean blockOnPersistentSend)
           
 void createQueue(SimpleString address, SimpleString queueName, boolean durable)
          Queues created by this method are not temporary
 void createQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable)
           
 void createQueue(java.lang.String address, java.lang.String queueName, boolean durable)
          Queues created by this method are not temporary
 void createQueue(java.lang.String address, java.lang.String queueName, java.lang.String filterString, boolean durable)
           
 void createTemporaryQueue(SimpleString address, SimpleString queueName)
           
 void createTemporaryQueue(SimpleString address, SimpleString queueName, SimpleString filter)
           
 void createTemporaryQueue(java.lang.String address, java.lang.String queueName)
           
 void createTemporaryQueue(java.lang.String address, java.lang.String queueName, java.lang.String filter)
           
 void deleteQueue(SimpleString queueName)
           
 void deleteQueue(java.lang.String queueName)
           
 int getVersion()
           
 javax.transaction.xa.XAResource getXAResource()
           
 boolean isAutoCommitAcks()
           
 boolean isAutoCommitSends()
           
 boolean isBlockOnAcknowledge()
           
 boolean isClosed()
           
 boolean isXA()
           
 SessionQueueQueryResponseMessage queueQuery(SimpleString queueName)
           
 boolean removeFailureListener(FailureListener listener)
           
 void rollback()
           
 void rollback(boolean considerLastMessageAsDelivered)
           
 void setSendAcknowledgementHandler(SendAcknowledgementHandler handler)
           
 void start()
           
 void stop()
           
 
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,
                 boolean durable)
                 throws MessagingException
Queues created by this method are not temporary

Throws:
MessagingException

createQueue

void createQueue(java.lang.String address,
                 java.lang.String queueName,
                 boolean durable)
                 throws MessagingException
Queues created by this method are not temporary

Throws:
MessagingException

createQueue

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

createQueue

void createQueue(java.lang.String address,
                 java.lang.String queueName,
                 java.lang.String filterString,
                 boolean durable)
                 throws MessagingException
Throws:
MessagingException

createTemporaryQueue

void createTemporaryQueue(SimpleString address,
                          SimpleString queueName)
                          throws MessagingException
Throws:
MessagingException

createTemporaryQueue

void createTemporaryQueue(java.lang.String address,
                          java.lang.String queueName)
                          throws MessagingException
Throws:
MessagingException

createTemporaryQueue

void createTemporaryQueue(SimpleString address,
                          SimpleString queueName,
                          SimpleString filter)
                          throws MessagingException
Throws:
MessagingException

createTemporaryQueue

void createTemporaryQueue(java.lang.String address,
                          java.lang.String queueName,
                          java.lang.String filter)
                          throws MessagingException
Throws:
MessagingException

deleteQueue

void deleteQueue(SimpleString queueName)
                 throws MessagingException
Throws:
MessagingException

deleteQueue

void deleteQueue(java.lang.String queueName)
                 throws MessagingException
Throws:
MessagingException

createConsumer

ClientConsumer createConsumer(SimpleString queueName)
                              throws MessagingException
Throws:
MessagingException

createConsumer

ClientConsumer createConsumer(SimpleString queueName,
                              SimpleString filterString)
                              throws MessagingException
Throws:
MessagingException

createConsumer

ClientConsumer createConsumer(SimpleString queueName,
                              SimpleString filterString,
                              boolean browseOnly)
                              throws MessagingException
Throws:
MessagingException

createConsumer

ClientConsumer createConsumer(SimpleString queueName,
                              SimpleString filterString,
                              int windowSize,
                              int maxRate,
                              boolean browseOnly)
                              throws MessagingException
Throws:
MessagingException

createConsumer

ClientConsumer createConsumer(java.lang.String queueName)
                              throws MessagingException
Throws:
MessagingException

createConsumer

ClientConsumer createConsumer(java.lang.String queueName,
                              java.lang.String filterString)
                              throws MessagingException
Throws:
MessagingException

createConsumer

ClientConsumer createConsumer(java.lang.String queueName,
                              java.lang.String filterString,
                              boolean browseOnly)
                              throws MessagingException
Throws:
MessagingException

createConsumer

ClientConsumer createConsumer(java.lang.String queueName,
                              java.lang.String filterString,
                              int windowSize,
                              int maxRate,
                              boolean browseOnly)
                              throws MessagingException
Throws:
MessagingException

createProducer

ClientProducer createProducer()
                              throws MessagingException
Create a producer with no default address. Address must be specified every time a message is sent

Throws:
MessagingException
See Also:
ClientProducer.send(SimpleString, org.jboss.messaging.core.message.Message)

createProducer

ClientProducer createProducer(SimpleString address)
                              throws MessagingException
Throws:
MessagingException

createProducer

ClientProducer createProducer(SimpleString address,
                              int rate)
                              throws MessagingException
Throws:
MessagingException

createProducer

ClientProducer createProducer(SimpleString address,
                              int maxRate,
                              boolean blockOnNonPersistentSend,
                              boolean blockOnPersistentSend)
                              throws MessagingException
Throws:
MessagingException

createProducer

ClientProducer createProducer(java.lang.String address)
                              throws MessagingException
Throws:
MessagingException

createProducer

ClientProducer createProducer(java.lang.String address,
                              int rate)
                              throws MessagingException
Throws:
MessagingException

createProducer

ClientProducer createProducer(java.lang.String address,
                              int maxRate,
                              boolean blockOnNonPersistentSend,
                              boolean blockOnPersistentSend)
                              throws MessagingException
Throws:
MessagingException

queueQuery

SessionQueueQueryResponseMessage queueQuery(SimpleString queueName)
                                            throws MessagingException
Throws:
MessagingException

bindingQuery

SessionBindingQueryResponseMessage bindingQuery(SimpleString address)
                                                throws MessagingException
Throws:
MessagingException

getXAResource

javax.transaction.xa.XAResource getXAResource()

commit

void commit()
            throws MessagingException
Throws:
MessagingException

rollback

void rollback()
              throws MessagingException
Throws:
MessagingException

rollback

void rollback(boolean considerLastMessageAsDelivered)
              throws MessagingException
Parameters:
considerLastMessageAsDelivered - the first message on deliveringMessage Buffer is considered as delivered
Throws:
MessagingException

close

void close()
           throws MessagingException
Throws:
MessagingException

isClosed

boolean isClosed()

isAutoCommitSends

boolean isAutoCommitSends()

isAutoCommitAcks

boolean isAutoCommitAcks()

isBlockOnAcknowledge

boolean isBlockOnAcknowledge()

isXA

boolean isXA()

createClientMessage

ClientMessage createClientMessage(byte type,
                                  boolean durable,
                                  long expiration,
                                  long timestamp,
                                  byte priority)

createClientMessage

ClientMessage createClientMessage(byte type,
                                  boolean durable)

createClientMessage

ClientMessage createClientMessage(boolean durable)

start

void start()
           throws MessagingException
Throws:
MessagingException

stop

void stop()
          throws MessagingException
Throws:
MessagingException

addFailureListener

void addFailureListener(FailureListener listener)

removeFailureListener

boolean removeFailureListener(FailureListener listener)

getVersion

int getVersion()

setSendAcknowledgementHandler

void setSendAcknowledgementHandler(SendAcknowledgementHandler handler)


Copyright © 2006 JBoss Inc. All Rights Reserved.