zmq

Class Mailbox

java.lang.Object

zmq.Mailbox

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class Mailbox
extends java.lang.Object
implements java.io.Closeable

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	active
private YPipe<Command>	cpipe
private java.lang.String	name
private Signaler	signaler
private java.util.concurrent.locks.Lock	sync

Constructor Summary

Constructors

Constructor and Description
Mailbox(java.lang.String name)

Method Summary

Modifier and Type	Method and Description
void	close()
java.nio.channels.SelectableChannel	getFd()
Command	recv(long timeout)
void	send(Command cmd)
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

cpipe

private final YPipe<Command> cpipe

signaler

private final Signaler signaler

sync

private final java.util.concurrent.locks.Lock sync

active

private boolean active

name

private final java.lang.String name

Constructor Detail

Mailbox

public Mailbox(java.lang.String name)

Method Detail

getFd

public java.nio.channels.SelectableChannel getFd()

send

public void send(Command cmd)

recv

public Command recv(long timeout)

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object