net.sourceforge.hiveevents
Class ChannelImpl.AbstractConsumerInfo<T>

java.lang.Object
  net.sourceforge.hiveevents.ChannelImpl.AbstractConsumerInfo<T>

All Implemented Interfaces:

ChannelImpl.ConsumerInfo<T>

Enclosing class:

ChannelImpl<T>

protected abstract static class ChannelImpl.AbstractConsumerInfo<T>
extends java.lang.Object
implements ChannelImpl.ConsumerInfo<T>

Field Summary

protected Filter<T>

_filter

Constructor Summary

protected

ChannelImpl.AbstractConsumerInfo(int id, int priority, Filter<T> filter)

Method Summary

int	getId()
int	getPriority()
T[]	pull(java.lang.Class<T> clazz)
T[]	pull(java.lang.Class<T> clazz, long timeout)
void	push(T event)
void	unblock()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

_filter

protected final Filter<T> _filter

Constructor Detail

ChannelImpl.AbstractConsumerInfo

protected ChannelImpl.AbstractConsumerInfo(int id,
                                           int priority,
                                           Filter<T> filter)

Method Detail

unblock

public void unblock()

Specified by:

unblock in interface ChannelImpl.ConsumerInfo<T>

push

public void push(T event)

Specified by:

push in interface ChannelImpl.ConsumerInfo<T>

pull

public T[] pull(java.lang.Class<T> clazz)

Specified by:

pull in interface ChannelImpl.ConsumerInfo<T>

pull

public T[] pull(java.lang.Class<T> clazz,
                long timeout)

Specified by:

pull in interface ChannelImpl.ConsumerInfo<T>

getPriority

public int getPriority()

Specified by:

getPriority in interface ChannelImpl.ConsumerInfo<T>

getId

public int getId()

Specified by:

getId in interface ChannelImpl.ConsumerInfo<T>