Packages

package jms

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Package Members

  1. package impl
  2. package javadsl
  3. package scaladsl

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

Deprecated Type Members

  1. case class NullMapMessageEntry(entryName: String, message: JmsMapMessagePassThrough[_]) extends Exception with NonRetriableJmsException with Product with Serializable
    Annotations
    @deprecated
    Deprecated

    (Since version Alpakka 3.0.4) Not used anywhere

  2. case class NullMessageProperty(propertyName: String, message: JmsEnvelope[_]) extends Exception with NonRetriableJmsException with Product with Serializable
    Annotations
    @deprecated
    Deprecated

    (Since version Alpakka 3.0.4) Not used anywhere

Value Members

  1. object AcknowledgeMode
  2. object ConnectionRetrySettings
  3. object Credentials
  4. object Destination
  5. object JmsBrowseSettings
  6. object JmsByteMessage

    Produces byte arrays to JMS.

  7. object JmsByteStringMessage

    Produces byte array messages to JMS from the incoming ByteString.

  8. object JmsConsumerSettings
  9. object JmsCorrelationId extends Serializable
  10. object JmsDeliveryMode extends Serializable
  11. object JmsExpiration extends Serializable
  12. object JmsMapMessage

    Produces map messages to JMS.

  13. object JmsMessage
  14. object JmsMessageFactory
  15. object JmsMessageId extends Serializable
  16. case object JmsNotConnected extends Exception with NoStackTrace with Product with Serializable
  17. object JmsObjectMessage

    Produces object messages to JMS.

  18. object JmsPassThrough

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

  19. object JmsPriority extends Serializable
  20. object JmsProducerSettings
  21. object JmsRedelivered extends Serializable
  22. object JmsReplyTo extends Serializable
  23. object JmsTextMessage

    Produces text messages to JMS.

  24. object JmsTimeToLive extends Serializable
  25. object JmsTimestamp extends Serializable
  26. object JmsType extends Serializable
  27. case object RetrySkippedOnMissingConnection extends Exception with NoStackTrace with Product with Serializable
  28. object SendRetrySettings

Ungrouped