org.apache.pekko.stream.connectors.jakartams
JmsProducerSettings
Companion object JmsProducerSettings
final class JmsProducerSettings extends JmsSettings
Settings for pekko.stream.connectors.jakartams.scaladsl.JmsProducer and pekko.stream.connectors.jakartams.javadsl.JmsProducer.
- Alphabetic
- By Inheritance
- JmsProducerSettings
- 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
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- val connectionFactory: ConnectionFactory
- Definition Classes
- JmsProducerSettings → JmsSettings
- val connectionRetrySettings: ConnectionRetrySettings
- Definition Classes
- JmsProducerSettings → JmsSettings
- val connectionStatusSubscriptionTimeout: FiniteDuration
- Definition Classes
- JmsProducerSettings → JmsSettings
- val credentials: Option[Credentials]
- Definition Classes
- JmsProducerSettings → JmsSettings
- val destination: Option[Destination]
- Definition Classes
- JmsProducerSettings → JmsSettings
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- 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
- 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 sendRetrySettings: SendRetrySettings
- val sessionCount: Int
- Definition Classes
- JmsProducerSettings → JmsSettings
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- val timeToLive: Option[Duration]
- def toString(): String
- Definition Classes
- JmsProducerSettings → 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 withConnectionFactory(value: ConnectionFactory): JmsProducerSettings
Factory to use for creating JMS connections.
- def withConnectionRetrySettings(value: ConnectionRetrySettings): JmsProducerSettings
Configure connection retrying.
- def withConnectionStatusSubscriptionTimeout(value: Duration): JmsProducerSettings
Java API: Timeout for connection status subscriber
- def withConnectionStatusSubscriptionTimeout(value: FiniteDuration): JmsProducerSettings
Timeout for connection status subscriber
- def withCredentials(value: Credentials): JmsProducerSettings
Set JMS broker credentials.
- def withDestination(value: Destination): JmsProducerSettings
Set a JMS destination.
Set a JMS destination. Allows for custom handling with CustomDestination.
- def withQueue(name: String): JmsProducerSettings
Set a queue name as JMS destination.
- def withSendRetrySettings(value: SendRetrySettings): JmsProducerSettings
Configure re-sending.
- def withSessionCount(value: Int): JmsProducerSettings
Number of parallel sessions to use for sending JMS messages.
Number of parallel sessions to use for sending JMS messages. Increasing the number of parallel sessions increases throughput at the cost of message ordering. While the messages may arrive out of order on the JMS broker, the producer flow outputs messages in the order they are received.
- def withTimeToLive(value: Duration): JmsProducerSettings
Java API: Time messages should be kept on the JMS broker.
Java API: Time messages should be kept on the JMS broker. This setting can be overridden on individual messages. If not set, messages will never expire.
- def withTimeToLive(value: Duration): JmsProducerSettings
Time messages should be kept on the JMS broker.
Time messages should be kept on the JMS broker. This setting can be overridden on individual messages. If not set, messages will never expire.
- def withTopic(name: String): JmsProducerSettings
Set a topic name as JMS destination.