Package com.onec.kafka

Class InboundEventRouter

java.lang.Object

com.onec.kafka.InboundEventRouter

public class InboundEventRouter
extends Object

Routes a decoded InboundEvent to every EventHandler that supports its type.

Constructor Summary

Constructors

Constructor	Description
InboundEventRouter(List<EventHandler> handlers)

Method Summary

Modifier and Type	Method	Description
int	dispatch(InboundEvent event)

Methods inherited from class java.lang.Object

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

Constructor Details

InboundEventRouter

public InboundEventRouter(List<EventHandler> handlers)

Method Details

dispatch

public int dispatch(InboundEvent event)

Returns:

the number of handlers that processed the event.