Package kieker.monitoring.writer.dump
Class DumpQueue
java.lang.Object
kieker.monitoring.writer.dump.DumpQueue
- All Implemented Interfaces:
java.lang.Iterable<IMonitoringRecord>
,java.util.Collection<IMonitoringRecord>
,java.util.concurrent.BlockingQueue<IMonitoringRecord>
,java.util.Queue<IMonitoringRecord>
public class DumpQueue extends java.lang.Object implements java.util.concurrent.BlockingQueue<IMonitoringRecord>
-
Constructor Summary
-
Method Summary
Modifier and Type Method Description boolean
add(IMonitoringRecord e)
boolean
addAll(java.util.Collection<? extends IMonitoringRecord> c)
void
clear()
boolean
contains(java.lang.Object o)
boolean
containsAll(java.util.Collection<?> c)
int
drainTo(java.util.Collection<? super IMonitoringRecord> c)
int
drainTo(java.util.Collection<? super IMonitoringRecord> c, int maxElements)
IMonitoringRecord
element()
boolean
isEmpty()
java.util.Iterator<IMonitoringRecord>
iterator()
boolean
offer(IMonitoringRecord e)
boolean
offer(IMonitoringRecord e, long timeout, java.util.concurrent.TimeUnit unit)
IMonitoringRecord
peek()
IMonitoringRecord
poll()
IMonitoringRecord
poll(long timeout, java.util.concurrent.TimeUnit unit)
void
put(IMonitoringRecord e)
int
remainingCapacity()
IMonitoringRecord
remove()
boolean
remove(java.lang.Object o)
boolean
removeAll(java.util.Collection<?> c)
boolean
retainAll(java.util.Collection<?> c)
int
size()
IMonitoringRecord
take()
java.lang.Object[]
toArray()
<T> T[]
toArray(T[] a)
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Constructor Details
-
Method Details
-
remove
- Specified by:
remove
in interfacejava.util.Queue<IMonitoringRecord>
-
poll
- Specified by:
poll
in interfacejava.util.Queue<IMonitoringRecord>
-
element
- Specified by:
element
in interfacejava.util.Queue<IMonitoringRecord>
-
peek
- Specified by:
peek
in interfacejava.util.Queue<IMonitoringRecord>
-
size
public int size()- Specified by:
size
in interfacejava.util.Collection<IMonitoringRecord>
-
isEmpty
public boolean isEmpty()- Specified by:
isEmpty
in interfacejava.util.Collection<IMonitoringRecord>
-
iterator
- Specified by:
iterator
in interfacejava.util.Collection<IMonitoringRecord>
- Specified by:
iterator
in interfacejava.lang.Iterable<IMonitoringRecord>
-
toArray
public java.lang.Object[] toArray()- Specified by:
toArray
in interfacejava.util.Collection<IMonitoringRecord>
-
toArray
public <T> T[] toArray(T[] a)- Specified by:
toArray
in interfacejava.util.Collection<IMonitoringRecord>
-
containsAll
public boolean containsAll(java.util.Collection<?> c)- Specified by:
containsAll
in interfacejava.util.Collection<IMonitoringRecord>
-
addAll
- Specified by:
addAll
in interfacejava.util.Collection<IMonitoringRecord>
-
removeAll
public boolean removeAll(java.util.Collection<?> c)- Specified by:
removeAll
in interfacejava.util.Collection<IMonitoringRecord>
-
retainAll
public boolean retainAll(java.util.Collection<?> c)- Specified by:
retainAll
in interfacejava.util.Collection<IMonitoringRecord>
-
clear
public void clear()- Specified by:
clear
in interfacejava.util.Collection<IMonitoringRecord>
-
add
- Specified by:
add
in interfacejava.util.concurrent.BlockingQueue<IMonitoringRecord>
- Specified by:
add
in interfacejava.util.Collection<IMonitoringRecord>
- Specified by:
add
in interfacejava.util.Queue<IMonitoringRecord>
-
offer
- Specified by:
offer
in interfacejava.util.concurrent.BlockingQueue<IMonitoringRecord>
- Specified by:
offer
in interfacejava.util.Queue<IMonitoringRecord>
-
put
- Specified by:
put
in interfacejava.util.concurrent.BlockingQueue<IMonitoringRecord>
- Throws:
java.lang.InterruptedException
-
offer
public boolean offer(IMonitoringRecord e, long timeout, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException- Specified by:
offer
in interfacejava.util.concurrent.BlockingQueue<IMonitoringRecord>
- Throws:
java.lang.InterruptedException
-
take
- Specified by:
take
in interfacejava.util.concurrent.BlockingQueue<IMonitoringRecord>
- Throws:
java.lang.InterruptedException
-
poll
public IMonitoringRecord poll(long timeout, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException- Specified by:
poll
in interfacejava.util.concurrent.BlockingQueue<IMonitoringRecord>
- Throws:
java.lang.InterruptedException
-
remainingCapacity
public int remainingCapacity()- Specified by:
remainingCapacity
in interfacejava.util.concurrent.BlockingQueue<IMonitoringRecord>
-
remove
public boolean remove(java.lang.Object o)- Specified by:
remove
in interfacejava.util.concurrent.BlockingQueue<IMonitoringRecord>
- Specified by:
remove
in interfacejava.util.Collection<IMonitoringRecord>
-
contains
public boolean contains(java.lang.Object o)- Specified by:
contains
in interfacejava.util.concurrent.BlockingQueue<IMonitoringRecord>
- Specified by:
contains
in interfacejava.util.Collection<IMonitoringRecord>
-
drainTo
- Specified by:
drainTo
in interfacejava.util.concurrent.BlockingQueue<IMonitoringRecord>
-
drainTo
- Specified by:
drainTo
in interfacejava.util.concurrent.BlockingQueue<IMonitoringRecord>
-