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]) @HotSpotIntrinsicCandidate() @native()
  8. val connectionProvider: AmqpConnectionProvider
    Definition Classes
    NamedQueueSourceSettings → AmqpConnectorSettings
  9. val consumerTag: String
  10. val declarations: Seq[Declaration]
    Definition Classes
    NamedQueueSourceSettings → AmqpConnectorSettings
  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. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  15. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  16. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  17. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  18. val noLocal: Boolean
  19. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  20. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  21. val queue: String
  22. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  23. def toString(): String
    Definition Classes
    NamedQueueSourceSettings → AnyRef → Any
  24. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  25. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  26. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  27. 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.

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

    Java API

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

    Java API

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

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

    (Since version 9)

Inherited from AmqpSourceSettings

Inherited from AmqpConnectorSettings

Inherited from AnyRef

Inherited from Any

Ungrouped