hub-server-workhorse/org.msensis.imahub.workhorse.api/RejectionMessageRSocketController

RejectionMessageRSocketController

@Controller
@MessageMapping(value = ["experimental.message.{client}"])
class RejectionMessageRSocketController(rejectedMessageService: RejectionMessageService, protobufSerializer: ProtoBuf)

Constructors

Link copied to clipboard
constructor(rejectedMessageService: RejectionMessageService, protobufSerializer: ProtoBuf)

Functions

Link copied to clipboard
@MessageMapping(value = ["reject"])
suspend fun rejectedMessages(@Payload(required = false) inBoundMessages: Flow<ByteArray>, @DestinationVariable client: String): Flow<RSocketResponse>

Receive a stream of rejectedMessages as request/stream RSocket API. Takes as argument a stream of rejectedMessages encoded in ProtoBuf format in payload. In metadata takes the client path as String.