public class ConnectionBlockedEvent extends AmqpEvent
AmqpEvent
emitted by the CachingConnectionFactory
when its connections are blocked.BlockedListener.handleBlocked(String)
,
Serialized Formsource
Constructor and Description |
---|
ConnectionBlockedEvent(Connection source,
String reason) |
Modifier and Type | Method and Description |
---|---|
Connection |
getConnection() |
String |
getReason() |
getTimestamp
getSource, toString
public ConnectionBlockedEvent(Connection source, String reason)
public Connection getConnection()
public String getReason()