ZeromqPrinter

Value Members

1. final def !=(arg0: AnyRef): Boolean

   Definition Classes

   AnyRef

2. final def !=(arg0: Any): Boolean

   Definition Classes

   Any

3. final def ##(): Int

   Definition Classes

   AnyRef → Any

4. final def ==(arg0: AnyRef): Boolean

   Definition Classes

   AnyRef

5. final def ==(arg0: Any): Boolean

   Definition Classes

   Any

6. final def asInstanceOf[T0]: T0

   Definition Classes

   Any

7. def channel: String

   The ZMQ channel to subscribe to.

   The ZMQ channel to subscribe to.

   Definition Classes

   ZeromqPrinter → ZeroMqTweets

8. def clone(): AnyRef

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... )

9. final def eq(arg0: AnyRef): Boolean

   Definition Classes

   AnyRef

10. def equals(arg0: Any): Boolean

    Definition Classes

    AnyRef → Any

11. def finalize(): Unit

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

12. final def getClass(): Class[_]

    Definition Classes

    AnyRef → Any

13. def handleException(exception: Throwable): Unit

    Gets called when an exception occurred during providing the Tweets.

    Gets called when an exception occurred during providing the Tweets. This will be a fatal exception, and tweets will not continue to flow after this exception occurred.

    exception

    the fatal exception

    Definition Classes

    PrintHashTags → TweetConsumer

14. def hashCode(): Int

    Definition Classes

    AnyRef → Any

15. def host: String

    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.

    Definition Classes

    ZeromqPrinter → ZeroMqTweets

16. final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

17. final def main(args: Array[String]): Unit

    Definition Classes

    TweetStreaming

18. final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

19. final def notify(): Unit

    Definition Classes

    AnyRef

20. final def notifyAll(): Unit

    Definition Classes

    AnyRef

21. final def onCompleted(): Unit

    Definition Classes

    TweetConsumer → Observer

22. final def onError(error: Throwable): Unit

    Definition Classes

    TweetConsumer → Observer

23. final def onNext(value: Tweet): Unit

    Definition Classes

    TweetConsumer → Observer

24. def onTweet(tweet: Tweet): Unit

    Gets called for every tweet that is pulled from the bbuzz.TweetProvider.

    Gets called for every tweet that is pulled from the bbuzz.TweetProvider. This method should not block and complete quickly.

    tweet

    a new bbuzz.Tweet

    Definition Classes

    PrintHashTags → TweetConsumer

25. def port: Int

    The port of the publisher socket.

    The port of the publisher socket. They should implement a ZMQ_PUB socket.

    Definition Classes

    ZeromqPrinter → ZeroMqTweets

26. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes

    AnyRef

27. def toString(): String

    Definition Classes

    AnyRef → Any

28. final def tweets: TweetObservable

    Listens to publishes message and publishes them as bbuzz.Tweets.

    Listens to publishes message and publishes them as bbuzz.Tweets. As calls to ZMQs recv method on sockets can block, this will do so in a new Thread.

    returns

    an Observable of Tweets

    Definition Classes

    ZeroMqTweets → TweetProvider

29. final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

30. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

31. final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )