public class ZEvent
extends java.lang.Object
| Event | Value type | Severity level |
|---|---|---|
| CONNECTED | SelectableChannel |
debug |
| CONNECT_DELAYED | ZMQ.Error or null if no error |
debug |
| CONNECT_RETRIED | Duration |
debug |
| LISTENING | SelectableChannel |
debug |
| BIND_FAILED | ZMQ.Error or null if no error |
error |
| ACCEPTED | SelectableChannel |
debug |
| ACCEPT_FAILED | ZMQ.Error or null if no error |
error |
| CLOSED | SelectableChannel |
debug |
| CLOSE_FAILED | ZMQ.Error or null if no error |
error |
| DISCONNECTED | SelectableChannel |
info |
| MONITOR_STOPPED | null value | debug |
| HANDSHAKE_FAILED_NO_DETAIL | ZMQ.Error or null if no error |
error |
| HANDSHAKE_SUCCEEDED | ZMQ.Error or null if no error |
debug |
| HANDSHAKE_FAILED_PROTOCOL | ZMonitor.ProtocolCode |
error |
| HANDSHAKE_FAILED_AUTH | Integer |
warn |
| HANDSHAKE_PROTOCOL | Integer |
debug |
| Modifier and Type | Class and Description |
|---|---|
static interface |
ZEvent.ZEventConsummer
An interface used to consume events in monitor
|
| Modifier and Type | Field and Description |
|---|---|
private java.lang.String |
address |
private ZMonitor.Event |
event |
private java.lang.Object |
value |
| Modifier | Constructor and Description |
|---|---|
private |
ZEvent(ZMQ.Event event,
java.util.function.Function<java.lang.Object,java.nio.channels.SelectableChannel> getResolveChannel) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
equals(java.lang.Object o) |
java.lang.String |
getAddress() |
ZMonitor.Event |
getEvent() |
<M> M |
getValue()
Return the value of the event as a high level java object.
|
int |
hashCode() |
boolean |
isDebug()
Used to check if the event is an error.
|
boolean |
isError()
Used to check if the event is an error.
|
boolean |
isInformation()
Used to check if the event is an information.
|
boolean |
isWarn()
Used to check if the event is a warning.
|
static ZEvent |
recv(ZMQ.Socket socket)
Receive an event from a monitor socket.
|
static ZEvent |
recv(ZMQ.Socket socket,
int flags)
Receive an event from a monitor socket.
|
(package private) static java.lang.Object |
resolve(ZMonitor.Event event,
java.lang.Object value,
java.util.function.Function<java.lang.Object,java.nio.channels.SelectableChannel> getResolveChannel) |
java.lang.String |
toString() |
private final ZMonitor.Event event
private final java.lang.Object value
private final java.lang.String address
private ZEvent(ZMQ.Event event, java.util.function.Function<java.lang.Object,java.nio.channels.SelectableChannel> getResolveChannel)
static java.lang.Object resolve(ZMonitor.Event event, java.lang.Object value, java.util.function.Function<java.lang.Object,java.nio.channels.SelectableChannel> getResolveChannel)
public ZMonitor.Event getEvent()
public <M> M getValue()
ZMonitor.ProtocolCode for a handshake protocol error.ZMQ.Error for any other error.Duration when associated with a delay.M - The expected type of the returned objectpublic java.lang.String getAddress()
public boolean isError()
Generally, any event that define the errno is considered as an error.
public boolean isWarn()
Generally, any event that return an authentication failure is considered as a warning.
public boolean isInformation()
Generally, any event that return an authentication failure is considered as a warning.
public boolean isDebug()
Generally, any event that define the errno is considered as an error.
public boolean equals(java.lang.Object o)
equals in class java.lang.Objectpublic int hashCode()
hashCode in class java.lang.Objectpublic java.lang.String toString()
toString in class java.lang.Objectpublic static ZEvent recv(ZMQ.Socket socket, int flags)
socket - the monitor socketflags - the flags to apply to the read operation.ZMQException - In case of errors with the monitor socketpublic static ZEvent recv(ZMQ.Socket socket)
socket - the monitor socketZMQException - In case of errors with the monitor socket