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

ContactRSocketController

@Controller

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

class ContactRSocketController(contactService: ContactService, protobufSerializer: ProtoBuf)

Constructors

constructor(contactService: ContactService, protobufSerializer: ProtoBuf)

Functions

getAccounts

@MessageMapping(value = ["get"])

suspend fun getAccounts(@Payload accounts: ByteArray, @DestinationVariable client: String): RSocketResponse

Get a List of numbers request/response RSocket API. Takes as argument a list of numbers as String encoded in ProtoBuf format in payload. In metadata takes the client path as String.

@MessageMapping(value = ["get.stream"])

fun getAccounts(@Payload accounts: Flow<ByteArray>, @DestinationVariable client: String): Flow<RSocketResponse>

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

getSingleContact

@MessageMapping(value = ["get.single"])

suspend fun getSingleContact(@Payload incomingNumber: ByteArray, @DestinationVariable client: String): RSocketResponse

Get a number request/response RSocket API. Takes as argument a number as String encoded in ProtoBuf format in payload. In metadata takes the client path as String.