final class JmsConsumerSettings extends JmsSettings

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. JmsConsumerSettings
  2. JmsSettings
  3. AnyRef
  4. 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 ackTimeout: Duration
  5. val acknowledgeMode: Option[AcknowledgeMode]
  6. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  7. val bufferSize: Int
  8. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  9. val connectionFactory: ConnectionFactory
    Definition Classes
    JmsConsumerSettingsJmsSettings
  10. val connectionRetrySettings: ConnectionRetrySettings
    Definition Classes
    JmsConsumerSettingsJmsSettings
  11. val connectionStatusSubscriptionTimeout: FiniteDuration
    Definition Classes
    JmsConsumerSettingsJmsSettings
  12. val credentials: Option[Credentials]
    Definition Classes
    JmsConsumerSettingsJmsSettings
  13. val destination: Option[Destination]
    Definition Classes
    JmsConsumerSettingsJmsSettings
  14. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  15. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  16. val failStreamOnAckTimeout: Boolean
  17. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  18. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  19. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  20. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  21. val maxAckInterval: Option[FiniteDuration]
  22. val maxPendingAcks: Int
  23. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  24. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  25. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  26. val selector: Option[String]
  27. val sessionCount: Int
    Definition Classes
    JmsConsumerSettingsJmsSettings
  28. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  29. def toString(): String
    Definition Classes
    JmsConsumerSettings → AnyRef → Any
  30. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  31. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  32. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  33. def withAckTimeout(value: Duration): JmsConsumerSettings

    Java API: Timeout for acknowledge.

    Java API: Timeout for acknowledge. (Used by TX consumers.)

  34. def withAckTimeout(value: Duration): JmsConsumerSettings

    Timeout for acknowledge.

    Timeout for acknowledge. (Used by TX consumers.)

  35. def withAcknowledgeMode(value: AcknowledgeMode): JmsConsumerSettings

    Set an explicit acknowledge mode.

    Set an explicit acknowledge mode. (Consumers have specific defaults.)

  36. def withBufferSize(value: Int): JmsConsumerSettings

    Buffer size for maximum number for messages read from JMS when there is no demand.

  37. def withConnectionFactory(value: ConnectionFactory): JmsConsumerSettings

    Factory to use for creating JMS connections.

  38. def withConnectionRetrySettings(value: ConnectionRetrySettings): JmsConsumerSettings

    Configure connection retrying.

  39. def withConnectionStatusSubscriptionTimeout(value: Duration): JmsConsumerSettings

    Java API: Timeout for connection status subscriber

  40. def withConnectionStatusSubscriptionTimeout(value: FiniteDuration): JmsConsumerSettings

    Timeout for connection status subscriber

  41. def withCredentials(value: Credentials): JmsConsumerSettings

    Set JMS broker credentials.

  42. def withDestination(value: Destination): JmsConsumerSettings

    Set a JMS to subscribe to.

    Set a JMS to subscribe to. Allows for custom handling with CustomDestination.

  43. def withDurableTopic(name: String, subscriberName: String): JmsConsumerSettings

    Set a durable topic name to listen to, with a unique subscriber name.

  44. def withFailStreamOnAckTimeout(value: Boolean): JmsConsumerSettings

    For use with transactions, if true the stream fails if Alpakka rolls back the transaction when ackTimeout is hit.

  45. def withMaxAckInterval(value: Duration): JmsConsumerSettings

    Java API: Max interval before sending queued acknowledges back to the broker.

    Java API: Max interval before sending queued acknowledges back to the broker. (Used by AckSources.)

  46. def withMaxAckInterval(value: FiniteDuration): JmsConsumerSettings

    Max interval before sending queued acknowledges back to the broker.

    Max interval before sending queued acknowledges back to the broker. (Used by AckSources.)

  47. def withMaxPendingAcks(value: Int): JmsConsumerSettings

    Max number of acks queued by AckSource before they are sent to broker.

    Max number of acks queued by AckSource before they are sent to broker. (Unless MaxAckInterval is specified)

  48. def withQueue(name: String): JmsConsumerSettings

    Set a queue name to read from.

  49. def withSelector(value: String): JmsConsumerSettings

    JMS selector expression.

    JMS selector expression.

    See also

    https://docs.oracle.com/cd/E19798-01/821-1841/bncer/index.html

  50. def withSessionCount(value: Int): JmsConsumerSettings

    Number of parallel sessions to use for receiving JMS messages.

  51. def withTopic(name: String): JmsConsumerSettings

    Set a topic name to listen to.

Inherited from JmsSettings

Inherited from AnyRef

Inherited from Any

Ungrouped