public interface EventBrokerClient extends Closeable
Modifier and Type | Method and 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) |
Map<String,Set<step.plugins.events.Event>> getEventBrokerGroupMap(int skip, int limit)
step.plugins.events.Event putEvent(step.plugins.events.Event event)
step.plugins.events.Event peekEvent(String id)
step.plugins.events.Event peekEventByGroupAndName(String group, String name) throws Exception
Exception
step.plugins.events.Event consumeEvent(String id)
step.plugins.events.Event consumeEventByGroupAndName(String group, String name) throws Exception
Exception
Set<step.plugins.events.Event> getGroupSkipLimit(String group, int skip, int limit) throws Exception
Exception
int getGroupSize(String group)
Copyright © 2020. All rights reserved.