protected virtual void StopAsyncDelivery()

in src/main/csharp/MessageConsumer.cs [189:208]

19 lines of code
3 McCabe index (conditional complexity)


		protected virtual void StopAsyncDelivery()
		{
			lock(this.asyncDeliveryLock)
			{
				this.asyncDelivery = false;
				if(null != this.asyncDeliveryThread)
				{
					Tracer.Info("Stopping async delivery thread.");
					this.asyncDeliveryThread.Interrupt();
					if(!this.asyncDeliveryThread.Join(10000))
					{
						Tracer.Info("Aborting async delivery thread.");
						this.asyncDeliveryThread.Abort();
					}

					this.asyncDeliveryThread = null;
					Tracer.Info("Async delivery thread stopped.");
				}
			}
		}