receiver – Receiver

The receiver is responsible for receiveing messages

class eventmq.receiver.Receiver(*args, **kwargs)

Receives messages and pass them to a on_recv.

name

str

Name of this socket

zcontext

zmq.Context

socket context

zsocket

zmq.Socket

__init__(*args, **kwargs)

Note

All args are optional unless otherwise noted.

Parameters:

• name (str) – name of this socket. By default a uuid will be generated
• context (zmq.Context) – Context to use when buliding the socket
• socket (zmq.Socket) – Should be one of zmq.REP or zmq.ROUTER. By default a ROUTER is used

Raises:

:class – TypeError: when callable is not callable

connect(addr=None)

Connect to address defined by addr

Parameters:addr (str) – Address to connect to as a connection string Raises::class – Exception

listen(addr=None)

start listening on addr

Parameters:addr (str) – Address to listen on as a connction string Raises::class – Exception

ready

Property used to check if this receiver is ready.

Returns:True if the receiver is ready to connect or listen, otherwise False Return type:bool

unbind(addr)

Unbinds current socket

Parameters:addr (str) – Address to disconnect from as a string Raises::class – Exception