ReduHandler

Properties

Link copied to clipboard
lateinit var broker: MessageBroker<ByteString, ProtoMessageWrapper>

Functions

Link copied to clipboard
suspend fun sendAndReceive(msg: ProtoMessageWrapper, topicName: String = Config.getPmonTopicName(), messageId: String = UUID.randomUUID().toString(), waitTime: Long = 1000): ProtoMessageWrapper