在Apache NMS中，可以使用两种方法来实现故障转移：URI阻塞和非阻塞。下面是包含代码示例的解决方法：

1. URI阻塞方法： 使用URI阻塞的方法，可以在连接失败时阻塞线程并等待新的连接。

   Uri uri = new Uri("tcp://localhost:61616");
   IConnectionFactory factory = new NMSConnectionFactory(uri);
   
   using (IConnection connection = factory.CreateConnection())
   {
       connection.Start();
       using (ISession session = connection.CreateSession())
       {
           IDestination destination = session.GetQueue("myQueue");
           using (IMessageConsumer consumer = session.CreateConsumer(destination))
           {
               while (true)
               {
                   IMessage message = consumer.Receive();
                   if (message != null)
                   {
                       // 处理消息
                   }
               }
           }
       }
   }
   

   在上面的代码中，如果连接失败，程序将阻塞在consumer.Receive()方法并等待新的连接。

2. 非阻塞方法： 使用非阻塞的方法，可以在连接失败时立即返回，并使用回调函数处理连接恢复的事件。

   Uri uri = new Uri("tcp://localhost:61616");
   IConnectionFactory factory = new NMSConnectionFactory(uri);
   
   using (IConnection connection = factory.CreateConnection())
   {
       connection.Start();
       using (ISession session = connection.CreateSession())
       {
           IDestination destination = session.GetQueue("myQueue");
           using (IMessageConsumer consumer = session.CreateConsumer(destination))
           {
               consumer.Listener += OnMessageReceived;
   
               // 阻塞主线程，等待连接失败
               ManualResetEvent connectionEvent = new ManualResetEvent(false);
               connection.ConnectionInterruptedListener += (sender, args) => connectionEvent.Set();
   
               // 等待连接恢复
               connection.ConnectionResumedListener += (sender, args) =>
               {
                   // 重新订阅队列
                   consumer.Close();
                   consumer.MessageListener = null;
                   consumer.Listener += OnMessageReceived;
                   consumer.Start();
               };
   
               connectionEvent.WaitOne();
           }
       }
   }
   
   // 消息处理回调函数
   private static void OnMessageReceived(IMessage message)
   {
       // 处理消息
   }
   

   在上面的代码中，consumer.Listener属性用于注册消息处理的回调函数。如果连接失败，主线程将阻塞在connectionEvent.WaitOne()方法，并等待连接中断的事件触发。一旦连接恢复，将重新订阅队列并开始处理新的消息。

通过使用上述的URI阻塞和非阻塞方法，可以实现Apache NMS中的故障转移，并在连接失败时进行恢复处理。