Type Members

1.  case class AckEnvelope extends Product with Serializable
2.  final class AcknowledgeMode extends AnyRef

   JMS acknowledge modes.

   JMS acknowledge modes. See javax.jms.Connection#createSession-boolean-int-

3.  case class ConnectionRetryException(message: String, cause: Throwable) extends Exception with Product with Serializable
4.  final class ConnectionRetrySettings extends AnyRef

   When a connection to a broker cannot be established and errors out, or is timing out being established or started, the connection can be retried.

   When a connection to a broker cannot be established and errors out, or is timing out being established or started, the connection can be retried. All JMS publishers, consumers, and browsers are configured with connection retry settings.

5.  final class Credentials extends AnyRef
6.  final case class CustomDestination(name: String, create: (Session) => javax.jms.Destination) extends Destination with Product with Serializable

   Destination factory to create specific destinations to send to/receive from.

7.  sealed abstract class Destination extends AnyRef

   A destination to send to/receive from.

8.  final case class DurableTopic(name: String, subscriberName: String) extends Destination with Product with Serializable

   Specify a durable topic destination to send to/receive from.

9.  final class JmsBrowseSettings extends AnyRef

   Settings for pekko.stream.connectors.jms.scaladsl.JmsConsumer.browse and pekko.stream.connectors.jms.javadsl.JmsConsumer.browse.

10.  final class JmsByteMessage extends JmsByteMessagePassThrough[NotUsed] with JmsMessage

    Produces byte arrays to JMS.

11.  sealed class JmsByteMessagePassThrough[+PassThrough] extends JmsEnvelope[PassThrough] with JmsEnvelopeWithProperties[PassThrough]

    Produces byte arrays to JMS, supports pass-through data.

    Produces byte arrays to JMS, supports pass-through data.

    PassThrough

    the type of data passed through the flexiFlow

12.  final class JmsByteStringMessage extends JmsByteStringMessagePassThrough[NotUsed] with JmsMessage

    Produces byte array messages to JMS from the incoming ByteString.

13.  sealed class JmsByteStringMessagePassThrough[+PassThrough] extends JmsEnvelope[PassThrough] with JmsEnvelopeWithProperties[PassThrough]

    Produces byte array messages to JMS from the incoming ByteString, supports pass-through data.

    Produces byte array messages to JMS from the incoming ByteString, supports pass-through data.

    PassThrough

    the type of data passed through the flexiFlow

14.  case class JmsConnectTimedOut(message: String) extends TimeoutException with Product with Serializable
15.  final class JmsConsumerSettings extends JmsSettings

    Settings for pekko.stream.connectors.jms.scaladsl.JmsConsumer and pekko.stream.connectors.jms.javadsl.JmsConsumer.

16.  final case class JmsCorrelationId(jmsCorrelationId: String) extends JmsHeader with Product with Serializable
17.  final case class JmsDeliveryMode(deliveryMode: Int) extends JmsHeader with Product with Serializable

    Delivery mode can be javax.jms.DeliveryMode.NON_PERSISTENT or javax.jms.DeliveryMode.PERSISTENT

18.  sealed trait JmsEnvelope[+PassThrough] extends AnyRef

    Base interface for messages handled by JmsProducers.

    Base interface for messages handled by JmsProducers. Sub-classes support pass-through or use pekko.NotUsed as type for pass-through.

    PassThrough

    the type of data passed through the flexiFlow

19.  sealed trait JmsEnvelopeWithProperties[+PassThrough] extends JmsEnvelope[PassThrough]

    Marker trait for stream elements that contain pass-through data with properties.

20.  final case class JmsExpiration(jmsExpiration: Long) extends JmsHeader with Product with Serializable
21.  sealed trait JmsHeader extends AnyRef
22.  final class JmsMapMessage extends JmsMapMessagePassThrough[NotUsed] with JmsMessage

    Produces map messages to JMS.

23.  sealed class JmsMapMessagePassThrough[+PassThrough] extends JmsEnvelope[PassThrough] with JmsEnvelopeWithProperties[PassThrough]

    Produces map messages to JMS, supports pass-through data.

    Produces map messages to JMS, supports pass-through data.

    PassThrough

    the type of data passed through the flexiFlow

