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.