final class NamedQueueSourceSettings extends AmqpSourceSettings

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. NamedQueueSourceSettings
  2. AmqpSourceSettings
  3. AmqpConnectorSettings
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. val ackRequired: Boolean
  5. val arguments: Map[String, AnyRef]
  6. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  7. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  8. val connectionProvider: AmqpConnectionProvider
  9. val consumerTag: String
  10. val declarations: Seq[Declaration]
  11. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  12. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  13. val exclusive: Boolean
  14. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  15. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  16. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  17. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  18. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  19. val noLocal: Boolean
  20. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  21. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  22. val queue: String
  23. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  24. def toString(): String
    Definition Classes
    NamedQueueSourceSettings → AnyRef → Any
  25. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  26. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  27. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  28. def withAckRequired(ackRequired: Boolean): NamedQueueSourceSettings

    Ack/Nack is required as default.

    Ack/Nack is required as default. Setting this to false will configure AMQP's autoAck so that the server considers messages acknowledged once delivered.

  29. def withArguments(arguments: Map[String, AnyRef]): NamedQueueSourceSettings

    Java API

  30. def withArguments(arguments: Map[String, AnyRef]): NamedQueueSourceSettings
  31. def withConsumerTag(consumerTag: String): NamedQueueSourceSettings
  32. def withDeclaration(declaration: Declaration): NamedQueueSourceSettings
  33. def withDeclarations(declarations: List[Declaration]): NamedQueueSourceSettings

    Java API

  34. def withDeclarations(declarations: Seq[Declaration]): NamedQueueSourceSettings
  35. def withExclusive(exclusive: Boolean): NamedQueueSourceSettings
  36. def withNoLocal(noLocal: Boolean): NamedQueueSourceSettings

Inherited from AmqpSourceSettings

Inherited from AmqpConnectorSettings

Inherited from AnyRef

Inherited from Any

Ungrouped