diff --git a/Sources/Contour/Contour.csproj b/Sources/Contour/Contour.csproj
index bc10bdd..d00b97e 100644
--- a/Sources/Contour/Contour.csproj
+++ b/Sources/Contour/Contour.csproj
@@ -14,7 +14,7 @@
   
   <ItemGroup>
     <PackageReference Include="Common.Logging" Version="3.4.1" />
-    <PackageReference Include="RabbitMQ.Client" Version="6.1.0" />
+    <PackageReference Include="RabbitMQ.Client" Version="6.2.4" />
     <PackageReference Include="System.Collections.Immutable" Version="1.7.0" />
     <PackageReference Include="System.Configuration.ConfigurationManager" Version="4.5.0" />
   </ItemGroup>
diff --git a/Sources/Contour/Transport/RabbitMQ/BusConfigurationEx.cs b/Sources/Contour/Transport/RabbitMQ/BusConfigurationEx.cs
index fcc4219..e816fb1 100644
--- a/Sources/Contour/Transport/RabbitMQ/BusConfigurationEx.cs
+++ b/Sources/Contour/Transport/RabbitMQ/BusConfigurationEx.cs
@@ -1,4 +1,4 @@
-using System;
+using System;
 using System.Collections.Generic;
 
 using Contour.Configuration;
@@ -127,5 +127,14 @@ public static IBusConfigurator UseRabbitMq(this IBusConfigurator busConfigurator
 
             return busConfigurator;
         }
+
+        public static bool RmqUseAsyncConsuming { get; private set; }
+
+        // Костыль, чтобы не тянеть в общую конфигурацию специфичную для эксперимента настройку
+        public static IBusConfiguration ConfigureRabbitMq(this IBusConfiguration busConfigurator, bool asyncConsuming)
+        {
+            RmqUseAsyncConsuming = asyncConsuming;
+            return busConfigurator;
+        }
     }
 }
diff --git a/Sources/Contour/Transport/RabbitMQ/Internal/Listener.cs b/Sources/Contour/Transport/RabbitMQ/Internal/Listener.cs
index 68306ff..e371967 100644
--- a/Sources/Contour/Transport/RabbitMQ/Internal/Listener.cs
+++ b/Sources/Contour/Transport/RabbitMQ/Internal/Listener.cs
@@ -1,4 +1,4 @@
-using Contour.Transport.RabbitMQ.Topology;
+using Contour.Transport.RabbitMQ.Topology;
 using RabbitMQ.Client;
 
 namespace Contour.Transport.RabbitMQ.Internal
@@ -464,7 +464,32 @@ private async Task ConsumerTaskMethod(CancellationToken token)
         {
             try
             {
-                var consumer = this.InitializeConsumer(token, out var channel);
+                Func<Task> startConsuming;
+                if (BusConfigurationEx.RmqUseAsyncConsuming)
+                {
+                    var consumer = this.InitializeAsyncConsumer(token, out var channel);
+                    startConsuming = () =>
+                    {
+                        this.StartConsumingAsync(consumer, channel, token);
+                        return Task.CompletedTask;
+                    };
+                }
+                else
+                {
+                    var consumer = this.InitializeConsumer(token, out var channel);
+                    startConsuming = async () =>
+                    {
+                        this.StartConsuming(consumer, channel);
+
+                        this.logger.Info($"Listner {this} start consuming.");
+
+                        while (!token.IsCancellationRequested)
+                        {
+                            var message = consumer.Dequeue();
+                            await this.Deliver(this.BuildDeliveryFrom(channel, message));
+                        }
+                    };
+                }
 
                 var waitSecond = 0;
                 // если шина так и не стала готова работать, то не смысла начинать слушать сообщения, что бы потом их потерять
@@ -486,17 +511,9 @@ private async Task ConsumerTaskMethod(CancellationToken token)
                     }
                 }
 
-                this.StartConsuming(consumer, channel);
-
-                this.logger.Info($"Listner {this} start consuming.");
-
-                while (!token.IsCancellationRequested)
-                {
-                    var message = consumer.Dequeue();
-                    await this.Deliver(this.BuildDeliveryFrom(channel, message));
-                }
+                await startConsuming();
             }
-            catch (OperationCanceledException)
+            catch (OperationCanceledException e) when (e.CancellationToken == token)
             {
                 this.logger.Info("Consume operation of listener has been canceled");
             }
@@ -527,8 +544,8 @@ private Expectation CreateExpectation(string correlationId, Type expectedRespons
             }
 
             return new Expectation(d => this.BuildResponse(d, expectedResponseType), timeoutTicket);
-        }
-
+        }
+
         private CancellableQueueingConsumer InitializeConsumer(CancellationToken token, out RabbitChannel channel)
         {
             // Opening a new channel may lead to a new connection creation
@@ -542,21 +559,97 @@ private CancellableQueueingConsumer InitializeConsumer(CancellationToken token,
                     this.ReceiverOptions.GetQoS().Value);
             }
 
-            var consumer = channel.BuildCancellableConsumer(token);
-           
+            var consumer = channel.BuildCancellableConsumer(token);
+
+
+            return consumer;
+        }
+
+        private void StartConsuming(IBasicConsumer consumer, RabbitChannel channel)
+        {
+            var tag = channel.StartConsuming(
+                this.endpoint.ListeningSource,
+                this.ReceiverOptions.IsAcceptRequired(),
+                consumer);
+
+            this.logger.Trace(
+                $"A consumer tagged [{tag}] has been registered in listener of [{string.Join(",", this.AcceptedLabels)}]");
+        }
+
+
+        private AsyncEventingBasicConsumer InitializeAsyncConsumer(CancellationToken token, out RabbitChannel channel)
+        {
+            // Opening a new channel may lead to a new connection creation
+            channel = this.connection.OpenChannel(token);
+            channel.Shutdown += this.OnChannelShutdown;
+            this.channels.Add(channel);
+
+            if (this.ReceiverOptions.GetQoS().HasValue)
+            {
+                channel.SetQos(
+                    this.ReceiverOptions.GetQoS().Value);
+            }
+
+            var consumer = channel.BuildConsumer();
 
             return consumer;
         }
 
