subscribe

fun subscribe(msgReceived: (ConsumerRecord<ByteArray, ProtoMessage>) -> Unit)

Subscription on new messages in topic

Parameters

msgReceived
  • callback function, called when received new message @param ProtoManId - destination from message.key() @param ProtoMessageWrapper - receved data from message.value()