public class DefaultEventManager extends Object implements EventManager
EventManager
implementation.Constructor and Description |
---|
DefaultEventManager(KaaClientState state,
EventTransport transport) |
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.
|
String |
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
|
public DefaultEventManager(KaaClientState state, EventTransport transport)
public void fillEventListenersSyncRequest(org.kaaproject.kaa.common.endpoint.gen.EventSyncRequest request)
EventManager
fillEventListenersSyncRequest
in interface EventManager
request
- the Event sync request.EventSyncRequest
public void clearState()
EventManager
clearState
in interface EventManager
public void produceEvent(String eventFqn, byte[] data, String target) throws IOException
EventManager
produceEvent
in interface EventManager
eventFqn
- Fully qualified name of the Eventdata
- Event datatarget
- Event target, null for event broadcasting.IOException
public void produceEvent(String eventFqn, byte[] data, String target, TransactionId trxId) throws IOException
EventManager
produceEvent
in interface EventManager
eventFqn
- Fully qualified name of the Eventdata
- Event datatarget
- Event target, null for event broadcasting.trxId
- Transaction Id of eventIOException
public void registerEventFamily(EventFamily eventFamily)
EventManager
registerEventFamily
in interface EventManager
eventFamily
- EventFamily instanceEventFamily
public void onGenericEvent(String eventFqn, byte[] data, String source)
EventManager
onGenericEvent
in interface EventManager
eventFqn
- Fully qualified name of the Eventdata
- Event datasource
- Event sourcepublic String findEventListeners(List<String> eventClassFQNs, FetchEventListeners listener)
EventListenersResolver
findEventListeners
in interface EventListenersResolver
eventClassFQNs
- List of event class FQNs which have to be supported by endpoint.listener
- Result listener FetchEventListeners
}public void eventListenersResponseReceived(List<org.kaaproject.kaa.common.endpoint.gen.EventListenersResponse> response)
EventManager
eventListenersResponseReceived
in interface EventManager
response
- List of responses.EventListenersResponse
public List<org.kaaproject.kaa.common.endpoint.gen.Event> getPendingEvents()
EventManager
getPendingEvents
in interface EventManager
Event
public TransactionId beginTransaction()
Transactable
beginTransaction
in interface Transactable
public void commit(TransactionId trxId)
Transactable
commit
in interface Transactable
trxId
- The unique identifier of the transaction which should be submitted.public void rollback(TransactionId trxId)
Transactable
rollback
in interface Transactable
trxId
- The unique identifier of the transaction which should be reverted.public void engageDataChannel()
EventManager
EventManager.releaseDataChannel()
calledengageDataChannel
in interface EventManager
public boolean releaseDataChannel()
EventManager
releaseDataChannel
in interface EventManager
Copyright © 2014. All rights reserved.