zmq

Class Mailbox

java.lang.Object

zmq.Mailbox

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, IMailbox

public final class Mailbox
extends java.lang.Object
implements IMailbox

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
Mailbox(Ctx ctx, java.lang.String name, int tid)

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

errno

private final Errno errno

Constructor Detail

Mailbox

public Mailbox(Ctx ctx,
               java.lang.String name,
               int tid)

Method Detail

getFd

public java.nio.channels.SelectableChannel getFd()

send

public void send(Command cmd)

Specified by:

send in interface IMailbox

recv

public Command recv(long timeout)

Specified by:

recv in interface IMailbox

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