org.jboss.messaging.core.server
Interface ServerSession

All Known Implementing Classes:

ServerSessionImpl

public interface ServerSession

A ServerSession

Author:

Tim Fox

Method Summary

void	acknowledge(long deliveryID, boolean allUpTo)
void	addDestination(SimpleString address, boolean temporary)
void	cancel(long deliveryID, boolean expired)
void	close()
void	commit()
SessionCreateBrowserResponseMessage	createBrowser(SimpleString queueName, SimpleString filterString)
SessionCreateConsumerResponseMessage	createConsumer(long clientTargetID, SimpleString queueName, SimpleString filterString, boolean noLocal, boolean autoDeleteQueue, int windowSize, int maxRate)
SessionCreateProducerResponseMessage	createProducer(long clientTargetID, SimpleString address, int windowSize, int maxRate)
void	createQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable, boolean temporary)
void	deleteQueue(SimpleString queueName)
SessionBindingQueryResponseMessage	executeBindingQuery(SessionBindingQueryMessage request)
SessionQueueQueryResponseMessage	executeQueueQuery(SessionQueueQueryMessage request)
long	getID()
java.util.List<javax.transaction.xa.Xid>	getInDoubtXids()
int	getXATimeout()
void	handleDelivery(MessageReference reference, ServerConsumer consumer)
void	promptDelivery(Queue queue)
void	removeBrowser(ServerBrowserImpl browser)
void	removeConsumer(ServerConsumer consumer)
void	removeDestination(SimpleString address, boolean temporary)
void	removeProducer(ServerProducer producer)
void	rollback()
void	send(ServerMessage msg)
void	setStarted(boolean started)
boolean	setXATimeout(int timeoutSeconds)
SessionXAResponseMessage	XACommit(boolean onePhase, javax.transaction.xa.Xid xid)
SessionXAResponseMessage	XAEnd(javax.transaction.xa.Xid xid, boolean failed)
SessionXAResponseMessage	XAForget(javax.transaction.xa.Xid xid)
SessionXAResponseMessage	XAJoin(javax.transaction.xa.Xid xid)
SessionXAResponseMessage	XAPrepare(javax.transaction.xa.Xid xid)
SessionXAResponseMessage	XAResume(javax.transaction.xa.Xid xid)
SessionXAResponseMessage	XARollback(javax.transaction.xa.Xid xid)
SessionXAResponseMessage	XAStart(javax.transaction.xa.Xid xid)
SessionXAResponseMessage	XASuspend()

Method Detail

getID

long getID()

removeBrowser

void removeBrowser(ServerBrowserImpl browser)
                   throws java.lang.Exception

Throws:

java.lang.Exception

removeConsumer

void removeConsumer(ServerConsumer consumer)
                    throws java.lang.Exception

Throws:

java.lang.Exception

removeProducer

void removeProducer(ServerProducer producer)
                    throws java.lang.Exception

Throws:

java.lang.Exception

close

void close()
           throws java.lang.Exception

Throws:

java.lang.Exception

setStarted

void setStarted(boolean started)
                throws java.lang.Exception

Throws:

java.lang.Exception

handleDelivery

void handleDelivery(MessageReference reference,
                    ServerConsumer consumer)
                    throws java.lang.Exception

Throws:

java.lang.Exception

promptDelivery

void promptDelivery(Queue queue)

send

void send(ServerMessage msg)
          throws java.lang.Exception

Throws:

java.lang.Exception

acknowledge

void acknowledge(long deliveryID,
                 boolean allUpTo)
                 throws java.lang.Exception

Throws:

java.lang.Exception

rollback

void rollback()
              throws java.lang.Exception

Throws:

java.lang.Exception

cancel

void cancel(long deliveryID,
            boolean expired)
            throws java.lang.Exception

Throws:

java.lang.Exception

commit

void commit()
            throws java.lang.Exception

Throws:

java.lang.Exception

XACommit

SessionXAResponseMessage XACommit(boolean onePhase,
                                  javax.transaction.xa.Xid xid)
                                  throws java.lang.Exception

Throws:

java.lang.Exception

XAEnd

SessionXAResponseMessage XAEnd(javax.transaction.xa.Xid xid,
                               boolean failed)
                               throws java.lang.Exception

Throws:

java.lang.Exception

XAForget

SessionXAResponseMessage XAForget(javax.transaction.xa.Xid xid)

XAJoin

SessionXAResponseMessage XAJoin(javax.transaction.xa.Xid xid)
                                throws java.lang.Exception

Throws:

java.lang.Exception

XAPrepare

SessionXAResponseMessage XAPrepare(javax.transaction.xa.Xid xid)
                                   throws java.lang.Exception

Throws:

java.lang.Exception

XAResume

SessionXAResponseMessage XAResume(javax.transaction.xa.Xid xid)
                                  throws java.lang.Exception

Throws:

java.lang.Exception

XARollback

SessionXAResponseMessage XARollback(javax.transaction.xa.Xid xid)
                                    throws java.lang.Exception

Throws:

java.lang.Exception

XAStart

SessionXAResponseMessage XAStart(javax.transaction.xa.Xid xid)

XASuspend

SessionXAResponseMessage XASuspend()
                                   throws java.lang.Exception

Throws:

java.lang.Exception

getInDoubtXids

java.util.List<javax.transaction.xa.Xid> getInDoubtXids()
                                                        throws java.lang.Exception

Throws:

java.lang.Exception

getXATimeout

int getXATimeout()

setXATimeout

boolean setXATimeout(int timeoutSeconds)

addDestination

void addDestination(SimpleString address,
                    boolean temporary)
                    throws java.lang.Exception

Throws:

java.lang.Exception

removeDestination

void removeDestination(SimpleString address,
                       boolean temporary)
                       throws java.lang.Exception

Throws:

java.lang.Exception

createQueue

void createQueue(SimpleString address,
                 SimpleString queueName,
                 SimpleString filterString,
                 boolean durable,
                 boolean temporary)
                 throws java.lang.Exception

Throws:

java.lang.Exception

deleteQueue

void deleteQueue(SimpleString queueName)
                 throws java.lang.Exception

Throws:

java.lang.Exception

createConsumer

SessionCreateConsumerResponseMessage createConsumer(long clientTargetID,
                                                    SimpleString queueName,
                                                    SimpleString filterString,
                                                    boolean noLocal,
                                                    boolean autoDeleteQueue,
                                                    int windowSize,
                                                    int maxRate)
                                                    throws java.lang.Exception

Throws:

java.lang.Exception

createProducer

SessionCreateProducerResponseMessage createProducer(long clientTargetID,
                                                    SimpleString address,
                                                    int windowSize,
                                                    int maxRate)
                                                    throws java.lang.Exception

Throws:

java.lang.Exception

executeQueueQuery

SessionQueueQueryResponseMessage executeQueueQuery(SessionQueueQueryMessage request)
                                                   throws java.lang.Exception

Throws:

java.lang.Exception

executeBindingQuery

SessionBindingQueryResponseMessage executeBindingQuery(SessionBindingQueryMessage request)
                                                       throws java.lang.Exception

Throws:

java.lang.Exception

createBrowser

SessionCreateBrowserResponseMessage createBrowser(SimpleString queueName,
                                                  SimpleString filterString)
                                                  throws java.lang.Exception

Throws:

java.lang.Exception