rad.services.msg.MsgReplier Class Reference

A protobuf-aware message replier. More...

Public Member Functions
def	__init__ (self, *str endpoint, list msg_types, handler, zmq.asyncio.Context zmq_ctx, asyncio.AbstractEventLoop loop, unknown_msg_handler=None)
bool	is_closed (self)
def	start (self)
	Starts accepting incoming requests. More...
def	send (self, bytes identity, msg)
	Send protobuf msg to identity. More...
def	stop (self)
	Unbinds socket and shuts down all related tasks to this Replier. More...

Detailed Description

A protobuf-aware message replier.

Constructor & Destructor Documentation

__init__()

def rad.services.msg.MsgReplier.__init__	(		self,
		*str	endpoint,
		list	msg_types,
			handler,
		zmq.asyncio.Context	zmq_ctx,
		asyncio.AbstractEventLoop	loop,
			unknown_msg_handler = None
	)

Member Function Documentation

is_closed()

bool rad.services.msg.MsgReplier.is_closed

(

self

)

send()

def rad.services.msg.MsgReplier.send	(		self,
		bytes	identity,
			msg
	)

Send protobuf msg to identity.

Returns

Future that resolves when message been sent.

start()

def rad.services.msg.MsgReplier.start

(

self

)

Starts accepting incoming requests.

stop()

def rad.services.msg.MsgReplier.stop

(

self

)

Unbinds socket and shuts down all related tasks to this Replier.

The ZmqMsgReplier is essentially dead after this.

see rad.services.msg.ZmqMsgReplier.stop.

---

The documentation for this class was generated from the following file:

• rad/py/rad/src/rad/services/msg.py