in src/main/csharp/MessageConsumer.cs [96:125]
public void Close()
{
lock(this)
{
if(closed)
{
return;
}
}
// wake up any pending dequeue() call on the dispatcher
this.dispatcher.Close();
lock(this)
{
try
{
this.xmsMessageConsumer.MessageListener = null;
this.xmsMessageConsumer.Close();
}
catch(Exception ex)
{
ExceptionUtil.WrapAndThrowNMSException(ex);
}
finally
{
closed = true;
}
}
}