ConnectionFactory connectionFactory = new ConnectionFactory
{
    UserName = "guest",
    Password = "guest",
    HostName = "192.168.151.81",
    Port = 5672,
    SocketWriteTimeout = -1,
};
IModel model = Program._connection.CreateModel();
EventingBasicConsumer eventingBasicConsumer = new EventingBasicConsumer(model);
eventingBasicConsumer.Shutdown += EventingBasicConsumer_Shutdown;
model.BasicQos(0, 1, false);
model.BasicConsume("MixQueueTest", false, eventingBasicConsumer);
eventingBasicConsumer.Received += EventingBasicConsumer_Received;

private static void EventingBasicConsumer_Received(object sender, BasicDeliverEventArgs e)
{
    (sender as EventingBasicConsumer).Model.BasicPublish(
        "NoExistQueue",
        "",
        null,
        Encoding.UTF8.GetBytes("justtest"));
}

private static void EventingBasicConsumer_Shutdown(object sender, ShutdownEventArgs e)
{
    IModel model = Program._connection.CreateModel(); // it will failed by timeout
}

private static IConnection _connection;
static void Main(string[] args)
{
    string hostName = null;
    hostName = "192.168.151.81";
    ConnectionFactory connectionFactory = new ConnectionFactory
    {
        UserName = "guest",
        Password = "guest",
        HostName = hostName,
        Port = 5672,
        SocketWriteTimeout = -1,
    };
    Program._connection = connectionFactory.CreateConnection();
    IModel model = _connection.CreateModel();
    EventingBasicConsumer eventingBasicConsumer = new EventingBasicConsumer(model);
    eventingBasicConsumer.Shutdown += EventingBasicConsumer_Shutdown;
    model.BasicQos(0, 1, false);
    model.BasicConsume("MixQueueTest", false, eventingBasicConsumer);
    eventingBasicConsumer.Received += EventingBasicConsumer_Received;
    Console.ReadLine();
}

private static void EventingBasicConsumer_Received(object sender, BasicDeliverEventArgs e)
{
    (sender as EventingBasicConsumer).Model.BasicPublish(
    "NoExistQueue",
    "",
    null,
    Encoding.UTF8.GetBytes("justtest"));
}

private static void EventingBasicConsumer_Shutdown(object sender, ShutdownEventArgs e)
{
    IModel model = Program._connection.CreateModel(); // it will failed by timeout
}