@Override
	public int getSize()
    {
    	int size = 0;
    	subscriptionsLock.readLock().lock();
    	try
        {
    		for(LocalTopicSubscription subscription : subscriptionMap.values())
        	{
                size += subscription.getLocalQueue().getSize();
            }
        }
    	finally
    	{
    		subscriptionsLock.readLock().unlock();
    	}
    	
    	return size;
    }
@ Override public int getSize ( ) { int size = 0 ; subscriptionsLock . readLock ( ) . lock ( ) ; try { for ( LocalTopicSubscription subscription : subscriptionMap . values ( ) ) { size += subscription . getLocalQueue ( ) . getSize ( ) ; } } finally { subscriptionsLock . readLock ( ) . unlock ( ) ; } return size ; }
/*
(non-Javadoc)
@see net.timewalker.ffmq4.local.destination.LocalDestinationMBean#getSize()