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
- All
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( ... ) @native() @HotSpotIntrinsicCandidate()
-
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: Any): Boolean
- Definition Classes
- AnyRef → Any
- val failStreamOnAckTimeout: Boolean
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
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() @HotSpotIntrinsicCandidate()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- 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(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
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.