final class JmsProducerSettings extends JmsSettings
Settings for akka.stream.alpakka.jms.scaladsl.JmsProducer and akka.stream.alpakka.jms.javadsl.JmsProducer.
- Alphabetic
- By Inheritance
- JmsProducerSettings
- 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
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate() @throws( ... )
-
val
connectionFactory: ConnectionFactory
- Definition Classes
- JmsProducerSettings → JmsSettings
-
val
connectionRetrySettings: ConnectionRetrySettings
- 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: Any): Boolean
- Definition Classes
- AnyRef → Any
-
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
-
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 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(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
def
withConnectionFactory(value: ConnectionFactory): JmsProducerSettings
Factory to use for creating JMS connections.
-
def
withConnectionRetrySettings(value: ConnectionRetrySettings): JmsProducerSettings
Configure connection retrying.
-
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.
Deprecated Value Members
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @Deprecated @deprecated @throws( classOf[java.lang.Throwable] )
- Deprecated
(Since version ) see corresponding Javadoc for more information.
-
def
withCredential(value: Credentials): JmsProducerSettings
- Annotations
- @deprecated
- Deprecated
(Since version 1.0-M1) use withCredentials instead