public async Task Consume(ConsumeContext<IOrderRequest> context)
        {
            var sw = new Stopwatch();
            sw.Start();
            var req = context.Message;

            GetOrderResponse data = null;

            try
            {

                data = await _gate.GetOrder(new GetOrderRequest());

                await context.RespondAsync<IOrderResponse>(new { Data = data.Data, TotalCount = data.TotalCountRecords, Error = data.Error });

                var msg = $"From :: ${JsonConvert.SerializeObject(context.Host)}, Id :: {context.MessageId}, Message :: {JsonConvert.SerializeObject(req)}, Response :: {data.Data}, ElapsedMiliseconds :: {sw.ElapsedMilliseconds}";
                _logger.LogInformation(msg);
            }
            catch (Exception ex)
            {
                _logger.LogError(ex, $"Request: {JsonConvert.SerializeObject(req)}");
            }

            sw.Stop();
        }