-        private void StartConsuming(IBasicConsumer consumer, RabbitChannel channel)
+        private void StartConsumingAsync(AsyncEventingBasicConsumer consumer, RabbitChannel channel, CancellationToken token)
         {
-            var tag = channel.StartConsuming(
+            consumer.Received += (s, e) => HandleMessage(e);
+
+            string tag = string.Empty;
+
+            async Task HandleMessage(BasicDeliverEventArgs args)
+            {
+                RabbitDelivery delivery = null;
+                try
+                {
+                    delivery = this.BuildDeliveryFrom(channel, args);
+                }
+                catch (Exception e)
+                {
+                    this.logger.Fatal(x => x("Delivery object has not been constructed, fetch a follow messages of the consumer for '{0}' is unpossible.", this.endpoint.ListeningSource.Address), e);
+                    throw;
+                }
+
+                try
+                {
+                    await this.Deliver(delivery);
+                }
+                catch (Exception e)
+                {
+                    this.OnFailure(delivery, e);
+                }
+            }
+
+
+            CancellationTokenRegistration cancellationCallbackRegistration = default;
+
+            void UnsubscribeConsumer()
+            {
+                channel.StopConsuming(tag);
+                cancellationCallbackRegistration.Dispose();
+            }
+
+            cancellationCallbackRegistration = token.Register(UnsubscribeConsumer);
+
+            if (token.IsCancellationRequested)
+            {
+                UnsubscribeConsumer();
+                return;
+            }
+
+            tag = channel.StartConsuming(
                 this.endpoint.ListeningSource,
                 this.ReceiverOptions.IsAcceptRequired(),
                 consumer);
 
             this.logger.Trace(
                 $"A consumer tagged [{tag}] has been registered in listener of [{string.Join(",", this.AcceptedLabels)}]");
+
+            this.logger.Info($"Listner {this} start consuming.");
         }
 
         private void OnChannelShutdown(IChannel channel, ShutdownEventArgs args)
diff --git a/Sources/Contour/Transport/RabbitMQ/Internal/RabbitBus.cs b/Sources/Contour/Transport/RabbitMQ/Internal/RabbitBus.cs
index 3aefdb2..b7774a2 100644
--- a/Sources/Contour/Transport/RabbitMQ/Internal/RabbitBus.cs
+++ b/Sources/Contour/Transport/RabbitMQ/Internal/RabbitBus.cs
@@ -1,4 +1,4 @@
-using System;
+using System;
 using System.Linq;
 using System.Threading;
 using System.Threading.Tasks;
@@ -37,9 +37,10 @@ public RabbitBus(BusConfiguration configuration)
             this.cancellationTokenSource = new CancellationTokenSource();
             var completion = new TaskCompletionSource<object>();
             completion.SetResult(new object());
-            this.workTask = completion.Task;
-            
-            this.connectionPool = new RabbitConnectionPool(this);
+            this.workTask = completion.Task;
+
+            var async = BusConfigurationEx.RmqUseAsyncConsuming;
+            this.connectionPool = new RabbitConnectionPool(this, async);
         }
         
         /// <summary>
@@ -305,4 +306,4 @@ private void OnListenerCreated(object sender, ListenerCreatedEventArgs e)
                 .ForEach(r => r.CheckIfCompatible(e.Listener));
         }
     }
