org.hornetq.core.server.impl

Class ServerSessionImpl

java.lang.Object

org.hornetq.core.server.impl.ServerSessionImpl

All Implemented Interfaces:

FailureListener, ServerSession

public class ServerSessionImpl
extends Object
implements ServerSession, FailureListener

Field Summary

Fields

Modifier and Type	Field and Description
PostOffice	postOffice

Constructor Summary

Constructors

Constructor and Description

ServerSessionImpl(String name, String username, String password, int minLargeMessageSize, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, boolean strictUpdateDeliveryCount, boolean xa, RemotingConnection remotingConnection, StorageManager storageManager, PostOffice postOffice, ResourceManager resourceManager, SecurityStore securityStore, ManagementService managementService, HornetQServer server, SimpleString managementAddress, SimpleString defaultAddress, SessionCallback callback)

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	clearLargeMessage()
void	close(boolean failed)
void	closeConsumer(long consumerID)
void	commit()
void	connectionFailed(HornetQException me, boolean failedOver) Notifies that a connection has failed due to the specified exception.
void	createConsumer(long consumerID, SimpleString queueName, SimpleString filterString, boolean browseOnly)
void	createQueue(SimpleString address, SimpleString name, SimpleString filterString, boolean temporary, boolean durable)
void	deleteQueue(SimpleString name)
void	describeProducersInfo(JSONArray array) 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()
String	getLastSentMessageID(String address)
String	getMetaData(String key)
int	getMinLargeMessageSize()
String	getName()
String	getPassword()
RemotingConnection	getRemotingConnection() For test cases only
Set<ServerConsumer>	getServerConsumers()
OperationContext	getSessionContext()
String[]	getTargetAddresses()
String	getUsername()
void	individualAcknowledge(long consumerID, long messageID)
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 messageBodySize, byte[] body, boolean continues)
void	sendLarge(MessageInternal message)
void	setSessionContext(OperationContext sessionContext)
void	setTransferring(boolean transferring)
void	start()
void	stop()
void	waitContextCompletion()
void	xaCommit(Xid xid, boolean onePhase)
void	xaEnd(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()

Methods inherited from class java.lang.Object

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

Field Detail

postOffice

public final PostOffice postOffice

Constructor Detail

ServerSessionImpl

public ServerSessionImpl(String name,
                 String username,
                 String password,
                 int minLargeMessageSize,
                 boolean autoCommitSends,
                 boolean autoCommitAcks,
                 boolean preAcknowledge,
                 boolean strictUpdateDeliveryCount,
                 boolean xa,
                 RemotingConnection remotingConnection,
                 StorageManager storageManager,
                 PostOffice postOffice,
                 ResourceManager resourceManager,
                 SecurityStore securityStore,
                 ManagementService managementService,
                 HornetQServer server,
                 SimpleString managementAddress,
                 SimpleString defaultAddress,
                 SessionCallback callback)
                  throws Exception

Throws:

Exception

Method Detail

getSessionContext

public OperationContext getSessionContext()

Specified by:

getSessionContext in interface ServerSession

Returns:

the sessionContext

setSessionContext

public void setSessionContext(OperationContext sessionContext)

Specified by:

setSessionContext in interface ServerSession

Parameters:

sessionContext - the sessionContext to set

getUsername

public String getUsername()

Specified by:

getUsername in interface ServerSession

getPassword

public String getPassword()

Specified by:

getPassword in interface ServerSession

getMinLargeMessageSize

public int getMinLargeMessageSize()

Specified by:

getMinLargeMessageSize in interface ServerSession

getName

public String getName()

Specified by:

getName in interface ServerSession

getConnectionID

public Object getConnectionID()

Specified by:

getConnectionID in interface ServerSession

getServerConsumers

public Set<ServerConsumer> getServerConsumers()

Specified by:

getServerConsumers in interface ServerSession

removeConsumer

public void removeConsumer(long consumerID)
                    throws Exception

Specified by:

removeConsumer in interface ServerSession

Throws:

Exception

createConsumer

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

Specified by:

createConsumer in interface ServerSession

Throws:

Exception

createQueue

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

Specified by:

createQueue in interface ServerSession

Throws:

Exception

getRemotingConnection

public RemotingConnection getRemotingConnection()

For test cases only

Returns:

deleteQueue

public void deleteQueue(SimpleString name)
                 throws Exception

Specified by:

deleteQueue in interface ServerSession

Throws:

Exception

executeQueueQuery

public QueueQueryResult executeQueueQuery(SimpleString name)
                                   throws Exception

Specified by:

executeQueueQuery in interface ServerSession

Throws:

Exception

executeBindingQuery

public BindingQueryResult executeBindingQuery(SimpleString address)
                                       throws Exception

Specified by:

executeBindingQuery in interface ServerSession

Throws:

Exception

forceConsumerDelivery

public void forceConsumerDelivery(long consumerID,
                         long sequence)
                           throws Exception

Specified by:

forceConsumerDelivery in interface ServerSession

Throws:

Exception

acknowledge

public void acknowledge(long consumerID,
               long messageID)
                 throws Exception

Specified by:

acknowledge in interface ServerSession

Throws:

Exception

individualAcknowledge

public void individualAcknowledge(long consumerID,
                         long messageID)
                           throws Exception

Specified by:

individualAcknowledge in interface ServerSession

Throws:

Exception

expire

public void expire(long consumerID,
          long messageID)
            throws Exception

Specified by:

expire in interface ServerSession

Throws:

Exception

commit

public void commit()
            throws Exception

Specified by:

commit in interface ServerSession

Throws:

Exception

rollback

public void rollback(boolean considerLastMessageAsDelivered)
              throws Exception

Specified by:

rollback in interface ServerSession

Throws:

Exception

xaCommit

public void xaCommit(Xid xid,
            boolean onePhase)
              throws Exception

Specified by:

xaCommit in interface ServerSession

Throws:

Exception

xaEnd

public void xaEnd(Xid xid)
           throws Exception

Specified by:

xaEnd in interface ServerSession

Throws:

Exception

xaForget

public void xaForget(Xid xid)
              throws Exception

Specified by:

xaForget in interface ServerSession

Throws:

Exception

xaJoin

public void xaJoin(Xid xid)
            throws Exception

Specified by:

xaJoin in interface ServerSession

Throws:

Exception

xaResume

public void xaResume(Xid xid)
              throws Exception

Specified by:

xaResume in interface ServerSession

Throws:

Exception

xaRollback

public void xaRollback(Xid xid)
                throws Exception

Specified by:

xaRollback in interface ServerSession

Throws:

Exception

xaStart

public void xaStart(Xid xid)
             throws Exception

Specified by:

xaStart in interface ServerSession

Throws:

Exception

xaSuspend

public void xaSuspend()
               throws Exception

Specified by:

xaSuspend in interface ServerSession

Throws:

Exception

xaPrepare

public void xaPrepare(Xid xid)
               throws Exception

Specified by:

xaPrepare in interface ServerSession

Throws:

Exception

xaGetInDoubtXids

public List<Xid> xaGetInDoubtXids()

Specified by:

xaGetInDoubtXids in interface ServerSession

xaGetTimeout

public int xaGetTimeout()

Specified by:

xaGetTimeout in interface ServerSession

xaSetTimeout

public void xaSetTimeout(int timeout)

Specified by:

xaSetTimeout in interface ServerSession

start

public void start()

Specified by:

start in interface ServerSession

stop

public void stop()

Specified by:

stop in interface ServerSession

waitContextCompletion

public void waitContextCompletion()

Specified by:

waitContextCompletion in interface ServerSession

close

public void close(boolean failed)

Specified by:

close in interface ServerSession

closeConsumer

public void closeConsumer(long consumerID)
                   throws Exception

Specified by:

closeConsumer in interface ServerSession

Throws:

Exception

receiveConsumerCredits

public void receiveConsumerCredits(long consumerID,
                          int credits)
                            throws Exception

Specified by:

receiveConsumerCredits in interface ServerSession

Throws:

Exception

sendLarge

public void sendLarge(MessageInternal message)
               throws Exception

Specified by:

sendLarge in interface ServerSession

Throws:

Exception

send

public void send(ServerMessage message,
        boolean direct)
          throws Exception

Specified by:

send in interface ServerSession

Throws:

Exception

sendContinuations

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

Specified by:

sendContinuations in interface ServerSession

Throws:

Exception

requestProducerCredits

public void requestProducerCredits(SimpleString address,
                          int credits)
                            throws Exception

Specified by:

requestProducerCredits in interface ServerSession

Throws:

Exception

setTransferring

public void setTransferring(boolean transferring)

Specified by:

setTransferring in interface ServerSession

addMetaData

public void addMetaData(String key,
               String data)

Specified by:

addMetaData in interface ServerSession

addUniqueMetaData

public boolean addUniqueMetaData(String key,
                        String data)

Specified by:

addUniqueMetaData in interface ServerSession

getMetaData

public String getMetaData(String key)

Specified by:

getMetaData in interface ServerSession

getTargetAddresses

public String[] getTargetAddresses()

Specified by:

getTargetAddresses in interface ServerSession

getLastSentMessageID

public String getLastSentMessageID(String address)

Specified by:

getLastSentMessageID in interface ServerSession

getCreationTime

public long getCreationTime()

Specified by:

getCreationTime in interface ServerSession

describeProducersInfo

public void describeProducersInfo(JSONArray array)
                           throws Exception

Description copied from interface: ServerSession

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

Specified by:

describeProducersInfo in interface ServerSession

Throws:

Exception

connectionFailed

public void connectionFailed(HornetQException me,
                    boolean failedOver)

Description copied from interface: FailureListener

Notifies that a connection has failed due to the specified exception.

Specified by:

connectionFailed in interface FailureListener

Parameters:

me - exception which has caused the connection to fail

clearLargeMessage

public void clearLargeMessage()