Examples of MessageCounter

This class stores message count informations for a given queue At intervals this class samples the queue for message count data Note that the underlying queue *does not* update statistics every time a message is added since that would reall slow things down, instead we *sample* the queues at regular intervals - this means we are less intrusive on the queue @author Ulf Schroeter @author Stephan Steinbacher @author Tim Fox @version $Revision: 1.8 $

org.jboss.jms.server.messagecounter.MessageCounter

      
      Iterator iter = counters.iterator();
      
      while (iter.hasNext())
      {
         MessageCounter counter = (MessageCounter)iter.next();
         
         counter.setHistoryLimit(limit);
      }
   }

Examples of org.jboss.jms.server.messagecounter.MessageCounter


            if (!mDest.isTemporary())
            {
              String counterName = TopicService.SUBSCRIPTION_MESSAGECOUNTER_PREFIX + queueName;
  
              MessageCounter counter = sp.getMessageCounterManager().unregisterMessageCounter(counterName);
  
              if (counter == null)
              {
                 throw new IllegalStateException("Cannot find counter to remove " + counterName);
              }

Examples of org.jboss.jms.server.messagecounter.MessageCounter


         postOffice.removeBinding(sub.getName(), sub.isClustered() && postOffice.isClustered());


         String counterName = TopicService.SUBSCRIPTION_MESSAGECOUNTER_PREFIX + sub.getName();


         MessageCounter counter = sp.getMessageCounterManager().unregisterMessageCounter(counterName);


         if (counter == null)
         {
            throw new IllegalStateException("Cannot find counter to remove " + counterName);
         }

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.