org.ops4j.pax.radman.service.event.repeater.queue.internal
Class EventQueueImpl<E>

java.lang.Object
  org.ops4j.pax.radman.service.event.repeater.queue.internal.EventQueueImpl<E>

Type Parameters:

E - the type of elements held in this queue

All Implemented Interfaces:

java.lang.Iterable<E>, java.util.Collection<E>, java.util.Queue<E>, EventQueue<E>

@ThreadSafe
public class EventQueueImpl<E>
extends java.lang.Object
implements EventQueue<E>

An asynchronous & thread-safe FIFO EventQueue.

Author:

Gavin Bong

Field Summary

Fields inherited from interface org.ops4j.pax.radman.service.event.repeater.EventQueue

ROLE, ROLE_GATEWAY, ROLE_HOST

Constructor Summary

EventQueueImpl(java.util.concurrent.ConcurrentLinkedQueue<E> queue, org.osgi.framework.BundleContext context)

Method Summary

boolean	add(E o)
boolean	addAll(java.util.Collection<? extends E> c)
void	clear()
boolean	contains(java.lang.Object o)
boolean	containsAll(java.util.Collection<?> c)
E	element()
boolean	isEmpty()
boolean	isRegistered() Thread-safe: No
java.util.Iterator<E>	iterator()
boolean	offer(E o)
E	peek()
E	poll()
E	remove()
boolean	remove(java.lang.Object o)
boolean	removeAll(java.util.Collection<?> c)
boolean	retainAll(java.util.Collection<?> c)
int	size()
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

Methods inherited from interface java.util.Collection

equals, hashCode

Constructor Detail

EventQueueImpl

public EventQueueImpl(java.util.concurrent.ConcurrentLinkedQueue<E> queue,
                      org.osgi.framework.BundleContext context)

Parameters:

queue - non-nullable

context - non-nullable

Throws:

java.lang.IllegalArgumentException - if either one of queue or context is null

Method Detail

isRegistered

public final boolean isRegistered()

Thread-safe: No

Clients must obtain a lock before calling

Returns:

true if this instance has not registered to the OSGi service registry

element

public E element()

Specified by:

element in interface java.util.Queue<E>

offer

public boolean offer(E o)

Specified by:

offer in interface java.util.Queue<E>

peek

public E peek()

Specified by:

peek in interface java.util.Queue<E>

poll

public E poll()

Specified by:

poll in interface java.util.Queue<E>

remove

public E remove()

Specified by:

remove in interface java.util.Queue<E>

add

public boolean add(E o)

Specified by:

add in interface java.util.Collection<E>

addAll

public boolean addAll(java.util.Collection<? extends E> c)

Specified by:

addAll in interface java.util.Collection<E>

clear

public void clear()

Specified by:

clear in interface java.util.Collection<E>

contains

public boolean contains(java.lang.Object o)

Specified by:

contains in interface java.util.Collection<E>

containsAll

public boolean containsAll(java.util.Collection<?> c)

Specified by:

containsAll in interface java.util.Collection<E>

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface java.util.Collection<E>

iterator

public java.util.Iterator<E> iterator()

Specified by:

iterator in interface java.lang.Iterable<E>

Specified by:

iterator in interface java.util.Collection<E>

remove

public boolean remove(java.lang.Object o)

Specified by:

remove in interface java.util.Collection<E>

removeAll

public boolean removeAll(java.util.Collection<?> c)

Specified by:

removeAll in interface java.util.Collection<E>

retainAll

public boolean retainAll(java.util.Collection<?> c)

Specified by:

retainAll in interface java.util.Collection<E>

size

public int size()

Specified by:

size in interface java.util.Collection<E>

toArray

public java.lang.Object[] toArray()

Specified by:

toArray in interface java.util.Collection<E>

toArray

public <T> T[] toArray(T[] a)

Specified by:

toArray in interface java.util.Collection<E>