24.  sealed trait JmsMessage extends JmsEnvelope[NotUsed] with JmsEnvelopeWithProperties[NotUsed]

    Marker trait for stream elements that do not contain pass-through data.

25.  final case class JmsMessageId(jmsMessageId: String) extends JmsHeader with Product with Serializable
26.  final class JmsObjectMessage extends JmsObjectMessagePassThrough[NotUsed] with JmsMessage

    Produces object messages to JMS.

27.  sealed class JmsObjectMessagePassThrough[+PassThrough] extends JmsEnvelope[PassThrough]

    Produces object messages to JMS, supports pass-through data.

    Produces object messages to JMS, supports pass-through data.

    PassThrough

    the type of data passed through the flexiFlow

28.  final class JmsPassThrough[+PassThrough] extends JmsEnvelope[PassThrough]

    A stream element that does not produce a JMS message, but merely passes data through a flexiFlow.

    A stream element that does not produce a JMS message, but merely passes data through a flexiFlow.

    PassThrough

    the type of data passed through the flexiFlow

29.  final case class JmsPriority(priority: Int) extends JmsHeader with Product with Serializable

    Priority of a message can be between 0 (lowest) and 9 (highest).

    Priority of a message can be between 0 (lowest) and 9 (highest). The default priority is 4.

30.  final class JmsProducerSettings extends JmsSettings

    Settings for pekko.stream.connectors.jms.scaladsl.JmsProducer and pekko.stream.connectors.jms.javadsl.JmsProducer.

31.  final case class JmsRedelivered(jmsRedelivered: Boolean) extends JmsHeader with Product with Serializable
32.  final case class JmsReplyTo(jmsDestination: Destination) extends JmsHeader with Product with Serializable
33.  trait JmsSettings extends AnyRef

    Shared settings for all JMS stages.

    Shared settings for all JMS stages. Used for internal standardization, and not meant to be used by user code.

    Annotations

    @DoNotInherit()

34.  final class JmsTextMessage extends JmsTextMessagePassThrough[NotUsed] with JmsMessage

    Produces text messages to JMS.

35.  sealed class JmsTextMessagePassThrough[+PassThrough] extends JmsEnvelope[PassThrough] with JmsEnvelopeWithProperties[PassThrough]

    Produces text messages to JMS, supports pass-through data.

    Produces text messages to JMS, supports pass-through data.

    PassThrough

    the type of data passed through the flexiFlow

36.  final case class JmsTimeToLive(timeInMillis: Long) extends JmsHeader with Product with Serializable
37.  final case class JmsTimestamp(jmsTimestamp: Long) extends JmsHeader with Product with Serializable
38.  final class JmsTxAckTimeout extends TimeoutException
39.  final case class JmsType(jmsType: String) extends JmsHeader with Product with Serializable
40.  trait NonRetriableJmsException extends Exception

    Marker trait indicating that the exception thrown is persistent.

    Marker trait indicating that the exception thrown is persistent. The operation will always fail when retried.

41.  final case class Queue(name: String) extends Destination with Product with Serializable

    Specify a queue as destination to send to/receive from.

42.  final class SendRetrySettings extends AnyRef

    When a connection to a broker starts failing, sending JMS messages will also fail.

    When a connection to a broker starts failing, sending JMS messages will also fail. Those failed messages can be retried at the cost of potentially duplicating the failed messages.

43.  final case class Topic(name: String) extends Destination with Product with Serializable

    Specify a topic as destination to send to/receive from.

44.  case class TxEnvelope extends Product with Serializable
45.  case class UnsupportedMapMessageEntryType(entryName: String, entryValue: Any, message: JmsMapMessagePassThrough[_]) extends Exception with NonRetriableJmsException with Product with Serializable
46.  case class UnsupportedMessagePropertyType(propertyName: String, propertyValue: Any, message: JmsEnvelope[_]) extends Exception with NonRetriableJmsException with Product with Serializable
47.  case class UnsupportedMessageType(message: Message) extends Exception with NonRetriableJmsException with Product with Serializable