code: @Override
  	public void unregisterConsumer(LocalMessageConsumer consumer)
      {
          super.unregisterConsumer(consumer);
          if (!consumer.isDurable())
          {
              log.debug("Removing non-durable subscription "+consumer.getSubscriberId());
              subscriptionsLock.writeLock().lock();
              try
      		{
              	LocalTopicSubscription subscription = subscriptionMap.remove(consumer.getSubscriberId());
              	if (subscription != null)
              		removeSubscription(subscription);
      		}
              finally
              {
              	subscriptionsLock.writeLock().unlock();
              }
          }
      }
docs: /* (non-Javadoc)
  @see net.timewalker.ffmq4.local.destination.AbstractLocalDestination#unregisterConsumer(net.timewalker.ffmq4.local.session.LocalMessageConsumer)