package jms
- Alphabetic
- Public
- Protected
Type Members
- case class AckEnvelope extends Product with Serializable
- final class AcknowledgeMode extends AnyRef
JMS acknowledge modes.
JMS acknowledge modes. See javax.jms.Connection#createSession-boolean-int-
- case class ConnectionRetryException(message: String, cause: Throwable) extends Exception with Product with Serializable
- 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.
- final class Credentials extends AnyRef
- 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.
- sealed abstract class Destination extends AnyRef
A destination to send to/receive from.
- final case class DurableTopic(name: String, subscriberName: String) extends Destination with Product with Serializable
Specify a durable topic destination to send to/receive from.
- final class JmsBrowseSettings extends AnyRef
Settings for pekko.stream.connectors.jms.scaladsl.JmsConsumer.browse and pekko.stream.connectors.jms.javadsl.JmsConsumer.browse.
- final class JmsByteMessage extends JmsByteMessagePassThrough[NotUsed] with JmsMessage
Produces byte arrays to JMS.
- 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
- final class JmsByteStringMessage extends JmsByteStringMessagePassThrough[NotUsed] with JmsMessage
Produces byte array messages to JMS from the incoming
ByteString
. - 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
- case class JmsConnectTimedOut(message: String) extends TimeoutException with Product with Serializable
- final class JmsConsumerSettings extends JmsSettings
Settings for pekko.stream.connectors.jms.scaladsl.JmsConsumer and pekko.stream.connectors.jms.javadsl.JmsConsumer.
- final case class JmsCorrelationId(jmsCorrelationId: String) extends JmsHeader with Product with Serializable
- 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
- 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
- sealed trait JmsEnvelopeWithProperties[+PassThrough] extends JmsEnvelope[PassThrough]
Marker trait for stream elements that contain pass-through data with properties.
- final case class JmsExpiration(jmsExpiration: Long) extends JmsHeader with Product with Serializable
- sealed trait JmsHeader extends AnyRef
- final class JmsMapMessage extends JmsMapMessagePassThrough[NotUsed] with JmsMessage
Produces map messages to JMS.
- 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
- sealed trait JmsMessage extends JmsEnvelope[NotUsed] with JmsEnvelopeWithProperties[NotUsed]
Marker trait for stream elements that do not contain pass-through data.
- final case class JmsMessageId(jmsMessageId: String) extends JmsHeader with Product with Serializable
- final class JmsObjectMessage extends JmsObjectMessagePassThrough[NotUsed] with JmsMessage
Produces object messages to JMS.
- 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
- 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
- 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.
- final class JmsProducerSettings extends JmsSettings
Settings for pekko.stream.connectors.jms.scaladsl.JmsProducer and pekko.stream.connectors.jms.javadsl.JmsProducer.
- final case class JmsRedelivered(jmsRedelivered: Boolean) extends JmsHeader with Product with Serializable
- final case class JmsReplyTo(jmsDestination: Destination) extends JmsHeader with Product with Serializable
- 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()
- final class JmsTextMessage extends JmsTextMessagePassThrough[NotUsed] with JmsMessage
Produces text messages to JMS.
- 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
- final case class JmsTimeToLive(timeInMillis: Long) extends JmsHeader with Product with Serializable
- final case class JmsTimestamp(jmsTimestamp: Long) extends JmsHeader with Product with Serializable
- final class JmsTxAckTimeout extends TimeoutException
- final case class JmsType(jmsType: String) extends JmsHeader with Product with Serializable
- 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.
- final case class Queue(name: String) extends Destination with Product with Serializable
Specify a queue as destination to send to/receive from.
- 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.
- final case class Topic(name: String) extends Destination with Product with Serializable
Specify a topic as destination to send to/receive from.
- case class TxEnvelope extends Product with Serializable
- case class UnsupportedMapMessageEntryType(entryName: String, entryValue: Any, message: JmsMapMessagePassThrough[_]) extends Exception with NonRetriableJmsException with Product with Serializable
- case class UnsupportedMessagePropertyType(propertyName: String, propertyValue: Any, message: JmsEnvelope[_]) extends Exception with NonRetriableJmsException with Product with Serializable
- case class UnsupportedMessageType(message: Message) extends Exception with NonRetriableJmsException with Product with Serializable
Deprecated Type Members
- 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
- 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
- object AcknowledgeMode
- object ConnectionRetrySettings
- object Credentials
- object Destination
- object JmsBrowseSettings
- object JmsByteMessage
Produces byte arrays to JMS.
- object JmsByteStringMessage
Produces byte array messages to JMS from the incoming
ByteString
. - object JmsConsumerSettings
- object JmsCorrelationId extends Serializable
- object JmsDeliveryMode extends Serializable
- object JmsExpiration extends Serializable
- object JmsMapMessage
Produces map messages to JMS.
- object JmsMessage
- object JmsMessageFactory
- object JmsMessageId extends Serializable
- case object JmsNotConnected extends Exception with NoStackTrace with Product with Serializable
- object JmsObjectMessage
Produces object messages to JMS.
- object JmsPassThrough
A stream element that does not produce a JMS message, but merely passes data through a
flexiFlow
. - object JmsPriority extends Serializable
- object JmsProducerSettings
- object JmsRedelivered extends Serializable
- object JmsReplyTo extends Serializable
- object JmsTextMessage
Produces text messages to JMS.
- object JmsTimeToLive extends Serializable
- object JmsTimestamp extends Serializable
- object JmsType extends Serializable
- case object RetrySkippedOnMissingConnection extends Exception with NoStackTrace with Product with Serializable
- object SendRetrySettings