Monitor remote message streams.
This is a bridge service which forwards various remote stream
streams to local listeners. It keeps only one connection open
to the remote stream server regardless of how many streams are
listening.
The interface is identical to the MessageStream interface, other
than the constructor and destructor. The remote stream has a
close method that should be called explicitly.
|
|
__init__(self,
server=None)
x.__init__(...) initializes x; see x.__class__.__doc__ for signature |
source code
|
|
|
|
close(self)
Close the remote streamer and detach all associated listeners. |
source code
|
|
|
|
|
|
|
header(self,
stream,
message)
Record a new header for a stream. |
source code
|
|
|
|
|
|
|
put(self,
stream,
message)
Post a message on stream. |
source code
|
|
|
|
listen(self,
stream,
queue)
Start listening on a stream. |
source code
|
|
|
|
hangup(self,
stream,
queue)
Stop listening on stream. |
source code
|
|
|
|
endqueue(self,
queue)
Stop all listeners for queue. |
source code
|
|
|
Inherited from object:
__delattr__,
__getattribute__,
__hash__,
__new__,
__reduce__,
__reduce_ex__,
__repr__,
__setattr__,
__str__
|
