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

   JmsConsumerSettings → JmsSettings

10.  val connectionRetrySettings: ConnectionRetrySettings

    Definition Classes

    JmsConsumerSettings → JmsSettings

11.  val connectionStatusSubscriptionTimeout: FiniteDuration

    Definition Classes

    JmsConsumerSettings → JmsSettings

12.  val credentials: Option[Credentials]

    Definition Classes

    JmsConsumerSettings → JmsSettings

13.  val destination: Option[Destination]

    Definition Classes

    JmsConsumerSettings → JmsSettings

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

    JmsConsumerSettings → JmsSettings

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.