-}
\ No newline at end of file
+}
diff --git a/Sources/Contour/Transport/RabbitMQ/Internal/RabbitChannel.cs b/Sources/Contour/Transport/RabbitMQ/Internal/RabbitChannel.cs
index eda5b21..892bfae 100644
--- a/Sources/Contour/Transport/RabbitMQ/Internal/RabbitChannel.cs
+++ b/Sources/Contour/Transport/RabbitMQ/Internal/RabbitChannel.cs
@@ -1,442 +1,464 @@
-namespace Contour.Transport.RabbitMQ.Internal
-{
-    using System;
-    using System.Collections.Generic;
-    using System.IO;
-    using System.Threading;
-    using Common.Logging;
-    using Helpers;
-    using Receiving;
-    using Topology;
-    using global::RabbitMQ.Client;
-    using System.Diagnostics;
-
-    /// <summary>
-    /// The rabbit channel.
-    /// </summary>
-    internal sealed class RabbitChannel : IChannel
-    {
-        private readonly object sync = new object();
-        private readonly IBusContext busContext;
-
-        private readonly ILog logger;
-
-        /// <summary>
-        /// Initializes a new instance of the <see cref="RabbitChannel"/> class. 
-        /// </summary>
-        /// <param name="connectionId">A connection identifier to which this channel belongs</param>
-        /// <param name="model">A native transport channel</param>
-        /// <param name="busContext">A bus context</param>
-        /// <param name="connectionString">Used connection string</param>
-        /// <param name="connectionKey">Key by connection string</param>
-        public RabbitChannel(Guid connectionId, IModel model, IBusContext busContext, string connectionString, string connectionKey)
-        {
-            this.ConnectionId = connectionId;
-            this.Model = model;
-            this.busContext = busContext;
-            this.ConnectionString = connectionString;
-            this.logger = LogManager.GetLogger($"{this.GetType().FullName}({this.ConnectionId}, {this.GetHashCode()})");
-            this.ConnectionKey = connectionKey;
-
-            this.Model.ModelShutdown += this.OnModelShutdown;
-        }
-
-        /// <summary>
-        /// Строка подключения
-        /// </summary>
-        internal string ConnectionString { get; }
-
-        public Guid ConnectionId { get; }
-
-        public string ConnectionKey { get; }
-
-        /// <summary>
-        /// The failed.
-        /// </summary>
-        [Obsolete("Channel failures are no longer propagated outside via events, instead an exception is thrown")]
-        public event Action<IChannel, ErrorEventArgs> Failed = (channel, args) => { };
-
-        /// <summary>
-        /// Is fired on channel shutdown.
-        /// </summary>
-        public event Action<IChannel, ShutdownEventArgs> Shutdown = (channel, args) => { };
-
-        /// <summary>
-        /// Gets the native.
-        /// </summary>
-        protected IModel Model { get; }
-
-        /// <summary>
-        /// Aborts the channel
-        /// </summary>
-        public void Abort()
-        {
-            this.Model?.Abort();
-        }
-
-        /// <summary>
-        /// The accept.
-        /// </summary>
-        /// <param name="delivery">
-        /// The delivery.
-        /// </param>
-        public void Accept(RabbitDelivery delivery)
-        {
-            this.logger.Trace(m => m("Accepting message [{0}] ({1}).", delivery.Label, delivery.Args.DeliveryTag));
-
-            this.SafeNativeInvoke(n => n.BasicAck(delivery.Args.DeliveryTag, false));
-        }
-
-        /// <summary>
-        /// The bind.
-        /// </summary>
-        /// <param name="queue">
-        /// The queue.
-        /// </param>
-        /// <param name="exchange">
-        /// The exchange.
-        /// </param>
-        /// <param name="routingKey">
-        /// The routing key.
-        /// </param>
-        public void Bind(Queue queue, Exchange exchange, string routingKey)
-        {
-            try
-            {
-                this.SafeNativeInvoke(n => n.QueueBind(queue.Name, exchange.Name, routingKey));
-            }
-            catch (Exception e)
-            {
-                this.logger.Error(m => m("Failed to bind queue to exchange [{1}:{2}] on channel: {0}", this.ToString(), exchange.Name, queue.Name), e);
-                throw;
-            }
-        }
-
-        /// <summary>
-        /// The build cancellable consumer.
-        /// </summary>
-        /// <param name="cancellationToken">
-        /// The cancellation token.
-        /// </param>
-        /// <returns>
-        /// The <see cref="CancellableQueueingConsumer"/>.
-        /// </returns>
-        public CancellableQueueingConsumer BuildCancellableConsumer(CancellationToken cancellationToken)
-        {
-            return new CancellableQueueingConsumer(this.Model, cancellationToken);
-        }
-
-        /// <summary>
-        /// The declare.
-        /// </summary>
-        /// <param name="exchange">
-        /// The exchange.
-        /// </param>
-        public void Declare(Exchange exchange)
-        {
-            try
-            {
-                this.SafeNativeInvoke(n => n.ExchangeDeclare(exchange.Name, exchange.Type, exchange.Durable, exchange.AutoDelete, new Dictionary<string, object>()));
-            }
-            catch (Exception e)
-            {
-                this.logger.Error(m => m("Failed to Declare Exchange [{1}] on channel: {0}", this.ToString(), exchange.Name), e);
-                throw;
-            }
-        }
-
-        /// <summary>
-        /// The declare.
-        /// </summary>
-        /// <param name="queue">
-        /// The queue.
-        /// </param>
-        public void Declare(Queue queue)
-        {
-            try
-            {
-                var arguments = new Dictionary<string, object>();
-                if (queue.Ttl.HasValue)
-                {
-                    arguments.Add(Contour.Headers.QueueMessageTtl, (long)queue.Ttl.Value.TotalMilliseconds);
-                }
-
-                if (queue.Limit.HasValue)
-                {
-                    arguments.Add(Contour.Headers.QueueMaxLength, (int)queue.Limit);
-                }
-
-                if (queue.MaxLengthBytes.HasValue)
-                {
-                    arguments.Add(Contour.Headers.QueueMaxLengthBytes, (int)queue.MaxLengthBytes);
-                }
-
-                this.SafeNativeInvoke(n =>
-                    n.QueueDeclare(queue.Name, queue.Durable, queue.Exclusive, queue.AutoDelete, arguments));
-            }
-            catch (Exception e)
-            {
-                this.logger.Error(m => m("Failed to Declare Queue [{1}] on channel: {0}", this.ToString(), queue.Name),
-                    e);
-                throw;
-            }
-        }
-
-        /// <summary>
-        /// The declare default queue.
-        /// </summary>
-        /// <returns>
-        /// The <see cref="string"/>.
-        /// </returns>
-        public string DeclareDefaultQueue()
-        {
-            try
-            {
-                var queueName = string.Empty;
-
-                this.SafeNativeInvoke(n => queueName = n.QueueDeclare());
-
-                return queueName;
-            }
-            catch (Exception e)
-            {
-                this.logger.Error(m => m("Failed to Declare Default Queue on channel: {0}", this.ToString()), e);
-                throw;
-            }
-        }
-
-        /// <summary>
-        /// The dispose.
-        /// </summary>
-        public void Dispose()
-        {
-            if (this.Model != null)
-            {
-                this.Model.ModelShutdown -= this.OnModelShutdown;
-
-                try
-                {
-                    this.Model.Abort();
-                    this.Model.Dispose();
-                }
-                catch (Exception)
-                {
-                    // Suppress all errors here
-                }
-            }
-        }
-
-        /// <summary>
-        /// Enable publish confirmation.
-        /// </summary>
-        public void EnablePublishConfirmation()
-        {
-            this.SafeNativeInvoke(n => n.ConfirmSelect());
-        }
-
-        /// <summary>
-        /// Get next seq no.
-        /// </summary>
-        /// <returns>
-        /// The <see cref="ulong"/>.
-        /// </returns>
-        public ulong GetNextSeqNo()
-        {
-            ulong seqNo = 0UL;
-            this.SafeNativeInvoke(n => seqNo = n.NextPublishSeqNo);
-            return seqNo;
-        }
-
-        /// <summary>
-        /// The on confirmation.
-        /// </summary>
-        /// <param name="handleConfirmation">
-        /// The handle confirmation.
-        /// </param>
-        public void OnConfirmation(ConfirmationHandler handleConfirmation)
-        {
-            this.SafeNativeInvoke(
-                n =>
-                    {
-                        n.BasicAcks += (model, args) => handleConfirmation(true, args.DeliveryTag, args.Multiple);
-                        n.BasicNacks += (model, args) => handleConfirmation(false, args.DeliveryTag, args.Multiple);
-                    });
-        }
-
-        /// <summary>
-        /// The publish.
-        /// </summary>
-        /// <param name="route">
-        /// The route.
-        /// </param>
-        /// <param name="message">
-        /// The message.
-        /// </param>
-        /// <param name="propsVisitor">
-        /// The props visitor.
-        /// </param>
-        public void Publish(IRoute route, IMessage message, Func<IBasicProperties, IDictionary<string, object>> propsVisitor = null)
-        {
-            var nativeRoute = (RabbitRoute)route;
-
-            this.logger.Trace(m => m("Emitting message [{0}] ({1}) through [{2}].", message.Label, message.Payload, nativeRoute));
-
-            var props = this.Model.CreateBasicProperties();
-            var body = this.busContext.PayloadConverter.FromObject(message.Payload);
-
-            if (props.Headers == null)
-            {
-                props.Headers = new Dictionary<string, object>();
-            }
-
-            props.ContentType = this.busContext.PayloadConverter.ContentType;
-            props.Timestamp = new AmqpTimestamp(DateTime.UtcNow.ToUnixTimestamp());
-
-            var headers = propsVisitor?.Invoke(props);
-            headers.ForEach(i => props.Headers.Add(i));
-
-            this.busContext.MessageLabelHandler.Inject(props, message.Label);
-
-            DiagnosticProps.Store(DiagnosticProps.Names.LastPublishAttemptConnectionString, this.ConnectionString);
-
-            this.SafeNativeInvoke(n => n.BasicPublish(nativeRoute.Exchange, nativeRoute.RoutingKey, false, props, body));
-        }
-
-        /// <summary>
-        /// The reject.
-        /// </summary>
-        /// <param name="delivery">
-        /// The delivery.
-        /// </param>
-        /// <param name="requeue">
-        /// The requeue.
-        /// </param>
-        public void Reject(RabbitDelivery delivery, bool requeue)
-        {
-            this.logger.Trace(m => m("Rejecting message [{0}] ({1}).", delivery.Label, delivery.Args.DeliveryTag));
-
-            this.SafeNativeInvoke(n => n.BasicNack(delivery.Args.DeliveryTag, false, requeue));
-        }
-
-        /// <summary>
-        /// The reply.
-        /// </summary>
-        /// <param name="message">
-        /// The message.
-        /// </param>
-        /// <param name="replyTo">
-        /// The reply to.
-        /// </param>
-        /// <param name="correlationId">
-        /// The correlation id.
-        /// </param>
-        public void Reply(IMessage message, RabbitRoute replyTo, string correlationId)
-        {
-            Func<IBasicProperties, IDictionary<string, object>> propsVisitor = p =>
-            {
-                p.CorrelationId = correlationId;
-                return message.Headers;
-            };
-
-            this.Publish(new RabbitRoute(replyTo.Exchange, replyTo.RoutingKey), message, propsVisitor);
-        }
-
-        /// <summary>
-        /// The set qos.
-        /// </summary>
-        /// <param name="qos">
-        /// The qos.
-        /// </param>
-        public void SetQos(QoSParams qos)
-        {
-            try
-            {
-                this.SafeNativeInvoke(n => n.BasicQos(qos.PrefetchSize, qos.PrefetchCount, false));
-            }
-            catch (Exception e)
-            {
-                this.logger.Error(m => m("Failed to set Qos on channel: {0}", this.ToString()), e);
-                throw;
-            }
-        }
-
-        /// <summary>
-        /// The start consuming.
-        /// </summary>
-        /// <param name="listeningSource">
-        /// The listening source.
-        /// </param>
-        /// <param name="requireAccept">
-        /// The require accept.
-        /// </param>
-        /// <param name="consumer">
-        /// The consumer.
-        /// </param>
-        /// <returns>
-        /// The <see cref="string"/>.
-        /// </returns>
-        public string StartConsuming(IListeningSource listeningSource, bool requireAccept, IBasicConsumer consumer)
-        {
-            try
-            {
-                var consumerTag = string.Empty;
-
-                this.SafeNativeInvoke(n => consumerTag = n.BasicConsume(listeningSource.Address, !requireAccept, consumer));
-
-                return consumerTag;
-            }
-            catch (Exception e)
-            {
-                this.logger.Error(m => m("Failed start consuming on channel."), e);
-                throw;
-            }
-        }
-
-        /// <summary>
-        /// The unpack as.
-        /// </summary>
-        /// <param name="type">
-        /// The type.
-        /// </param>
-        /// <param name="delivery">
-        /// The delivery.
-        /// </param>
-        /// <returns>
-        /// The <see cref="IMessage"/>.
-        /// </returns>
-        public IMessage UnpackAs(Type type, RabbitDelivery delivery)
-        {
-            var payload = this.busContext.PayloadConverter.ToObject(delivery.Args.Body.ToArray(), type);
-            return new Message(delivery.Label, delivery.Headers, payload);
-        }
-
-        private void OnModelShutdown(object sender, ShutdownEventArgs args)
-        {
-            this.logger.Trace($"Channel is closed due to '{args.ReplyText}'");
-            this.Shutdown(this, args);
-        }
-
-        /// <summary>
-        /// The safe native invoke.
-        /// </summary>
-        /// <param name="invokeAction">
-        /// The invoke action.
-        /// </param>
-        private void SafeNativeInvoke(Action<IModel> invokeAction)
-        {
-            try
-            {
-                lock (this.sync)
-                {
-                    this.logger.Trace($"Performing channel action [{invokeAction.Method.Name}]");
-                    invokeAction(this.Model);
-                }
-            }
-            catch (Exception ex)
-            {
-                this.logger.Error($"Channel action failed due to {ex.Message}, connection string: [{this.ConnectionString}]", ex);
-                throw;
-            }
-        }
-    }
-}
+using RabbitMQ.Client.Events;
+
+namespace Contour.Transport.RabbitMQ.Internal
+{
+    using System;
+    using System.Collections.Generic;
+    using System.IO;
+    using Common.Logging;
+    using Helpers;
+    using Receiving;
+    using Topology;
+    using global::RabbitMQ.Client;
+    using System.Threading;
+
+    /// <summary>
+    /// The rabbit channel.
+    /// </summary>
+    internal sealed class RabbitChannel : IChannel
+    {
+        private readonly object sync = new object();
+        private readonly IBusContext busContext;
+
+        private readonly ILog logger;
+
+        /// <summary>
+        /// Initializes a new instance of the <see cref="RabbitChannel"/> class. 
+        /// </summary>
+        /// <param name="connectionId">A connection identifier to which this channel belongs</param>
+        /// <param name="model">A native transport channel</param>
+        /// <param name="busContext">A bus context</param>
+        /// <param name="connectionString">Used connection string</param>
+        /// <param name="connectionKey">Key by connection string</param>
+        public RabbitChannel(Guid connectionId, IModel model, IBusContext busContext, string connectionString, string connectionKey)
+        {
+            this.ConnectionId = connectionId;
+            this.Model = model;
+            this.busContext = busContext;
+            this.ConnectionString = connectionString;
+            this.logger = LogManager.GetLogger($"{this.GetType().FullName}({this.ConnectionId}, {this.GetHashCode()})");
+            this.ConnectionKey = connectionKey;
+
+            this.Model.ModelShutdown += this.OnModelShutdown;
+        }
+
+        /// <summary>
+        /// Строка подключения
+        /// </summary>
+        internal string ConnectionString { get; }
+
+        public Guid ConnectionId { get; }
+
+        public string ConnectionKey { get; }
+
+        /// <summary>
+        /// The failed.
+        /// </summary>
+        [Obsolete("Channel failures are no longer propagated outside via events, instead an exception is thrown")]
+        public event Action<IChannel, ErrorEventArgs> Failed = (channel, args) => { };
+
+        /// <summary>
+        /// Is fired on channel shutdown.
+        /// </summary>
+        public event Action<IChannel, ShutdownEventArgs> Shutdown = (channel, args) => { };
+
+        /// <summary>
+        /// Gets the native.
+        /// </summary>
+        protected IModel Model { get; }
+
+        /// <summary>
+        /// Aborts the channel
+        /// </summary>
+        public void Abort()
+        {
+            this.Model?.Abort();
+        }
+
+        /// <summary>
+        /// The accept.
+        /// </summary>
+        /// <param name="delivery">
+        /// The delivery.
+        /// </param>
+        public void Accept(RabbitDelivery delivery)
+        {
+            this.logger.Trace(m => m("Accepting message [{0}] ({1}).", delivery.Label, delivery.Args.DeliveryTag));
+
+            this.SafeNativeInvoke(n => n.BasicAck(delivery.Args.DeliveryTag, false));
+        }
+
+        /// <summary>
+        /// The bind.
+        /// </summary>
+        /// <param name="queue">
+        /// The queue.
+        /// </param>
+        /// <param name="exchange">
+        /// The exchange.
+        /// </param>
+        /// <param name="routingKey">
+        /// The routing key.
+        /// </param>
+        public void Bind(Queue queue, Exchange exchange, string routingKey)
+        {
+            try
+            {
+                this.SafeNativeInvoke(n => n.QueueBind(queue.Name, exchange.Name, routingKey));
+            }
+            catch (Exception e)
+            {
+                this.logger.Error(m => m("Failed to bind queue to exchange [{1}:{2}] on channel: {0}", this.ToString(), exchange.Name, queue.Name), e);
+                throw;
+            }
+        }
+
+        /// <summary>
+        /// The build AsyncEventingBasicConsumer consumer.
+        /// </summary>
+        /// <returns>
+        /// The <see cref="AsyncEventingBasicConsumer"/>.
+        /// </returns>
+        public AsyncEventingBasicConsumer BuildConsumer()
+        {
+            return new AsyncEventingBasicConsumer(this.Model);
+        }
+
+
+        /// <summary>
+        /// The build cancellable consumer.
+        /// </summary>
+        /// <param name="cancellationToken">
+        /// The cancellation token.
+        /// </param>
+        /// <returns>
+        /// The <see cref="CancellableQueueingConsumer"/>.
+        /// </returns>
+        public CancellableQueueingConsumer BuildCancellableConsumer(CancellationToken cancellationToken)
+        {
+            return new CancellableQueueingConsumer(this.Model, cancellationToken);
+        }
+
+        /// <summary>
+        /// The declare.
+        /// </summary>
+        /// <param name="exchange">
+        /// The exchange.
+        /// </param>
+        public void Declare(Exchange exchange)
+        {
+            try
+            {
+                this.SafeNativeInvoke(n => n.ExchangeDeclare(exchange.Name, exchange.Type, exchange.Durable, exchange.AutoDelete, new Dictionary<string, object>()));
+            }
+            catch (Exception e)
+            {
+                this.logger.Error(m => m("Failed to Declare Exchange [{1}] on channel: {0}", this.ToString(), exchange.Name), e);
+                throw;
+            }
+        }
+
+        /// <summary>
+        /// The declare.
+        /// </summary>
+        /// <param name="queue">
+        /// The queue.
+        /// </param>
+        public void Declare(Queue queue)
+        {
+            try
+            {
+                var arguments = new Dictionary<string, object>();
+                if (queue.Ttl.HasValue)
+                {
+                    arguments.Add(Contour.Headers.QueueMessageTtl, (long)queue.Ttl.Value.TotalMilliseconds);
+                }
+
+                if (queue.Limit.HasValue)
+                {
+                    arguments.Add(Contour.Headers.QueueMaxLength, (int)queue.Limit);
+                }
+
+                if (queue.MaxLengthBytes.HasValue)
+                {
+                    arguments.Add(Contour.Headers.QueueMaxLengthBytes, (int)queue.MaxLengthBytes);
+                }
+
+                this.SafeNativeInvoke(n =>
+                    n.QueueDeclare(queue.Name, queue.Durable, queue.Exclusive, queue.AutoDelete, arguments));
+            }
+            catch (Exception e)
+            {
+                this.logger.Error(m => m("Failed to Declare Queue [{1}] on channel: {0}", this.ToString(), queue.Name),
+                    e);
+                throw;
+            }
+        }
+
+        /// <summary>
+        /// The declare default queue.
+        /// </summary>
+        /// <returns>
+        /// The <see cref="string"/>.
+        /// </returns>
+        public string DeclareDefaultQueue()
+        {
+            try
+            {
+                var queueName = string.Empty;
+
+                this.SafeNativeInvoke(n => queueName = n.QueueDeclare());
+
+                return queueName;
+            }
+            catch (Exception e)
+            {
+                this.logger.Error(m => m("Failed to Declare Default Queue on channel: {0}", this.ToString()), e);
+                throw;
+            }
+        }
+
+        /// <summary>
+        /// The dispose.
+        /// </summary>
+        public void Dispose()
+        {
+            if (this.Model != null)
+            {
+                this.Model.ModelShutdown -= this.OnModelShutdown;
+
+                try
+                {
+                    this.Model.Abort();
+                    this.Model.Dispose();
+                }
+                catch (Exception)
+                {
+                    // Suppress all errors here
+                }
+            }
+        }
+
+        /// <summary>
+        /// Enable publish confirmation.
+        /// </summary>
+        public void EnablePublishConfirmation()
+        {
+            this.SafeNativeInvoke(n => n.ConfirmSelect());
+        }
+
+        /// <summary>
+        /// Get next seq no.
+        /// </summary>
+        /// <returns>
+        /// The <see cref="ulong"/>.
+        /// </returns>
+        public ulong GetNextSeqNo()
+        {
+            ulong seqNo = 0UL;
+            this.SafeNativeInvoke(n => seqNo = n.NextPublishSeqNo);
+            return seqNo;
+        }
+
+        /// <summary>
+        /// The on confirmation.
+        /// </summary>
+        /// <param name="handleConfirmation">
+        /// The handle confirmation.
+        /// </param>
+        public void OnConfirmation(ConfirmationHandler handleConfirmation)
+        {
+            this.SafeNativeInvoke(
+                n =>
+                    {
+                        n.BasicAcks += (model, args) => handleConfirmation(true, args.DeliveryTag, args.Multiple);
+                        n.BasicNacks += (model, args) => handleConfirmation(false, args.DeliveryTag, args.Multiple);
+                    });
+        }
+
+        /// <summary>
+        /// The publish.
+        /// </summary>
+        /// <param name="route">
+        /// The route.
+        /// </param>
+        /// <param name="message">
+        /// The message.
+        /// </param>
+        /// <param name="propsVisitor">
+        /// The props visitor.
+        /// </param>
+        public void Publish(IRoute route, IMessage message, Func<IBasicProperties, IDictionary<string, object>> propsVisitor = null)
+        {
+            var nativeRoute = (RabbitRoute)route;
+
+            this.logger.Trace(m => m("Emitting message [{0}] ({1}) through [{2}].", message.Label, message.Payload, nativeRoute));
+
+            var props = this.Model.CreateBasicProperties();
+            var body = this.busContext.PayloadConverter.FromObject(message.Payload);
+
+            if (props.Headers == null)
+            {
+                props.Headers = new Dictionary<string, object>();
+            }
+
+            props.ContentType = this.busContext.PayloadConverter.ContentType;
+            props.Timestamp = new AmqpTimestamp(DateTime.UtcNow.ToUnixTimestamp());
+
+            var headers = propsVisitor?.Invoke(props);
+            headers.ForEach(i => props.Headers.Add(i));
+
+            this.busContext.MessageLabelHandler.Inject(props, message.Label);
+
+            DiagnosticProps.Store(DiagnosticProps.Names.LastPublishAttemptConnectionString, this.ConnectionString);
+
+            this.SafeNativeInvoke(n => n.BasicPublish(nativeRoute.Exchange, nativeRoute.RoutingKey, false, props, body));
+        }
+
+        /// <summary>
+        /// The reject.
+        /// </summary>
+        /// <param name="delivery">
+        /// The delivery.
+        /// </param>
+        /// <param name="requeue">
+        /// The requeue.
+        /// </param>
+        public void Reject(RabbitDelivery delivery, bool requeue)
+        {
+            this.logger.Trace(m => m("Rejecting message [{0}] ({1}).", delivery.Label, delivery.Args.DeliveryTag));
+
+            this.SafeNativeInvoke(n => n.BasicNack(delivery.Args.DeliveryTag, false, requeue));
+        }
+
+        /// <summary>
+        /// The reply.
+        /// </summary>
+        /// <param name="message">
+        /// The message.
+        /// </param>
+        /// <param name="replyTo">
+        /// The reply to.
+        /// </param>
+        /// <param name="correlationId">
+        /// The correlation id.
+        /// </param>
+        public void Reply(IMessage message, RabbitRoute replyTo, string correlationId)
+        {
+            Func<IBasicProperties, IDictionary<string, object>> propsVisitor = p =>
+            {
+                p.CorrelationId = correlationId;
+                return message.Headers;
+            };
+
+            this.Publish(new RabbitRoute(replyTo.Exchange, replyTo.RoutingKey), message, propsVisitor);
+        }
+
+        /// <summary>
+        /// The set qos.
+        /// </summary>
+        /// <param name="qos">
+        /// The qos.
+        /// </param>
+        public void SetQos(QoSParams qos)
+        {
+            try
+            {
+                this.SafeNativeInvoke(n => n.BasicQos(qos.PrefetchSize, qos.PrefetchCount, false));
+            }
+            catch (Exception e)
+            {
+                this.logger.Error(m => m("Failed to set Qos on channel: {0}", this.ToString()), e);
+                throw;
+            }
+        }
+
+        /// <summary>
+        /// The start consuming.
+        /// </summary>
+        /// <param name="listeningSource">
+        /// The listening source.
+        /// </param>
+        /// <param name="requireAccept">
+        /// The require accept.
+        /// </param>
+        /// <param name="consumer">
+        /// The consumer.
+        /// </param>
+        /// <returns>
+        /// The <see cref="string"/>.
+        /// </returns>
+        public string StartConsuming(IListeningSource listeningSource, bool requireAccept, IBasicConsumer consumer)
+        {
+            try
+            {
+                var consumerTag = string.Empty;
+
+                this.SafeNativeInvoke(n => consumerTag = n.BasicConsume(listeningSource.Address, !requireAccept, consumer));
+
+                return consumerTag;
+            }
+            catch (Exception e)
+            {
+                this.logger.Error(m => m("Failed start consuming on channel."), e);
+                throw;
+            }
+        }
+
+        /// <summary>
+        /// Unsubscribe consumer from queue via <param name="tag"/> subscription ID.
+        /// </summary>
+        /// <param name="tag">Subscription ID</param>
+        public void StopConsuming(string tag)
+        {
+            this.Model.BasicCancel(tag);
+        }
+
+        /// <summary>
+        /// The unpack as.
+        /// </summary>
+        /// <param name="type">
+        /// The type.
+        /// </param>
+        /// <param name="delivery">
+        /// The delivery.
+        /// </param>
+        /// <returns>
+        /// The <see cref="IMessage"/>.
+        /// </returns>
+        public IMessage UnpackAs(Type type, RabbitDelivery delivery)
+        {
+            var payload = this.busContext.PayloadConverter.ToObject(delivery.Args.Body.ToArray(), type);
+            return new Message(delivery.Label, delivery.Headers, payload);
+        }
+
+        private void OnModelShutdown(object sender, ShutdownEventArgs args)
+        {
+            this.logger.Trace($"Channel is closed due to '{args.ReplyText}'");
+            this.Shutdown(this, args);
+        }
+
+        /// <summary>
+        /// The safe native invoke.
+        /// </summary>
+        /// <param name="invokeAction">
+        /// The invoke action.
+        /// </param>
+        private void SafeNativeInvoke(Action<IModel> invokeAction)
+        {
+            try
+            {
+                lock (this.sync)
+                {
+                    this.logger.Trace($"Performing channel action [{invokeAction.Method.Name}]");
+                    invokeAction(this.Model);
+                }
+            }
+            catch (Exception ex)
+            {
+                this.logger.Error($"Channel action failed due to {ex.Message}, connection string: [{this.ConnectionString}]", ex);
+                throw;
+            }
+        }
+    }
+}
diff --git a/Sources/Contour/Transport/RabbitMQ/Internal/RabbitConnection.cs b/Sources/Contour/Transport/RabbitMQ/Internal/RabbitConnection.cs
index facc01a..ed61c7e 100644
--- a/Sources/Contour/Transport/RabbitMQ/Internal/RabbitConnection.cs
+++ b/Sources/Contour/Transport/RabbitMQ/Internal/RabbitConnection.cs
@@ -1,4 +1,4 @@
-using System;
+using System;
 using System.Collections.Generic;
 using System.IO;
 using System.Linq;
