amqp

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