final class JmsConsumerSettings extends JmsSettings
Settings for akka.stream.alpakka.jms.scaladsl.JmsConsumer and akka.stream.alpakka.jms.javadsl.JmsConsumer.
- Alphabetic
- By Inheritance
- JmsConsumerSettings
- JmsSettings
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
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
- val ackTimeout: Duration
- val acknowledgeMode: Option[AcknowledgeMode]
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- val bufferSize: Int
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- val connectionFactory: ConnectionFactory
- Definition Classes
- JmsConsumerSettings → JmsSettings
- val connectionRetrySettings: ConnectionRetrySettings
- Definition Classes
- JmsConsumerSettings → JmsSettings
- val connectionStatusSubscriptionTimeout: FiniteDuration
- Definition Classes
- JmsConsumerSettings → JmsSettings
- val credentials: Option[Credentials]
- Definition Classes
- JmsConsumerSettings → JmsSettings
- val destination: Option[Destination]
- Definition Classes
- JmsConsumerSettings → JmsSettings
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- val failStreamOnAckTimeout: Boolean
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- val maxAckInterval: Option[FiniteDuration]
- val maxPendingAcks: Int
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- val selector: Option[String]
- val sessionCount: Int
- Definition Classes
- JmsConsumerSettings → JmsSettings
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- JmsConsumerSettings → AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- def withAckTimeout(value: Duration): JmsConsumerSettings
Java API: Timeout for acknowledge.
Java API: Timeout for acknowledge. (Used by TX consumers.)
- def withAckTimeout(value: Duration): JmsConsumerSettings
Timeout for acknowledge.
Timeout for acknowledge. (Used by TX consumers.)
- def withAcknowledgeMode(value: AcknowledgeMode): JmsConsumerSettings
Set an explicit acknowledge mode.
Set an explicit acknowledge mode. (Consumers have specific defaults.)
- def withBufferSize(value: Int): JmsConsumerSettings
Buffer size for maximum number for messages read from JMS when there is no demand.
- def withConnectionFactory(value: ConnectionFactory): JmsConsumerSettings
Factory to use for creating JMS connections.
- def withConnectionRetrySettings(value: ConnectionRetrySettings): JmsConsumerSettings
Configure connection retrying.
- def withConnectionStatusSubscriptionTimeout(value: Duration): JmsConsumerSettings
Java API: Timeout for connection status subscriber
- def withConnectionStatusSubscriptionTimeout(value: FiniteDuration): JmsConsumerSettings
Timeout for connection status subscriber
- def withCredentials(value: Credentials): JmsConsumerSettings
Set JMS broker credentials.
- def withDestination(value: Destination): JmsConsumerSettings
Set a JMS to subscribe to.
Set a JMS to subscribe to. Allows for custom handling with CustomDestination.
- def withDurableTopic(name: String, subscriberName: String): JmsConsumerSettings
Set a durable topic name to listen to, with a unique subscriber name.
- def withFailStreamOnAckTimeout(value: Boolean): JmsConsumerSettings
For use with transactions, if true the stream fails if Alpakka rolls back the transaction when
ackTimeout
is hit. - 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.)
- 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.)
- 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)
- def withQueue(name: String): JmsConsumerSettings
Set a queue name to read from.
- 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
- def withSessionCount(value: Int): JmsConsumerSettings
Number of parallel sessions to use for receiving JMS messages.
- def withTopic(name: String): JmsConsumerSettings
Set a topic name to listen to.