public interface EventManager extends EventListenersResolver, Transactable
Modifier and Type | Method and Description |
---|---|
void |
clearState()
Clears the current manager's state.
|
void |
engageDataChannel()
Restrict manager to use data channel until
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.
|
void |
onGenericEvent(String eventFqn,
byte[] data,
String source)
Retrieves an event.
|
List<org.kaaproject.kaa.common.endpoint.gen.Event> |
peekPendingEvents()
Peek but not clear list of pending events and removes them from EventManager.
|
List<org.kaaproject.kaa.common.endpoint.gen.Event> |
pollPendingEvents()
Retrieves and clears list of pending events and removes them from EventManager.
|
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.
|
findEventListeners
beginTransaction, commit, rollback
void registerEventFamily(EventFamily eventFamily)
eventFamily
- EventFamily instanceEventFamily
void produceEvent(String eventFqn, byte[] data, String target)
eventFqn
- Fully qualified name of the Eventdata
- Event datatarget
- Event target, null for event broadcasting.void produceEvent(String eventFqn, byte[] data, String target, TransactionId trxId)
eventFqn
- Fully qualified name of the Eventdata
- Event datatarget
- Event target, null for event broadcasting.trxId
- Transaction Id of eventvoid onGenericEvent(String eventFqn, byte[] data, String source)
eventFqn
- Fully qualified name of the Eventdata
- Event datasource
- Event sourcevoid eventListenersResponseReceived(List<org.kaaproject.kaa.common.endpoint.gen.EventListenersResponse> response)
response
- List of responses.EventListenersResponse
void fillEventListenersSyncRequest(org.kaaproject.kaa.common.endpoint.gen.EventSyncRequest request)
request
- the Event sync request.EventSyncRequest
List<org.kaaproject.kaa.common.endpoint.gen.Event> pollPendingEvents()
Event
List<org.kaaproject.kaa.common.endpoint.gen.Event> peekPendingEvents()
Event
void clearState()
void engageDataChannel()
releaseDataChannel()
calledboolean releaseDataChannel()
Copyright © 2015. All rights reserved.