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...

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() [1/2]

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`
	)

◆ init() [2/2]

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() [1/2]

bool rad.services.msg.MsgReplier.is_closed ( self )

◆ is_closed() [2/2]

bool rad.services.msg.MsgReplier.is_closed ( self )

◆ send() [1/2]

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

Send protobuf msg to identity.

Returns: Future that resolves when message been sent.

◆ send() [2/2]

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

Send protobuf msg to identity.

Returns: Future that resolves when message been sent.

◆ start() [1/2]

def rad.services.msg.MsgReplier.start ( self )

Starts accepting incoming requests.

◆ start() [2/2]

def rad.services.msg.MsgReplier.start ( self )

Starts accepting incoming requests.

◆ stop() [1/2]

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.

◆ stop() [2/2]