public class Connection_1_0 extends Object implements ConnectionEventListener
ConnectionEventListener.DefaultConnectionEventListener
DEFAULT
Constructor and Description |
---|
Connection_1_0(ConnectionEndpoint connectionEndpoint,
long connectionId,
AmqpPort<?> port,
Transport transport,
SubjectCreator subjectCreator,
AMQPConnection_1_0 amqpConnection) |
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() |
public Connection_1_0(ConnectionEndpoint connectionEndpoint, long connectionId, AmqpPort<?> port, Transport transport, SubjectCreator subjectCreator, AMQPConnection_1_0 amqpConnection)
public ConnectionEndpoint getConnectionEndpoint()
public Object getReference()
public void openReceived()
openReceived
in interface ConnectionEventListener
public void remoteSessionCreation(SessionEndpoint endpoint)
remoteSessionCreation
in interface ConnectionEventListener
public void closeReceived()
closeReceived
in interface ConnectionEventListener
public void closed()
public void sendConnectionCloseAsync(AMQConstant cause, String message)
public void block()
public void unblock()
public void closeSessionAsync(Session_1_0 session, AMQConstant cause, String message)
public long getConnectionId()
public List<Session_1_0> getSessionModels()
public LogSubject getLogSubject()
public String getRemoteAddressString()
public String getClientId()
public String getRemoteContainerName()
public Principal getAuthorizedPrincipal()
public long getSessionCountLimit()
public AmqpPort<?> getPort()
public AMQPConnection_1_0 getAmqpConnection()
public Transport getTransport()
public VirtualHostImpl getVirtualHost()
public void transportStateChanged()
public void notifyWork()
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.