org.jboss.messaging.core.server.impl
Class ServerConnectionImpl
java.lang.Object
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)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
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)
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.