Fan messages from many publishers out to many subscribers. More...
Public Member Functions | |
| None | run (self) |
Run the forwarding broker until :meth:close requests shutdown. | |
| None | close (self) |
| Request broker shutdown without touching another thread's sockets. | |
Fan messages from many publishers out to many subscribers.
| None messaging.zeromq.broker.ZeroMqBroker.run | ( | self | ) |
Run the forwarding broker until :meth:close requests shutdown.
The ZeroMQ context and sockets are created and destroyed on this thread so callers may safely run the broker in either the foreground or a dedicated Python thread.