akka

amqp

package amqp

Visibility
  1. Public
  2. All

Type Members

  1. trait AMQPMessage extends AnyRef

    Attributes
    sealed
  2. case class Acknowledge (deliveryTag: Long) extends AMQPMessage with Product with Serializable

  3. case class Acknowledged (deliveryTag: Long) extends AMQPMessage with Product with Serializable

  4. class AkkaAmqp extends AnyRef

    Attributes
    final
  5. case class ChannelShutdown (cause: ShutdownSignalException) extends InternalAMQPMessage with Product with Serializable

  6. case class ConnectionShutdown (cause: ShutdownSignalException) extends InternalAMQPMessage with Product with Serializable

  7. case class CustomExchange (exchangeType: String) extends ExchangeType with Product with Serializable

  8. case class Delivery (payload: Array[Byte], routingKey: String, deliveryTag: Long, isRedeliver: Boolean, properties: BasicProperties, sender: Option[ActorRef]) extends AMQPMessage with Product with Serializable

  9. class ExampleSessionJava extends AnyRef

  10. trait ExchangeType extends AnyRef

    Attributes
    sealed
  11. trait InternalAMQPMessage extends AMQPMessage

    Attributes
    sealed
  12. case class Message (payload: Array[Byte], routingKey: String, mandatory: Boolean, immediate: Boolean, properties: Option[BasicProperties]) extends AMQPMessage with Product with Serializable

  13. case class Reject (deliveryTag: Long, requeue: Boolean) extends AMQPMessage with Product with Serializable

  14. case class Rejected (deliveryTag: Long) extends AMQPMessage with Product with Serializable

  15. class RpcClientActor [I, O] extends FaultTolerantChannelActor

  16. class RpcServerActor [I, O] extends Actor

Value Members

  1. object AMQP extends AnyRef

    AMQP Actor API.

  2. object AkkaAmqp extends

  3. object ChannelRequest extends InternalAMQPMessage with Product with Serializable

  4. object Connect extends AMQPMessage with Product with Serializable

  5. object Connected extends AMQPMessage with Product with Serializable

  6. object Direct extends ExchangeType with Product with Serializable

  7. object Disconnected extends AMQPMessage with Product with Serializable

  8. object ExampleSession extends AnyRef

  9. object ExampleSessionJava extends

  10. object Fanout extends ExchangeType with Product with Serializable

  11. object Match extends ExchangeType with Product with Serializable

  12. object Reconnecting extends AMQPMessage with Product with Serializable

  13. object Restarting extends AMQPMessage with Product with Serializable

  14. object Start extends AMQPMessage with Product with Serializable

  15. object Started extends AMQPMessage with Product with Serializable

  16. object Stopped extends AMQPMessage with Product with Serializable

  17. object Topic extends ExchangeType with Product with Serializable

  18. package rpc