xmlBlaster 2.2.0 API

org.xmlBlaster.test.classtest.queue
Class I_QueueTest.QueueSizeListener

java.lang.Object
  extended by org.xmlBlaster.test.classtest.queue.I_QueueTest.QueueSizeListener
All Implemented Interfaces:
I_StorageSizeListener
Enclosing class:
I_QueueTest

 class I_QueueTest.QueueSizeListener
extends java.lang.Object
implements I_StorageSizeListener


Field Summary
private  int count
           
private  long lastIncrementBytes
           
private  long lastIncrementEntries
           
private  long lastNumBytes
           
private  long lastNumEntries
           
 
Constructor Summary
I_QueueTest.QueueSizeListener()
           
 
Method Summary
 void changed(I_Storage storage, long numEntries, long numBytes, boolean isShutdown)
          This event is sent every time a change in entries has occurred in the queue.
 void clear()
           
 int getCount()
           
 long getLastIncrementBytes()
           
 long getLastIncrementEntries()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

lastNumEntries

private long lastNumEntries

lastNumBytes

private long lastNumBytes

lastIncrementEntries

private long lastIncrementEntries

lastIncrementBytes

private long lastIncrementBytes

count

private int count
Constructor Detail

I_QueueTest.QueueSizeListener

I_QueueTest.QueueSizeListener()
Method Detail

getLastIncrementEntries

public long getLastIncrementEntries()

getLastIncrementBytes

public long getLastIncrementBytes()

getCount

public int getCount()

clear

public void clear()

changed

public void changed(I_Storage storage,
                    long numEntries,
                    long numBytes,
                    boolean isShutdown)
Description copied from interface: I_StorageSizeListener
This event is sent every time a change in entries has occurred in the queue.

It is invoked after the change has taken place. It allows for example to generate threshold alarms.

changed() is additionally called if the queue is shutdown (you can't operate on the queue anymore in this case).

The changed() invocation is guaranteed to NOT be in any Queue specific synchronize

Specified by:
changed in interface I_StorageSizeListener
Parameters:
storage - The queue which fires the change event
numEntries - the number of entries in the queue after the change has taken place
numBytes - number of bytes in the queue after the change has taken change.
isShutdown - Is set to true if queue.shutdown() was executed

xmlBlaster 2.2.0 API

Copyright © 1999-2014 The xmlBlaster.org contributers.