org.zeromq

Class ZMQ.Context

java.lang.Object

org.zeromq.ZMQ.Context

All Implemented Interfaces:

Closeable, AutoCloseable

Enclosing class:

ZMQ

public static class ZMQ.Context
extends Object
implements Closeable

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ZMQ.Context(int ioThreads) Class constructor.

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
boolean	close(Selector selector) Closes a Selector that was created within this context.
boolean	getBlocky() Deprecated. use isBlocky() instead
int	getIOThreads() The size of the 0MQ thread pool to handle I/O operations.
boolean	getIPv6()
int	getMaxSockets() The maximum number of sockets allowed on the context
boolean	isBlocky()
boolean	isClosed()
boolean	isIPv6()
boolean	isTerminated() Returns true if terminate() has been called on ctx.
ZMQ.Poller	poller() Create a new Poller within this context, with a default size.
ZMQ.Poller	poller(int size) Create a new Poller within this context, with a specified initial size.
Selector	selector() Create a new Selector within this context.
boolean	setBlocky(boolean block)
boolean	setIOThreads(int ioThreads) Set the size of the 0MQ thread pool to handle I/O operations.
boolean	setIPv6(boolean ipv6)
boolean	setMaxSockets(int maxSockets) Sets the maximum number of sockets allowed on the context
ZMQ.Socket	socket(int type) Create a new Socket within this context.
void	term() This is an explicit "destructor".

Methods inherited from class java.lang.Object

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

Constructor Detail

ZMQ.Context

protected ZMQ.Context(int ioThreads)

Class constructor.

Parameters:

ioThreads - size of the threads pool to handle I/O operations.

Method Detail

isTerminated

public boolean isTerminated()

Returns true if terminate() has been called on ctx.

getIOThreads

public int getIOThreads()

The size of the 0MQ thread pool to handle I/O operations.

setIOThreads

public boolean setIOThreads(int ioThreads)

Set the size of the 0MQ thread pool to handle I/O operations.

getMaxSockets

public int getMaxSockets()

The maximum number of sockets allowed on the context

setMaxSockets

public boolean setMaxSockets(int maxSockets)

Sets the maximum number of sockets allowed on the context

getBlocky

@Deprecated
public boolean getBlocky()

Deprecated. use isBlocky() instead

isBlocky

public boolean isBlocky()

setBlocky

public boolean setBlocky(boolean block)

isIPv6

public boolean isIPv6()

getIPv6

public boolean getIPv6()

setIPv6

public boolean setIPv6(boolean ipv6)

term

public void term()

This is an explicit "destructor". It can be called to ensure the corresponding 0MQ Context has been disposed of.

isClosed

public boolean isClosed()

socket

public ZMQ.Socket socket(int type)

Create a new Socket within this context.

Parameters:

type - the socket type.

Returns:

the newly created Socket.

selector

public Selector selector()

Create a new Selector within this context.

Returns:

the newly created Selector.

close

public boolean close(Selector selector)

Closes a Selector that was created within this context.

Parameters:

selector - the Selector to close.

Returns:

true if the selector was closed. otherwise false (mostly because it was not created by the context).

poller

public ZMQ.Poller poller()

Create a new Poller within this context, with a default size. DO NOT FORGET TO CLOSE THE POLLER AFTER USE with ZMQ.Poller.close()

Returns:

the newly created Poller.

poller

public ZMQ.Poller poller(int size)

Create a new Poller within this context, with a specified initial size. DO NOT FORGET TO CLOSE THE POLLER AFTER USE with ZMQ.Poller.close()

Parameters:

size - the poller initial size.

Returns:

the newly created Poller.

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable