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 Actor

    Actor to write consumer.

  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.

Value Members

  1. object PublishingHandler extends AnyRef

    Companion.

  2. object SubscribingHandler extends AnyRef

    Companion.