connector-jms/com.river.connector.jms

Package-level declarations

Functions

Link copied to clipboard
@ExperimentalCoroutinesApi
fun ConnectionFactory.consume(    queueName: String,     credentials: Credentials? = null,     sessionMode: SessionMode = SessionMode.CLIENT_ACKNOWLEDGE,     pollingMaxWait: Duration = 10.seconds,     concurrency: Int = 1): Flow<CommittableMessage>

Consumes messages from a specified JMS queue using a reactive Flow API.

Link copied to clipboard
@ExperimentalCoroutinesApi
fun ConnectionFactory.sendToDestination(    destination: JmsDestination,     upstream: Flow<JmsMessage>,     concurrency: Int = 1,     credentials: Credentials? = null): Flow<Unit>

Sends messages to a specified JMS destination from a given upstream flow of JmsMessage objects.