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