org.apache.qpid.server.protocol.v1_0

Class Connection_1_0

java.lang.Object

org.apache.qpid.server.protocol.v1_0.Connection_1_0

All Implemented Interfaces:

ConnectionEventListener

public class Connection_1_0
extends Object
implements ConnectionEventListener

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.qpid.amqp_1_0.transport.ConnectionEventListener

ConnectionEventListener.DefaultConnectionEventListener

Field Summary

Fields inherited from interface org.apache.qpid.amqp_1_0.transport.ConnectionEventListener

DEFAULT

Constructor Summary

Constructors

Constructor and Description
Connection_1_0(ConnectionEndpoint connectionEndpoint, long connectionId, AmqpPort<?> port, Transport transport, SubjectCreator subjectCreator, AMQPConnection_1_0 amqpConnection)

Method Summary

Modifier and Type	Method and Description
void	block()
void	closed()
void	closeReceived()
void	closeSessionAsync(Session_1_0 session, AMQConstant cause, String message)
AMQPConnection_1_0	getAmqpConnection()
Principal	getAuthorizedPrincipal()
String	getClientId()
ConnectionEndpoint	getConnectionEndpoint()
long	getConnectionId()
LogSubject	getLogSubject()
AmqpPort<?>	getPort()
Object	getReference()
String	getRemoteAddressString()
String	getRemoteContainerName()
long	getSessionCountLimit()
List<Session_1_0>	getSessionModels()
Transport	getTransport()
VirtualHostImpl	getVirtualHost()
void	notifyWork()
void	openReceived()
Iterator<Runnable>	processPendingIterator()
void	remoteSessionCreation(SessionEndpoint endpoint)
void	sendConnectionCloseAsync(AMQConstant cause, String message)
String	toString()
void	transportStateChanged()
void	unblock()

Methods inherited from class java.lang.Object

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

Constructor Detail

Connection_1_0

public Connection_1_0(ConnectionEndpoint connectionEndpoint,
                      long connectionId,
                      AmqpPort<?> port,
                      Transport transport,
                      SubjectCreator subjectCreator,
                      AMQPConnection_1_0 amqpConnection)

Method Detail

getConnectionEndpoint

public ConnectionEndpoint getConnectionEndpoint()

getReference

public Object getReference()

openReceived

public void openReceived()

Specified by:

openReceived in interface ConnectionEventListener

remoteSessionCreation

public void remoteSessionCreation(SessionEndpoint endpoint)

Specified by:

remoteSessionCreation in interface ConnectionEventListener

closeReceived

public void closeReceived()

Specified by:

closeReceived in interface ConnectionEventListener

closed

public void closed()

sendConnectionCloseAsync

public void sendConnectionCloseAsync(AMQConstant cause,
                                     String message)

block

public void block()

unblock

public void unblock()

closeSessionAsync

public void closeSessionAsync(Session_1_0 session,
                              AMQConstant cause,
                              String message)

getConnectionId

public long getConnectionId()

getSessionModels

public List<Session_1_0> getSessionModels()

getLogSubject

public LogSubject getLogSubject()

getRemoteAddressString

public String getRemoteAddressString()

getClientId

public String getClientId()

getRemoteContainerName

public String getRemoteContainerName()

getAuthorizedPrincipal

public Principal getAuthorizedPrincipal()

getSessionCountLimit

public long getSessionCountLimit()

getPort

public AmqpPort<?> getPort()

getAmqpConnection

public AMQPConnection_1_0 getAmqpConnection()

getTransport

public Transport getTransport()

getVirtualHost

public VirtualHostImpl getVirtualHost()

transportStateChanged

public void transportStateChanged()

notifyWork

public void notifyWork()

processPendingIterator

public Iterator<Runnable> processPendingIterator()

toString

public String toString()

Overrides:

toString in class Object