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

MessagePublicationRSocketController

@Controller

@MessageMapping(value = ["v1.message.{client}"])

class MessagePublicationRSocketController(messagePublicationService: MessagePublicationService, protobufSerializer: ProtoBuf, serverStore: ServerStore)

Constructors

constructor(messagePublicationService: MessagePublicationService, protobufSerializer: ProtoBuf, serverStore: ServerStore)

Functions

publish

@MessageMapping(value = ["stream"])

fun publish(@Payload(required = false) inBoundMessages: Flow<ByteArray>, @DestinationVariable client: String): Flow<RSocketResponse>

Flow variant of publishSingleMessage as request/stream RSocket API.

publishSingleMessage

@MessageMapping(value = ["put"])

suspend fun publishSingleMessage(@Payload inBoundMessage: ByteArray, @DestinationVariable client: String)

Receive MessageEntity fnf RSocket API. Takes as argument an MessageEntity encoded in ProtoBuf format in payload. In metadata takes the client path as String.