com.alanbuttars.commons.config.eventbus

Class EventBusAsyncImpl

java.lang.Object

com.alanbuttars.commons.config.eventbus.EventBusAsyncImpl

All Implemented Interfaces:

EventBus

public class EventBusAsyncImpl
extends Object
implements EventBus

Implements the EventBus interface by utilizing Google Guava's asynchronous AsyncEventBus.

Author:

Alan Buttars

Constructor Summary

Constructors

Constructor and Description
EventBusAsyncImpl(Executor executor) See AsyncEventBus.AsyncEventBus(Executor).
EventBusAsyncImpl(Executor executor, String eventBusId) See AsyncEventBus.AsyncEventBus(String, Executor).
EventBusAsyncImpl(Executor executor, com.google.common.eventbus.SubscriberExceptionHandler exceptionHandler) See AsyncEventBus.AsyncEventBus(Executor, SubscriberExceptionHandler).

Method Summary

Methods

Modifier and Type	Method and Description
protected com.google.common.eventbus.AsyncEventBus	getEventBus()
<E extends Event> void	publish(E event) Publishes an event to the event bus.
void	subscribe(Object object) Subscribes to events published by this event bus.
void	unsubscribe(Object object) Unsubscribes to events published by this event bus.

Methods inherited from class java.lang.Object

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

Constructor Detail

EventBusAsyncImpl

public EventBusAsyncImpl(Executor executor)

See AsyncEventBus.AsyncEventBus(Executor).

EventBusAsyncImpl

public EventBusAsyncImpl(Executor executor,
                 String eventBusId)

See AsyncEventBus.AsyncEventBus(String, Executor).

EventBusAsyncImpl

public EventBusAsyncImpl(Executor executor,
                 com.google.common.eventbus.SubscriberExceptionHandler exceptionHandler)

See AsyncEventBus.AsyncEventBus(Executor, SubscriberExceptionHandler).

Method Detail

getEventBus

protected com.google.common.eventbus.AsyncEventBus getEventBus()

publish

public <E extends Event> void publish(E event)

Publishes an event to the event bus.

Specified by:

publish in interface EventBus

Parameters:

event - Non-null event

subscribe

public void subscribe(Object object)

Subscribes to events published by this event bus.

Specified by:

subscribe in interface EventBus

Parameters:

object - Non-null object

unsubscribe

public void unsubscribe(Object object)

Unsubscribes to events published by this event bus. If the object is already unsubscribed, this method does nothing.

Specified by:

unsubscribe in interface EventBus