@@ -27,7 +27,7 @@ internal class RabbitConnection : IRabbitConnection
         private readonly ConnectionFactory connectionFactory;
         private INativeConnection connection;
 
-        public RabbitConnection(IEndpoint endpoint, string connectionString, IBusContext busContext)
+        public RabbitConnection(IEndpoint endpoint, string connectionString, IBusContext busContext, bool async = false)
         {
             this.Id = Guid.NewGuid();
             this.endpoint = endpoint;
@@ -49,8 +49,14 @@ public RabbitConnection(IEndpoint endpoint, string connectionString, IBusContext
                 Uri = new Uri(this.ConnectionString),
                 AutomaticRecoveryEnabled = false,
                 ClientProperties = clientProperties,
-                RequestedConnectionTimeout = TimeSpan.FromMilliseconds(ConnectionTimeout)
+                RequestedConnectionTimeout = TimeSpan.FromMilliseconds(ConnectionTimeout),
             };
+
+            if (async)
+            {
+                this.connectionFactory.DispatchConsumersAsync = true;
+                this.connectionFactory.ConsumerDispatchConcurrency = 1;
+            }
         }
 
         public event EventHandler Opened;
@@ -258,4 +264,4 @@ private static string GetConnectionKey(string connectionString)
             return $"{ip}:{uri.Port}:{uri.Segments.Last()}";
         }
     }
