onPublish

protected open fun onPublish(exchange: String, routingKey: String, body: Array<Byte>)