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() |
getTimestampgetSource, toStringpublic ConnectionBlockedEvent(Connection source, String reason)
public Connection getConnection()
public String getReason()