-}
\ No newline at end of file
+}
diff --git a/Sources/Contour/Transport/RabbitMQ/Internal/RabbitConnectionPool.cs b/Sources/Contour/Transport/RabbitMQ/Internal/RabbitConnectionPool.cs
index 976617e..c680e17 100644
--- a/Sources/Contour/Transport/RabbitMQ/Internal/RabbitConnectionPool.cs
+++ b/Sources/Contour/Transport/RabbitMQ/Internal/RabbitConnectionPool.cs
@@ -2,9 +2,9 @@ namespace Contour.Transport.RabbitMQ.Internal
 {
     internal class RabbitConnectionPool : ConnectionPool<IRabbitConnection>
     {
-        public RabbitConnectionPool(IBusContext context)
+        public RabbitConnectionPool(IBusContext context, bool asyncConsuming)
         {
-            this.Provider = new RabbitConnectionProvider(context);
+            this.Provider = new RabbitConnectionProvider(context, asyncConsuming);
         }
     }
-}
\ No newline at end of file
+}
diff --git a/Sources/Contour/Transport/RabbitMQ/Internal/RabbitConnectionProvider.cs b/Sources/Contour/Transport/RabbitMQ/Internal/RabbitConnectionProvider.cs
index 01764d9..7454156 100644
--- a/Sources/Contour/Transport/RabbitMQ/Internal/RabbitConnectionProvider.cs
+++ b/Sources/Contour/Transport/RabbitMQ/Internal/RabbitConnectionProvider.cs
@@ -1,4 +1,4 @@
-using Common.Logging;
+using Common.Logging;
 
 namespace Contour.Transport.RabbitMQ.Internal
 {
@@ -7,17 +7,19 @@ internal class RabbitConnectionProvider : IConnectionProvider<IRabbitConnection>
         private readonly ILog logger = LogManager.GetLogger<RabbitConnectionProvider>();
         private readonly IEndpoint endpoint;
         private readonly IBusContext context;
+        private readonly bool asyncConsuming;
 
-        public RabbitConnectionProvider(IBusContext context)
+        public RabbitConnectionProvider(IBusContext context, bool asyncConsuming)
         {
             this.endpoint = context.Endpoint;
-            this.context = context;
+            this.context = context;
+            this.asyncConsuming = asyncConsuming;
         }
 
         public IRabbitConnection Create(string connectionString)
         {
             this.logger.Trace($"Creating a new connection for endpoint [{this.endpoint}] at [{connectionString}]");
-            return new RabbitConnection(this.endpoint, connectionString, this.context);
+            return new RabbitConnection(this.endpoint, connectionString, this.context, asyncConsuming);
         }
     }
 }
