_handle = _host.ConnectReceiveEndpoint(p =>
        {
            p.BindMessageExchanges = false;
            p.Handler<T>(context =>
            {
                _receivedMessage = context.Message;
                _messageReceived.Set();
                return Task.CompletedTask;
            });
            p.Bind<T>(z =>
            {
                z.ExchangeType = "direct";
                z.RoutingKey = _routingKey;
            });
        });