connector-amqp/com.river.connector.amqp

Package-level declarations

Types

@ExperimentalCoroutinesApi

interface Message

ReceivingMessage

@ExperimentalCoroutinesApi

interface ReceivingMessage

Functions

@ExperimentalCoroutinesApi

@ExperimentalRiverApi

fun Connection.autoAckConsume(queue: String, prefetch: Int = 100): Flow<ReceivingMessage.AutoAck>

@ExperimentalRiverApi

fun ConnectionFactory.connection(name: String? = null): Connection

@ExperimentalCoroutinesApi

@ExperimentalRiverApi

fun Connection.consume(queue: String, prefetch: Int = 100): Flow<ReceivingMessage.ManualAck>

nonBlockingConnectionFactory

@ExperimentalRiverApi

fun nonBlockingConnectionFactory(threadNumber: Int = 1, f: ConnectionFactory.() -> Unit): ConnectionFactory

@ExperimentalRiverApi

fun Channel.publishFlow(upstream: Flow<Message.Default>): Flow<Unit>

@ExperimentalRiverApi

fun Channel.publishFlow(exchange: String, routingKey: String, upstream: Flow<Message.Simple>): Flow<Unit>

@ExperimentalRiverApi

fun Connection.publishFlow(exchange: String, routingKey: String, upstream: Flow<Message.Simple>): Flow<Unit>

@ExperimentalRiverApi

fun <T> Connection.withChannel(f: Channel.() -> T): T