org.jboss.messaging.core.server.impl
Class ServerConnectionImpl

java.lang.Object
  extended by org.jboss.messaging.core.server.impl.ServerConnectionImpl
All Implemented Interfaces:
ServerConnection

public class ServerConnectionImpl
extends java.lang.Object
implements ServerConnection

Concrete implementation of ConnectionEndpoint.

Version:
$Revision: 3789 $ $Id: ServerConnectionImpl.java 3789 2008-02-25 15:34:18Z ataylor $
Author:
Ovidiu Feodorov, Tim Fox, Jeff Mesnil, Andy Taylor

Constructor Summary
ServerConnectionImpl(long id, java.lang.String username, java.lang.String password, long remotingClientSessionID, java.lang.String clientAddress, PacketDispatcher dispatcher, ResourceManager resourceManager, StorageManager persistenceManager, HierarchicalRepository<QueueSettings> queueSettingsRepository, PostOffice postOffice, SecurityStore securityStore, ConnectionManager connectionManager)
           
 
Method Summary
 void addTemporaryDestination(SimpleString address)
           
 void addTemporaryQueue(Queue queue)
           
 void close()
           
 ConnectionCreateSessionResponseMessage createSession(boolean xa, boolean autoCommitSends, boolean autoCommitAcks, PacketReturner sender)
           
 java.lang.String getClientAddress()
           
 long getCreated()
           
 long getCreatedTime()
           
 long getID()
           
 java.lang.String getPassword()
           
 long getRemotingClientSessionID()
           
 SecurityStore getSecurityStore()
           
 java.util.Collection<ServerSession> getSessions()
           
 java.lang.String getUsername()
           
 boolean isStarted()
           
 void removeSession(ServerSession session)
           
 void removeTemporaryDestination(SimpleString address)
           
 void removeTemporaryQueue(Queue queue)
           
 void start()
           
 void stop()
           
 java.lang.String toString()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

ServerConnectionImpl

public ServerConnectionImpl(long id,
                            java.lang.String username,
                            java.lang.String password,
                            long remotingClientSessionID,
                            java.lang.String clientAddress,
                            PacketDispatcher dispatcher,
                            ResourceManager resourceManager,
                            StorageManager persistenceManager,
                            HierarchicalRepository<QueueSettings> queueSettingsRepository,
                            PostOffice postOffice,
                            SecurityStore securityStore,
                            ConnectionManager connectionManager)
Method Detail

getID

public long getID()
Specified by:
getID in interface ServerConnection

createSession

public ConnectionCreateSessionResponseMessage createSession(boolean xa,
                                                            boolean autoCommitSends,
                                                            boolean autoCommitAcks,
                                                            PacketReturner sender)
                                                     throws java.lang.Exception
Specified by:
createSession in interface ServerConnection
Throws:
java.lang.Exception

start

public void start()
           throws java.lang.Exception
Specified by:
start in interface ServerConnection
Throws:
java.lang.Exception

stop

public void stop()
          throws java.lang.Exception
Specified by:
stop in interface ServerConnection
Throws:
java.lang.Exception

close

public void close()
           throws java.lang.Exception
Specified by:
close in interface ServerConnection
Throws:
java.lang.Exception

getSecurityStore

public SecurityStore getSecurityStore()
Specified by:
getSecurityStore in interface ServerConnection

getUsername

public java.lang.String getUsername()
Specified by:
getUsername in interface ServerConnection

getPassword

public java.lang.String getPassword()
Specified by:
getPassword in interface ServerConnection

removeSession

public void removeSession(ServerSession session)
                   throws java.lang.Exception
Specified by:
removeSession in interface ServerConnection
Throws:
java.lang.Exception

addTemporaryQueue

public void addTemporaryQueue(Queue queue)
Specified by:
addTemporaryQueue in interface ServerConnection

removeTemporaryQueue

public void removeTemporaryQueue(Queue queue)
Specified by:
removeTemporaryQueue in interface ServerConnection

addTemporaryDestination

public void addTemporaryDestination(SimpleString address)
Specified by:
addTemporaryDestination in interface ServerConnection

removeTemporaryDestination

public void removeTemporaryDestination(SimpleString address)
Specified by:
removeTemporaryDestination in interface ServerConnection

isStarted

public boolean isStarted()
Specified by:
isStarted in interface ServerConnection

getCreatedTime

public long getCreatedTime()
Specified by:
getCreatedTime in interface ServerConnection

getClientAddress

public java.lang.String getClientAddress()
Specified by:
getClientAddress in interface ServerConnection

getCreated

public long getCreated()
Specified by:
getCreated in interface ServerConnection

getRemotingClientSessionID

public long getRemotingClientSessionID()
Specified by:
getRemotingClientSessionID in interface ServerConnection

getSessions

public java.util.Collection<ServerSession> getSessions()
Specified by:
getSessions in interface ServerConnection

toString

public java.lang.String toString()
Overrides:
toString in class java.lang.Object


Copyright © 2006 JBoss Inc. All Rights Reserved.