org.tools4j.nobark.queue

Interface ConflationQueue.Appender<K,V>

Type Parameters:

K - the type of the conflation key

V - the type of values in the queue

Enclosing interface:

ConflationQueue<K,V>

public static interface ConflationQueue.Appender<K,V>

Appender used by the producer to enqueue values.

Method Summary

Modifier and Type	Method and Description
V	enqueue(K conflationKey, V value) Enqueue the specified value using the given conflation key.

Method Detail

enqueue

V enqueue(K conflationKey,
          V value)

Enqueue the specified value using the given conflation key. If conflation occurred, the conflated value is returned. If no conflation occurs, null is returned, or for ExchangeConflationQueue implementations an exchange value from the poller may be returned if present.

Parameters:

conflationKey - the conflation key

value - the value to enqueue

Returns:

the conflated value if conflation occurred, or otherwise null or an exchange value from the poller for ExchangeConflationQueue implementations