org.apache.qpid.server.connection
Class ConnectionRegistry

java.lang.Object
  extended by org.apache.qpid.server.connection.ConnectionRegistry
All Implemented Interfaces:
org.apache.qpid.common.Closeable, IConnectionRegistry

public class ConnectionRegistry
extends Object
implements IConnectionRegistry, org.apache.qpid.common.Closeable


Constructor Summary
ConnectionRegistry()
           
 
Method Summary
 void close()
          Close all of the currently open connections.
 void deregisterConnection(AMQProtocolSession connnection)
           
 void expireClosedChannels()
           
 void initialise()
           
 void registerConnection(AMQProtocolSession connnection)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ConnectionRegistry

public ConnectionRegistry()
Method Detail

initialise

public void initialise()
Specified by:
initialise in interface IConnectionRegistry

expireClosedChannels

public void expireClosedChannels()

close

public void close()
Close all of the currently open connections.

Specified by:
close in interface org.apache.qpid.common.Closeable
Specified by:
close in interface IConnectionRegistry

registerConnection

public void registerConnection(AMQProtocolSession connnection)
Specified by:
registerConnection in interface IConnectionRegistry

deregisterConnection

public void deregisterConnection(AMQProtocolSession connnection)
Specified by:
deregisterConnection in interface IConnectionRegistry


Licensed to the Apache Software Foundation