rabbitmq-protocol/it.unibo.pulvreakt.platforms.rabbitmq/RabbitmqProtocol

RabbitmqProtocol

expect class RabbitmqProtocol(hostname: String = "localhost", port: Int = 5672, username: String = "guest", password: String = "guest", virtualHost: String = "/") : Protocol

Implement the Channel interface relying on RabbitMQ as a platform for communications.

actual class RabbitmqProtocol(hostname: String, port: Int, username: String, password: String, virtualHost: String) : Protocol

Implement the Communicator interface relying on RabbitMQ as a platform for communications.

actual class RabbitmqProtocol(hostname: String, port: Int, username: String, password: String, virtualHost: String) : Protocol

Implement the Communicator interface relying on RabbitMQ as a platform for communications.

actual class RabbitmqProtocol(hostname: String, port: Int, username: String, password: String, virtualHost: String) : Protocol

Implement the Communicator interface relying on RabbitMQ as a platform for communications.

Constructors

Link copied to clipboard
expect constructor(hostname: String = "localhost", port: Int = 5672, username: String = "guest", password: String = "guest", virtualHost: String = "/")
actual constructor(hostname: String, port: Int, username: String, password: String, virtualHost: String)
actual constructor(hostname: String, port: Int, username: String, password: String, virtualHost: String)
actual constructor(hostname: String, port: Int, username: String, password: String, virtualHost: String)

Properties

Link copied to clipboard
abstract val di: DI
open lateinit override var di: DI
open lateinit override var di: DI
open lateinit override var di: DI
diContext
Link copied to clipboard
open val diContext: DIContext<*>
open val diContext: DIContext<*>
open val diContext: DIContext<*>
open val diContext: DIContext<*>
diTrigger
Link copied to clipboard
open val diTrigger: DITrigger?
open val diTrigger: DITrigger?
open val diTrigger: DITrigger?
open val diTrigger: DITrigger?

Functions

Link copied to clipboard
abstract suspend fun finalize(): Either<ProtocolError, Unit>
open suspend override fun finalize(): Either<ProtocolError, Unit>
open suspend override fun finalize(): Either<ProtocolError, Unit>
open suspend override fun finalize(): Either<ProtocolError, Unit>
Link copied to clipboard
abstract suspend fun initialize(): Either<ProtocolError, Unit>
open suspend override fun initialize(): Either<ProtocolError, Unit>
open suspend override fun initialize(): Either<ProtocolError, Unit>
open suspend override fun initialize(): Either<ProtocolError, Unit>
Link copied to clipboard
abstract fun readFromChannel(from: Entity, to: Entity): Either<ProtocolError, Flow<ByteArray>>
open override fun readFromChannel(from: Entity, to: Entity): Either<ProtocolError, Flow<ByteArray>>
open override fun readFromChannel(from: Entity, to: Entity): Either<ProtocolError, Flow<ByteArray>>
open override fun readFromChannel(from: Entity, to: Entity): Either<ProtocolError, Flow<ByteArray>>
Link copied to clipboard
abstract suspend fun setupChannel(source: Entity, destination: Entity)
open suspend override fun setupChannel(source: Entity, destination: Entity)
open suspend override fun setupChannel(source: Entity, destination: Entity)
open suspend override fun setupChannel(source: Entity, destination: Entity)
Link copied to clipboard
abstract fun setupInjector(kodein: DI)
open override fun setupInjector(kodein: DI)
open override fun setupInjector(kodein: DI)
open override fun setupInjector(kodein: DI)
Link copied to clipboard
abstract suspend fun writeToChannel(from: Entity, to: Entity, message: ByteArray): Either<ProtocolError, Unit>
open suspend override fun writeToChannel(from: Entity, to: Entity, message: ByteArray): Either<ProtocolError, Unit>
open suspend override fun writeToChannel(from: Entity, to: Entity, message: ByteArray): Either<ProtocolError, Unit>
open suspend override fun writeToChannel(from: Entity, to: Entity, message: ByteArray): Either<ProtocolError, Unit>