Publishers and Subscribers

Publisher Interface

class zircon.publishers.base.BasePublisher

Abstract base class defining the Publisher interface.

A Publisher broadcasts data in some form, to be picked up by one or more Subscribers. It is used by Reporters to communicate with Injectors.

Usage:

p = MyPublisher()
p.open()

while not done:
    msg = get_data()
    p.send(msg)

p.close()

open()

Open the connection.

close()

Close the connection.

send(msg)

Broadcast a message.

Subscriber Interface

class zircon.subscribers.base.BaseSubscriber

Abstract base class defining the Subscriber interface.

A Subscriber receives data from a Publisher. It is used by Injectors to listen to Reporters.

Usage:

s = MySubscriber()
s.open()

while not done:
    msg = s.receive()
    process(msg)

p.close()

open()

Open the connection.

close()

Close the connection.

receive()

Receive a message.