Directives

Type Members

case class Ackable(handler: Handler) extends Product with Serializable

Value Members

final def !=(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def ##(): Int

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

Definition Classes
AnyRef → Any
object Ackable extends (Handler) ⇒ Ackable with Serializable
def ack: Handler

Definition Classes
Directives
def ack(f: Ackable): Handler

Ack the message
Ack the message
Examples:
```
ack()

ack(Future {
  //Some work
})
```
Note that in the case of acking with a Future, if the Future fails, then the message is counted as erroneous, and the RecoveryStrategy is use is applied.
Definition Classes
Directives
def as[T](implicit um: RabbitUnmarshaller[T]): RabbitUnmarshaller[T]

Definition Classes
Directives
final def asInstanceOf[T0]: T0

Definition Classes
Any
def body[T](um: RabbitUnmarshaller[T]): Directive1[T]

Extract the message body.
Extract the message body. Uses a RabbitUnmarshaller to deserialize.
Example:
```
body(as[JobDescription])
```
Definition Classes
Directives
def channel(qos: Int = 1): ChannelDirective

Declarative which declares a channel
Declarative which declares a channel

Definition Classes
Directives
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
def consume(binding: QueueDefinition[Concreteness], args: Seq[Header] = Seq(), consumerTagPrefix: Option[String] = None): BindingDirective

Declarative which declares a consumer
Declarative which declares a consumer

Definition Classes
Directives
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def equals(arg0: Any): Boolean

Definition Classes
AnyRef → Any
def exchange: Directive1[String]

Directive which yields the exchange through which the message was published
Directive which yields the exchange through which the message was published

Definition Classes
Directives
def extract[T](map: (Delivery) ⇒ T): Directive1[T]

Extract any arbitrary value from the delivery / Java RabbitMQ objects.
Extract any arbitrary value from the delivery / Java RabbitMQ objects. Accepts a function which receives a Delivery and returns some value.

Definition Classes
Directives
def extractEither[T](map: (Delivery) ⇒ Either[Rejection, T]): Directive1[T]

Like extract, but the provided function should return an Either, with left for a rejection, right for success.
Like extract, but the provided function should return an Either, with left for a rejection, right for success.

Definition Classes
Directives
def fail(ex: Throwable): Handler

Fail the given element
Fail the given element

Definition Classes
Directives
def finalize(): Unit

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

Definition Classes
AnyRef → Any
def hashCode(): Int

Definition Classes
AnyRef → Any
def hprovide[T <: HList](value: T): Directive[T]

Definition Classes
Directives
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
def isRedeliver: Directive1[Boolean]

Directive which yields whether this message been delivered once before (although, not necessarily received)
Directive which yields whether this message been delivered once before (although, not necessarily received)

Definition Classes
Directives
def nack(requeue: Boolean = false): Handler

Nack the message; does NOT trigger the RecoveryStrategy in use.
Nack the message; does NOT trigger the RecoveryStrategy in use.

Definition Classes
Directives
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
def optionalProperty[T](extractor: PropertyExtractor[T]): Directive1[Option[T]]

Given a property, yields Some(value).
Given a property, yields Some(value). If the underlying value does not exist (is null), then it yields None.

Definition Classes
Directives
def passive[T <: Exchange.Value](exchange: Exchange[T]): Exchange[T]

Definition Classes
Directives
def passive[T <: Concreteness](queue: QueueDefinition[T]): QueueDefinition[T]

Passive topic binding
Passive topic binding

Definition Classes
Directives
def pqueue(queue: String): QueueDefinition[Concrete]

Passive queue binding
Passive queue binding

Definition Classes
Directives
def property[T](extractor: PropertyExtractor[T]): Directive1[T]

Given a property, yields it's value.
Given a property, yields it's value. If the underlying value does not exist (is null), then it nacks.

Definition Classes
Directives
def provide[T](value: T): Directive[::[T, HNil]]

Definition Classes
Directives
def queue(queue: String, durable: Boolean = true, exclusive: Boolean = false, autoDelete: Boolean = false): QueueDefinition[Concrete]

Provides values for the consume directive.
Provides values for the consume directive.

Definition Classes
Directives
def routingKey: Directive1[String]

Directive which yields the routingKey (topic) through which the message was published
Directive which yields the routingKey (topic) through which the message was published

Definition Classes
Directives
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
def toString(): String

Definition Classes
AnyRef → Any
def topic(queue: QueueDefinition[Concrete], topics: List[String], exchange: Exchange[Topic.type] = ...): Binding

Definition Classes
Directives
def typeOf[T]: TypeHolder[T]

Definition Classes
Directives
final def wait(): Unit

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

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

Definition Classes
AnyRef
Annotations
@throws( ... )

Related Docs: trait Directives | package op_rabbit

object Directives extends Directives

Type Members

case class Ackable(handler: Handler) extends Product with Serializable

Value Members

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

object Ackable extends (Handler) ⇒ Ackable with Serializable

def ack: Handler

def ack(f: Ackable): Handler

def as[T](implicit um: RabbitUnmarshaller[T]): RabbitUnmarshaller[T]

final def asInstanceOf[T0]: T0

def body[T](um: RabbitUnmarshaller[T]): Directive1[T]

def channel(qos: Int = 1): ChannelDirective

def clone(): AnyRef

def consume(binding: QueueDefinition[Concreteness], args: Seq[Header] = Seq(), consumerTagPrefix: Option[String] = None): BindingDirective

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def exchange: Directive1[String]

def extract[T](map: (Delivery) ⇒ T): Directive1[T]

def extractEither[T](map: (Delivery) ⇒ Either[Rejection, T]): Directive1[T]

def fail(ex: Throwable): Handler

def finalize(): Unit

final def getClass(): Class[_]

def hashCode(): Int

def hprovide[T <: HList](value: T): Directive[T]

final def isInstanceOf[T0]: Boolean

def isRedeliver: Directive1[Boolean]

def nack(requeue: Boolean = false): Handler

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

def optionalProperty[T](extractor: PropertyExtractor[T]): Directive1[Option[T]]

def passive[T <: Exchange.Value](exchange: Exchange[T]): Exchange[T]

def passive[T <: Concreteness](queue: QueueDefinition[T]): QueueDefinition[T]

def pqueue(queue: String): QueueDefinition[Concrete]

def property[T](extractor: PropertyExtractor[T]): Directive1[T]

def provide[T](value: T): Directive[::[T, HNil]]

def queue(queue: String, durable: Boolean = true, exclusive: Boolean = false, autoDelete: Boolean = false): QueueDefinition[Concrete]

def routingKey: Directive1[String]

final def synchronized[T0](arg0: ⇒ T0): T0

def toString(): String

def topic(queue: QueueDefinition[Concrete], topics: List[String], exchange: Exchange[Topic.type] = ...): Binding

def typeOf[T]: TypeHolder[T]

final def wait(): Unit

final def wait(arg0: Long, arg1: Int): Unit

final def wait(arg0: Long): Unit

Inherited from Directives

Inherited from AnyRef

Inherited from Any

Ungrouped