Package step.client.eventbroker
Interface EventBrokerClient
-
- All Superinterfaces:
AutoCloseable
,Closeable
- All Known Implementing Classes:
InMemoryEventBrokerClient
,RemoteEventBrokerClient
public interface EventBrokerClient extends Closeable
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Map<String,Boolean>
clear()
Map<String,Boolean>
clearGroup(String group)
Map<String,Object>
clearStats()
step.plugins.events.Event
consumeEvent(String id)
step.plugins.events.Event
consumeEventByGroupAndName(String group, String name)
Set<String>
getDistinctGroupNames()
Map<String,Set<step.plugins.events.Event>>
getEventBrokerGroupMap()
Map<String,Set<step.plugins.events.Event>>
getEventBrokerGroupMap(int skip, int limit)
Map<String,step.plugins.events.Event>
getEventBrokerIdMap()
Map<String,step.plugins.events.Event>
getEventBrokerIdMap(int skip, int limit)
Set<step.plugins.events.Event>
getFullGroup(String group)
Map<String,Object>
getGlobalStats()
int
getGroupSize(String group)
Set<step.plugins.events.Event>
getGroupSkipLimit(String group, int skip, int limit)
Map<String,Object>
getGroupStats(String group)
step.plugins.events.Event
peekEvent(String id)
step.plugins.events.Event
peekEventByGroupAndName(String group, String name)
step.plugins.events.Event
putEvent(step.plugins.events.Event event)
Map<String,Object>
setCircuitBreakerThreshold(long circuitBreakerThreshold)
-
-
-
Method Detail
-
getEventBrokerIdMap
Map<String,step.plugins.events.Event> getEventBrokerIdMap(int skip, int limit)
-
getEventBrokerGroupMap
Map<String,Set<step.plugins.events.Event>> getEventBrokerGroupMap(int skip, int limit)
-
putEvent
step.plugins.events.Event putEvent(step.plugins.events.Event event)
-
peekEvent
step.plugins.events.Event peekEvent(String id)
-
peekEventByGroupAndName
step.plugins.events.Event peekEventByGroupAndName(String group, String name) throws Exception
- Throws:
Exception
-
consumeEvent
step.plugins.events.Event consumeEvent(String id)
-
consumeEventByGroupAndName
step.plugins.events.Event consumeEventByGroupAndName(String group, String name) throws Exception
- Throws:
Exception
-
getGroupSkipLimit
Set<step.plugins.events.Event> getGroupSkipLimit(String group, int skip, int limit) throws Exception
- Throws:
Exception
-
getGroupSize
int getGroupSize(String group)
-
-