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

rejectedMessages

@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.

Tries to notify message's sender the reason why the message was rejected and whether the operation is retryable or not.

Returns a stream of HubPayload encoded in ProtoBuf only in case of error. Otherwise, in case of success the payload is empty.

Experimental API

This API is still under development, which means that the design of the declaration may (or may not) change in the future in some way that may break the code. See issue #321 to track the implementation.