package rabbitmq

  1. Public
  2. All

Type Members

  1. case class Binding(source: String, vhost: String, destination: String, destination_type: String, routing_key: String, arguments: JsObject, properties_key: String) extends Product with Serializable

    RabbitMQ Bindings retrieve from management API *

  2. class EventFilter extends Actor

    Actual message on reply queue.

  3. class ExtractorsHeartbeats extends Actor

    Listen for heartbeats messages sent by extractors.

  4. class MsgConsumer extends DefaultConsumer

    Listen for responses coming back on replyQueue

  5. class PendingRequestCancellationActor extends Actor

    First, it will connect to the target rabbitmq queue to download each pending submission request and search the cancellation submission by comparing the message id of each pending submission request.

  6. class PublishDirectActor extends Actor

    Send message on specified channel directly to a queue and tells receiver to reply on specified queue.

  7. class RabbitmqExtractionBusService extends ExtractionBusService

    Rabbitmq service.