onPublish

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