org.hornetq.core.server

Interface ServerSession

All Known Implementing Classes:

ServerSessionImpl

public interface ServerSession

A ServerSession

Author:

Tim Fox,

Method Summary

Methods

Modifier and Type	Method and Description
void	acknowledge(long consumerID, long messageID)
void	addMetaData(String key, String data)
boolean	addUniqueMetaData(String key, String data)
void	close(boolean failed)
void	closeConsumer(long consumerID)
void	commit()
void	createConsumer(long consumerID, SimpleString queueName, SimpleString filterString, boolean browseOnly)
void	createQueue(SimpleString address, SimpleString name, SimpleString filterString, boolean temporary, boolean durable)
void	createSharedQueue(SimpleString address, SimpleString name, boolean durable, SimpleString filterString)
void	deleteQueue(SimpleString name)
void	describeProducersInfo(JSONArray objs) Add all the producers detail to the JSONArray object.
BindingQueryResult	executeBindingQuery(SimpleString address)
QueueQueryResult	executeQueueQuery(SimpleString name)
void	expire(long consumerID, long messageID)
void	forceConsumerDelivery(long consumerID, long sequence)
Object	getConnectionID()
long	getCreationTime()
Transaction	getCurrentTransaction()
String	getLastSentMessageID(String address)
String	getMetaData(String key)
int	getMinLargeMessageSize()
String	getName()
String	getPassword()
RemotingConnection	getRemotingConnection()
Set<ServerConsumer>	getServerConsumers()
OperationContext	getSessionContext()
String[]	getTargetAddresses()
String	getUsername()
void	individualAcknowledge(long consumerID, long messageID)
void	individualCancel(long consumerID, long messageID, boolean failed)
void	receiveConsumerCredits(long consumerID, int credits)
void	removeConsumer(long consumerID)
void	requestProducerCredits(SimpleString address, int credits)
void	rollback(boolean considerLastMessageAsDelivered)
void	send(ServerMessage message, boolean direct)
void	sendContinuations(int packetSize, long totalBodySize, byte[] body, boolean continues)
void	sendLarge(MessageInternal msg)
void	setTransferring(boolean transferring)
void	start()
void	stop()
void	waitContextCompletion()
void	xaCommit(Xid xid, boolean onePhase)
void	xaEnd(Xid xid)
void	xaFailed(Xid xid)
void	xaForget(Xid xid)
List<Xid>	xaGetInDoubtXids()
int	xaGetTimeout()
void	xaJoin(Xid xid)
void	xaPrepare(Xid xid)
void	xaResume(Xid xid)
void	xaRollback(Xid xid)
void	xaSetTimeout(int timeout)
void	xaStart(Xid xid)
void	xaSuspend()

Method Detail

getName

String getName()

getUsername

String getUsername()

getPassword

String getPassword()

getMinLargeMessageSize

int getMinLargeMessageSize()

getConnectionID

Object getConnectionID()

getRemotingConnection

RemotingConnection getRemotingConnection()

removeConsumer

void removeConsumer(long consumerID)
                    throws Exception

Throws:

Exception

acknowledge

void acknowledge(long consumerID,
               long messageID)
                 throws Exception

Throws:

Exception

individualAcknowledge

void individualAcknowledge(long consumerID,
                         long messageID)
                           throws Exception

Throws:

Exception

individualCancel

void individualCancel(long consumerID,
                    long messageID,
                    boolean failed)
                      throws Exception

Throws:

Exception

expire

void expire(long consumerID,
          long messageID)
            throws Exception

Throws:

Exception

rollback

void rollback(boolean considerLastMessageAsDelivered)
              throws Exception

Throws:

Exception

commit

void commit()
            throws Exception

Throws:

Exception

xaCommit

void xaCommit(Xid xid,
            boolean onePhase)
              throws Exception

Throws:

Exception

xaEnd

void xaEnd(Xid xid)
           throws Exception

Throws:

Exception

xaForget

void xaForget(Xid xid)
              throws Exception

Throws:

Exception

xaJoin

void xaJoin(Xid xid)
            throws Exception

Throws:

Exception

xaPrepare

void xaPrepare(Xid xid)
               throws Exception

Throws:

Exception

xaResume

void xaResume(Xid xid)
              throws Exception

Throws:

Exception

xaRollback

void xaRollback(Xid xid)
                throws Exception

Throws:

Exception

xaStart

void xaStart(Xid xid)
             throws Exception

Throws:

Exception

xaFailed

void xaFailed(Xid xid)
              throws Exception

Throws:

Exception

xaSuspend

void xaSuspend()
               throws Exception

Throws:

Exception

xaGetInDoubtXids

List<Xid> xaGetInDoubtXids()

xaGetTimeout

int xaGetTimeout()

xaSetTimeout

void xaSetTimeout(int timeout)

start

void start()

stop

void stop()

createQueue

void createQueue(SimpleString address,
               SimpleString name,
               SimpleString filterString,
               boolean temporary,
               boolean durable)
                 throws Exception

Throws:

Exception

deleteQueue

void deleteQueue(SimpleString name)
                 throws Exception

Throws:

Exception

createConsumer

void createConsumer(long consumerID,
                  SimpleString queueName,
                  SimpleString filterString,
                  boolean browseOnly)
                    throws Exception

Throws:

Exception

executeQueueQuery

QueueQueryResult executeQueueQuery(SimpleString name)
                                   throws Exception

Throws:

Exception

executeBindingQuery

BindingQueryResult executeBindingQuery(SimpleString address)
                                       throws Exception

Throws:

Exception

closeConsumer

void closeConsumer(long consumerID)
                   throws Exception

Throws:

Exception

receiveConsumerCredits

void receiveConsumerCredits(long consumerID,
                          int credits)
                            throws Exception

Throws:

Exception

sendContinuations

void sendContinuations(int packetSize,
                     long totalBodySize,
                     byte[] body,
                     boolean continues)
                       throws Exception

Throws:

Exception

send

void send(ServerMessage message,
        boolean direct)
          throws Exception

Throws:

Exception

sendLarge

void sendLarge(MessageInternal msg)
               throws Exception

Throws:

Exception

forceConsumerDelivery

void forceConsumerDelivery(long consumerID,
                         long sequence)
                           throws Exception

Throws:

Exception

requestProducerCredits

void requestProducerCredits(SimpleString address,
                          int credits)
                            throws Exception

Throws:

Exception

close

void close(boolean failed)
           throws Exception

Throws:

Exception

waitContextCompletion

void waitContextCompletion()
                           throws Exception

Throws:

Exception

setTransferring

void setTransferring(boolean transferring)

getServerConsumers

Set<ServerConsumer> getServerConsumers()

addMetaData

void addMetaData(String key,
               String data)

addUniqueMetaData

boolean addUniqueMetaData(String key,
                        String data)

getMetaData

String getMetaData(String key)

getTargetAddresses

String[] getTargetAddresses()

describeProducersInfo

void describeProducersInfo(JSONArray objs)
                           throws Exception

Add all the producers detail to the JSONArray object. This is a method to be used by the management layer.

Parameters:

objs -

Throws:

Exception

getLastSentMessageID

String getLastSentMessageID(String address)

getCreationTime

long getCreationTime()

getSessionContext

OperationContext getSessionContext()

getCurrentTransaction

Transaction getCurrentTransaction()

createSharedQueue

void createSharedQueue(SimpleString address,
                     SimpleString name,
                     boolean durable,
                     SimpleString filterString)
                       throws Exception

Throws:

Exception