MailboxSafe

java.lang.Object
- zmq.MailboxSafe

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, IMailbox
```
public class MailboxSafe
extends java.lang.Object
implements IMailbox
```

Field Summary

Fields
Modifier and Type	Field	Description
`private java.util.concurrent.locks.Condition`	`condition`
`private YPipe<Command>`	`cpipe`
`private Errno`	`errno`
`private java.lang.String`	`name`
`private java.util.ArrayList<Signaler>`	`signalers`
`private java.util.concurrent.locks.ReentrantLock`	`sync`

Constructor Summary

Constructors
Constructor Description

MailboxSafe(Ctx ctx, java.util.concurrent.locks.ReentrantLock sync, java.lang.String name)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`addSignaler(Signaler signaler)`
`void`	`clearSignalers()`
`void`	`close()`
`Command`	`recv(long timeout)`
`void`	`removeSignaler(Signaler signaler)`
`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
```

sync

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

condition

private final java.util.concurrent.locks.Condition condition

signalers

private final java.util.ArrayList<Signaler> signalers

name
```
private final java.lang.String name
```

errno
```
private final Errno errno
```

Constructor Detail

MailboxSafe

public MailboxSafe(Ctx ctx,
                   java.util.concurrent.locks.ReentrantLock sync,
                   java.lang.String name)

Method Detail
- addSignaler
```
public void addSignaler(Signaler signaler)
```
- removeSignaler
```
public void removeSignaler(Signaler signaler)
```
- clearSignalers
```
public void clearSignalers()
```
- 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.lang.AutoCloseable
  
  Specified by:
  
  close in interface java.io.Closeable
  
  Throws:
  
  java.io.IOException
- toString
```
public java.lang.String toString()
```
  Overrides:
  
  toString in class java.lang.Object