Package com.linkedin.venice.listener

Class ListenerManager<T>

java.lang.Object

com.linkedin.venice.listener.ListenerManager<T>

Type Parameters:

T - T should be a type of listener

public class ListenerManager<T>
extends Object

This class provides the unified way to manager venice listener.

Constructor Summary

Constructors

Constructor	Description
ListenerManager()

Method Summary

Modifier and Type	Method	Description
void	subscribe(String key, T listener)
void	trigger(String key, Consumer<T> handler)	Trigger notification and execute the given handler.
void	unsubscribe(String key, T listener)

Methods inherited from class java.lang.Object

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

Constructor Details

ListenerManager

public ListenerManager()

Method Details

subscribe

public void subscribe(String key,
 T listener)

unsubscribe

public void unsubscribe(String key,
 T listener)

trigger

public void trigger(String key,
 Consumer<T> handler)

Trigger notification and execute the given handler.

Parameters:

key -

handler - The function really handle the event. It accepts listener and call the corresponding handle method of this listener.