diff --git a/Sources/Contour/Transport/RabbitMQ/Internal/RabbitDelivery.cs b/Sources/Contour/Transport/RabbitMQ/Internal/RabbitDelivery.cs
index 7a567f0..cafcc0b 100644
--- a/Sources/Contour/Transport/RabbitMQ/Internal/RabbitDelivery.cs
+++ b/Sources/Contour/Transport/RabbitMQ/Internal/RabbitDelivery.cs
@@ -1,7 +1,6 @@
-using System;
+using System;
 using System.Collections.Generic;
 using System.Diagnostics.CodeAnalysis;
-using System.Globalization;
 using System.Threading.Tasks;
 
 using Contour.Configuration;
@@ -247,7 +246,9 @@ public IMessage UnpackAs(Type type)
         /// <returns>Заголовки сообщения.</returns>
         private IDictionary<string, object> ExtractHeadersFrom(BasicDeliverEventArgs args)
         {
-            var h = new Dictionary<string, object>(args.BasicProperties.Headers);
+            var h = args.BasicProperties.Headers != null
+                ? new Dictionary<string, object>(args.BasicProperties.Headers)
+                : new Dictionary<string, object>();
 
             if (this.CorrelationId != null)
             {
@@ -262,4 +263,4 @@ private IDictionary<string, object> ExtractHeadersFrom(BasicDeliverEventArgs arg
             return h;
         }
     }
-}
\ No newline at end of file
+}