rad.services.pubsub.Publisher Class Reference

Publisher provides the capability to publish protobuf topics over ZMQ. More...

Public Member Functions
def	__init__ (self, *str endpoint, zmq.asyncio.Context zmq_ctx, asyncio.AbstractEventLoop loop=None)
def	stop (self)
	Stop publisher. More...
asyncio.Future	publish (self, str topic_name, google.protobuf.message.Message topic)
	Publish topic under name topic_name. More...
def	__init__ (self, *str endpoint, zmq.asyncio.Context zmq_ctx, asyncio.AbstractEventLoop loop=None)
def	stop (self)
	Stop publisher. More...
asyncio.Future	publish (self, str topic_name, google.protobuf.message.Message topic)
	Publish topic under name topic_name. More...

Detailed Description

Publisher provides the capability to publish protobuf topics over ZMQ.

Constructor & Destructor Documentation

__init__() [1/2]

def rad.services.pubsub.Publisher.__init__	(		self,
		*str	endpoint,
		zmq.asyncio.Context	zmq_ctx,
		asyncio.AbstractEventLoop	loop = None
	)

__init__() [2/2]

def rad.services.pubsub.Publisher.__init__	(		self,
		*str	endpoint,
		zmq.asyncio.Context	zmq_ctx,
		asyncio.AbstractEventLoop	loop = None
	)

Member Function Documentation

publish() [1/2]

asyncio.Future rad.services.pubsub.Publisher.publish	(		self,
		str	topic_name,
		google.protobuf.message.Message	topic
	)

Publish topic under name topic_name.

Returns Future that resolves once topic has been published.

publish() [2/2]

asyncio.Future rad.services.pubsub.Publisher.publish	(		self,
		str	topic_name,
		google.protobuf.message.Message	topic
	)

Publish topic under name topic_name.

Returns Future that resolves once topic has been published.

stop() [1/2]

def rad.services.pubsub.Publisher.stop

(

self

)

Stop publisher.

Closes socket

stop() [2/2]

def rad.services.pubsub.Publisher.stop

(

self

)

Stop publisher.

Closes socket

---

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

• INTROOT/lib/python3.7/site-packages/rad/services/pubsub.py