flex/com.xpdustry.flex.message/MessagePipeline

MessagePipeline

interface MessagePipeline : PriorityProcessorPipeline<MessageContext, CompletableFuture<String>>

Functions

Link copied to clipboard
open fun broadcast(sender: Audience, target: Audience, message: String): CompletableFuture<Void?>
abstract fun broadcast(sender: Audience, target: Audience, message: String, template: String): CompletableFuture<Void?>
Link copied to clipboard
abstract fun pump(context: MessageContext): CompletableFuture<String>
Link copied to clipboard
open override fun register(name: String, processor: Processor<MessageContext, CompletableFuture<String>>)
abstract fun register(name: String, priority: Priority, processor: Processor<MessageContext, CompletableFuture<String>>)