The ZMQ channel to subscribe to.
The hostname of the publisher socket.
The hostname of the publisher socket. They should implement a ZMQ_PUB socket.
If you connect too localhost, do not use localhost
but 127.0.0.1
instead.
The port of the publisher socket.
The port of the publisher socket. They should implement a ZMQ_PUB socket.
Listens to publishes message and publishes them as bbuzz.Tweets.
Listens to publishes message and publishes them as bbuzz.Tweets.
As calls to ZMQ
s recv method on sockets can block, this will do so in a new Thread.
an Observable
of Tweets
Provides tweets by listening on a ZeroMQ SUB socket.
ZMQ message are picked from a ZMQ_SUB socket. These messages can consist of multiple parts, where the first part is the channel name and the second part is the actual message.
The connection is always made over tcp.