org.kaaproject.kaa.client.event

Class DefaultEventManager

java.lang.Object

org.kaaproject.kaa.client.event.DefaultEventManager

All Implemented Interfaces:

EventListenersResolver, EventManager, Transactable

public class DefaultEventManager
extends Object
implements EventManager

Default EventManager implementation.

Author:

Taras Lemkin

Constructor Summary

Constructors

Constructor and Description
DefaultEventManager(KaaClientState state, EventTransport transport)

Method Summary

Methods

Modifier and Type	Method and Description
TransactionId	beginTransaction() Create new transaction entry.
void	clearState() Clears the current manager's state.
void	commit(TransactionId trxId) Submit the transaction
void	engageDataChannel() Restrict manager to use data channel until EventManager.releaseDataChannel() called
void	eventListenersResponseReceived(List<org.kaaproject.kaa.common.endpoint.gen.EventListenersResponse> response) Called when SyncResponse contains resolved list of endpoints which support FQNs given in a request before.
void	fillEventListenersSyncRequest(org.kaaproject.kaa.common.endpoint.gen.EventSyncRequest request) Adds new event listener requests to the given Sync request.
int	findEventListeners(List<String> eventClassFQNs, FetchEventListeners listener) Submits an event listeners resolution request
List<org.kaaproject.kaa.common.endpoint.gen.Event>	getPendingEvents() Retrieves list of pending events and removes them from EventManager.
void	onGenericEvent(String eventFqn, byte[] data, String source) Retrieves an event.
void	produceEvent(String eventFqn, byte[] data, String target) Creates an Event and passes it to OPS
void	produceEvent(String eventFqn, byte[] data, String target, TransactionId trxId) Creates an Event and passes it to OPS
void	registerEventFamily(EventFamily eventFamily) Add event family object which can handle specified event.
boolean	releaseDataChannel() Allow manager to use data channel.
void	rollback(TransactionId trxId) Revert the transaction

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultEventManager

public DefaultEventManager(KaaClientState state,
                   EventTransport transport)

Method Detail

fillEventListenersSyncRequest

public void fillEventListenersSyncRequest(org.kaaproject.kaa.common.endpoint.gen.EventSyncRequest request)

Description copied from interface: EventManager

Adds new event listener requests to the given Sync request.

Specified by:

fillEventListenersSyncRequest in interface EventManager

Parameters:

request - the Event sync request.

See Also:

EventSyncRequest

clearState

public void clearState()

Description copied from interface: EventManager

Clears the current manager's state.

Specified by:

clearState in interface EventManager

produceEvent

public void produceEvent(String eventFqn,
                byte[] data,
                String target)
                  throws IOException

Description copied from interface: EventManager

Creates an Event and passes it to OPS

Specified by:

produceEvent in interface EventManager

Parameters:

eventFqn - Fully qualified name of the Event

data - Event data

target - Event target, null for event broadcasting.

Throws:

IOException

produceEvent

public void produceEvent(String eventFqn,
                byte[] data,
                String target,
                TransactionId trxId)
                  throws IOException

Description copied from interface: EventManager

Creates an Event and passes it to OPS

Specified by:

produceEvent in interface EventManager

Parameters:

eventFqn - Fully qualified name of the Event

data - Event data

target - Event target, null for event broadcasting.

trxId - Transaction Id of event

Throws:

IOException

registerEventFamily

public void registerEventFamily(EventFamily eventFamily)

Description copied from interface: EventManager

Add event family object which can handle specified event.

Specified by:

registerEventFamily in interface EventManager

Parameters:

eventFamily - EventFamily instance

See Also:

EventFamily

onGenericEvent

public void onGenericEvent(String eventFqn,
                  byte[] data,
                  String source)

Description copied from interface: EventManager

Retrieves an event.

Specified by:

onGenericEvent in interface EventManager

Parameters:

eventFqn - Fully qualified name of the Event

data - Event data

source - Event source

findEventListeners

public int findEventListeners(List<String> eventClassFQNs,
                     FetchEventListeners listener)

Description copied from interface: EventListenersResolver

Submits an event listeners resolution request

Specified by:

findEventListeners in interface EventListenersResolver

Parameters:

eventClassFQNs - List of event class FQNs which have to be supported by endpoint.

listener - Result listener FetchEventListeners}

Returns:

Request ID of submitted request

eventListenersResponseReceived

public void eventListenersResponseReceived(List<org.kaaproject.kaa.common.endpoint.gen.EventListenersResponse> response)

Description copied from interface: EventManager

Called when SyncResponse contains resolved list of endpoints which support FQNs given in a request before.

Specified by:

eventListenersResponseReceived in interface EventManager

Parameters:

response - List of responses.

See Also:

EventListenersResponse

getPendingEvents

public List<org.kaaproject.kaa.common.endpoint.gen.Event> getPendingEvents()

Description copied from interface: EventManager

Retrieves list of pending events and removes them from EventManager.

Specified by:

getPendingEvents in interface EventManager

Returns:

List of Event objects

See Also:

Event

beginTransaction

public TransactionId beginTransaction()

Description copied from interface: Transactable

Create new transaction entry.

Specified by:

beginTransaction in interface Transactable

Returns:

TransactionId Unique id of created transaction.

commit

public void commit(TransactionId trxId)

Description copied from interface: Transactable

Submit the transaction

Specified by:

commit in interface Transactable

Parameters:

trxId - The unique identifier of the transaction which should be submitted.

rollback

public void rollback(TransactionId trxId)

Description copied from interface: Transactable

Revert the transaction

Specified by:

rollback in interface Transactable

Parameters:

trxId - The unique identifier of the transaction which should be reverted.

engageDataChannel

public void engageDataChannel()

Description copied from interface: EventManager

Restrict manager to use data channel until EventManager.releaseDataChannel() called

Specified by:

engageDataChannel in interface EventManager

releaseDataChannel

public boolean releaseDataChannel()

Description copied from interface: EventManager

Allow manager to use data channel.

Specified by:

releaseDataChannel in interface EventManager

Returns:

true if there is data to be sent via data channel
false otherwise