Package io.streamthoughts.azkarra.api.events

Class EventStreamSupport

java.lang.Object

io.streamthoughts.azkarra.api.events.EventStreamSupport

All Implemented Interfaces:

EventStreamProvider

Direct Known Subclasses:

ServerSentEventExample.WordCountPublisherTopology

public class EventStreamSupport
extends Object
implements EventStreamProvider

Base class for EventStreamProvider. This class provides convenient methods to register EventStream and to send records.

Since:

0.8.0

Constructor Summary

Constructors

Constructor	Description
EventStreamSupport()

Method Summary

Modifier and Type	Method	Description
<K,V> void	addEventStream(EventStream<K,V> eventStream)
protected void	addEventStreamsWithDefaults(String... types)
List<EventStream>	eventStreams()	Returns the list of EventStream
<K,V> void	send(String type, KV<K,V> kv)	Sends a null-key value record into into the given stream.
<K,V> void	send(String type, K key, V value)	Sends a key-value record into the given stream.
<K,V> void	send(String type, K key, V value, long timestamp)	Sends a timestamped key-value record into the given stream.
<K,V> void	send(String type, V value)	Sends a key-value record into this queue.
protected void	setDefaultEventQueueLimitHandler(LimitHandler limitHandler)	Sets the default LimitHandler that will be used for creating EventStream.
protected void	setDefaultEventQueueSize(int queueSize)	Sets the default event queue size that will be used for creating EventStream.

Methods inherited from class java.lang.Object

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

Constructor Detail

EventStreamSupport

public EventStreamSupport()

Method Detail

eventStreams

public List<EventStream> eventStreams()

Returns the list of EventStream

Specified by:

eventStreams in interface EventStreamProvider

Returns:

a list of EventStream. Must not return null.

addEventStream

public <K,V> void addEventStream(EventStream<K,V> eventStream)

addEventStreamsWithDefaults

protected void addEventStreamsWithDefaults(String... types)

setDefaultEventQueueLimitHandler

protected void setDefaultEventQueueLimitHandler(LimitHandler limitHandler)

Sets the default LimitHandler that will be used for creating EventStream.

Parameters:

limitHandler - the LimitHandler.

setDefaultEventQueueSize

protected void setDefaultEventQueueSize(int queueSize)

Sets the default event queue size that will be used for creating EventStream.

Parameters:

queueSize - the queue size.

send

public <K,V> void send(String type,
                             V value)

Sends a key-value record into this queue.

Parameters:

type - the type of the event-stream.

value - the record value.

send

public <K,V> void send(String type,
                             K key,
                             V value)

Sends a key-value record into the given stream.

Parameters:

type - the type of the event-stream.

key - the record key.

value - the record value.

send

public <K,V> void send(String type,
                             K key,
                             V value,
                             long timestamp)

Sends a timestamped key-value record into the given stream.

Parameters:

type - the type of the event-stream.

key - the record key.

value - the record value.

send

public <K,V> void send(String type,
                             KV<K,V> kv)

Sends a null-key value record into into the given stream.

Parameters:

type - the type of the event-stream.

kv - the KV record.