widebase.stream.handler

rq

package rq

Visibility
  1. Public
  2. All

Type Members

  1. class ConsumerHandler extends SimpleChannelUpstreamHandler with Logger

    Handles consumer.

  2. class ConsumerWriter extends Thread

    A consumer writer.

  3. trait PersistenceHandler extends AnyRef

    Handles rollback tables.

  4. class PersistenceWriter extends AnyRef

    A persistence writer.

  5. class PublishingHandler extends SimpleChannelUpstreamHandler with Logger with PersistenceHandler

    Handles publishers.

  6. trait RecordListener extends AnyRef

    A trait to build record listeners.

  7. class SubscribingHandler extends SimpleChannelUpstreamHandler with Logger

    Handles subscriptions.