akka.amqp

AMQP

object AMQP extends AnyRef

AMQP Actor API. Implements Connection, Producer and Consumer materialized as Actors.

See also

akka.amqp.ExampleSession

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Hide All
  2. Show all
  1. AMQP
  2. AnyRef
  3. Any
Visibility
  1. Public
  2. All

Type Members

  1. class AMQPSupervisorActor extends Actor

    Main supervisor

  2. case class ActiveDeclaration (durable: Boolean, autoDelete: Boolean, exclusive: Boolean) extends Declaration with Product with Serializable

  3. case class ChannelParameters (shutdownListener: Option[ShutdownListener], channelCallback: Option[ActorRef], prefetchSize: Int) extends Product with Serializable

    Additional parameters for the channel

  4. case class ConnectionParameters (addresses: Array[Address], username: String, password: String, virtualHost: String, initReconnectDelay: Long, connectionCallback: Option[ActorRef]) extends Product with Serializable

    Parameters used to make the connection to the amqp broker.

  5. case class ConsumerParameters (routingKey: String, deliveryHandler: ActorRef, queueName: Option[String], exchangeParameters: Option[ExchangeParameters], queueDeclaration: Declaration, selfAcknowledging: Boolean, channelParameters: Option[ChannelParameters]) extends Product with Serializable

    Consumer specific parameters

  6. trait Declaration extends AnyRef

    Declaration type used for either exchange or queue declaration

  7. case class ExchangeParameters (exchangeName: String, exchangeType: ExchangeType, exchangeDeclaration: Declaration, configurationArguments: Map[String, AnyRef]) extends Product with Serializable

    Exchange specific parameters

  8. trait FromBinary [T] extends AnyRef

    Serialization stuff

  9. class ProducerClient [O] extends AnyRef

    Convenience

  10. case class ProducerParameters (exchangeParameters: Option[ExchangeParameters], producerId: Option[String], returnListener: Option[ReturnListener], channelParameters: Option[ChannelParameters], errorCallbackActor: Option[ActorRef]) extends Product with Serializable

    Producer specific parameters

  11. trait ToBinary [T] extends AnyRef

Value Members

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

    Attributes
    final
    Definition Classes
    AnyRef
  2. def != (arg0: Any): Boolean

    Attributes
    final
    Definition Classes
    Any
  3. def ## (): Int

    Attributes
    final
    Definition Classes
    AnyRef → Any
  4. def == (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  5. def == (arg0: Any): Boolean

    Attributes
    final
    Definition Classes
    Any
  6. object NoActionDeclaration extends Declaration with Product with Serializable

  7. object PassiveDeclaration extends Declaration with Product with Serializable

  8. def asInstanceOf [T0] : T0

    Attributes
    final
    Definition Classes
    Any
  9. def clone (): AnyRef

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  10. lazy val consumerDispatcher : MessageDispatcher

  11. def eq (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  12. def equals (arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  13. def finalize (): Unit

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  14. def getClass (): java.lang.Class[_]

    Attributes
    final
    Definition Classes
    AnyRef → Any
  15. def hashCode (): Int

    Definition Classes
    AnyRef → Any
  16. def isInstanceOf [T0] : Boolean

    Attributes
    final
    Definition Classes
    Any
  17. def ne (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  18. def newConnection (): ActorRef

  19. def newConnection (connectionParameters: ConnectionParameters = new ConnectionParameters()): ActorRef

  20. def newConsumer (connection: ActorRef, consumerParameters: ConsumerParameters): ActorRef

  21. def newProducer (connection: ActorRef, producerParameters: ProducerParameters): ActorRef

  22. def newProtobufConsumer [I <: Message] (connection: ActorRef, handler: (I) ⇒ Unit, exchangeName: Option[String], routingKey: Option[String], queueName: Option[String])(implicit manifest: Manifest[I]): ActorRef

  23. def newProtobufConsumer [I <: Message] (connection: ActorRef, handler: Procedure[I], exchangeName: String, routingKey: String, queueName: String, clazz: Class[I]): ActorRef

  24. def newProtobufConsumer [I <: Message] (connection: ActorRef, handler: Procedure[I], exchangeName: String, routingKey: String, clazz: Class[I]): ActorRef

  25. def newProtobufConsumer [I <: Message] (connection: ActorRef, handler: Procedure[I], exchangeName: String, clazz: Class[I]): ActorRef

  26. def newProtobufProducer [O <: Message] (connection: ActorRef, exchangeName: Option[String], routingKey: Option[String] = None, producerId: Option[String] = None): ProducerClient[O]

  27. def newProtobufProducer [O <: Message] (connection: ActorRef, exchangeName: String, routingKey: String, producerId: String): ProducerClient[O]

  28. def newProtobufProducer [O <: Message] (connection: ActorRef, exchangeName: String, routingKey: String): ProducerClient[O]

  29. def newProtobufProducer [O <: Message] (connection: ActorRef, exchangeName: String): ProducerClient[O]

  30. def newStringConsumer (connection: ActorRef, handler: (String) ⇒ Unit, exchangeName: Option[String], routingKey: Option[String] = None, queueName: Option[String] = None): ActorRef

  31. def newStringConsumer (connection: ActorRef, handler: Procedure[String], exchangeName: String, routingKey: String, queueName: String): ActorRef

  32. def newStringConsumer (connection: ActorRef, handler: Procedure[String], exchangeName: String, routingKey: String): ActorRef

  33. def newStringConsumer (connection: ActorRef, handler: Procedure[String], exchangeName: String): ActorRef

  34. def newStringProducer (connection: ActorRef, exchangeName: Option[String], routingKey: Option[String] = None, producerId: Option[String] = None): ProducerClient[String]

  35. def newStringProducer (connection: ActorRef, exchangeName: String, routingKey: String, producerId: String): ProducerClient[String]

  36. def newStringProducer (connection: ActorRef, exchangeName: String, routingKey: String): ProducerClient[String]

  37. def newStringProducer (connection: ActorRef, exchangeName: String): ProducerClient[String]

  38. def notify (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
  39. def notifyAll (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
  40. lazy val producerDispatcher : MessageDispatcher

  41. def shutdownAll (): Unit

  42. def synchronized [T0] (arg0: ⇒ T0): T0

    Attributes
    final
    Definition Classes
    AnyRef
  43. def toString (): String

    Definition Classes
    AnyRef → Any
  44. def wait (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()
  45. def wait (arg0: Long, arg1: Int): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()
  46. def wait (arg0: Long): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

Inherited from AnyRef

Inherited from Any