SocketComm

class akkits.utils.zmq.SocketComm(context, addr, socket_type, connect_type, high_water_mark=1, ssh_server='', name='')

Bases: object

__init__(context, addr, socket_type, connect_type, high_water_mark=1, ssh_server='', name='')

Creates a SocketComm object that wraps a ZMQ Socket.

Parameters

• context (zmq.Context) – ZMQ Context.

• addr (str) – The socket address (including port).

• socket_type (int) – Socket type SocketType.

• connect_type (int) – Connection type ConnType.

• high_water_mark (int, optional) – High water mark. Defaults to 1. If it is 1 and the socket type is PUB/SUB, then CONFLATE will be set to True.

• ssh_server (str, optional) – SSH server address for tunnelling. Defaults to “”.

• name (str, optional) – A name for this object. Defaults to “”.