step.plugins.events

Interface EventBrokerClient

All Superinterfaces:

AutoCloseable, Closeable

public interface EventBrokerClient
extends Closeable

Method Summary

Modifier and Type	Method and Description
Map<String,Boolean>	clear()
Map<String,Boolean>	clearGroup(String group)
Map<String,Object>	clearStats()
Event	consumeEvent(String id)
Event	consumeEventByGroupAndName(String group, String name)
Set<String>	getDistinctGroupNames()
Map<String,Set<Event>>	getEventBrokerGroupMap()
Map<String,Set<Event>>	getEventBrokerGroupMap(int skip, int limit)
Map<String,Event>	getEventBrokerIdMap()
Map<String,Event>	getEventBrokerIdMap(int skip, int limit)
Set<Event>	getFullGroup(String group)
Map<String,Object>	getGlobalStats()
int	getGroupSize(String group)
Set<Event>	getGroupSkipLimit(String group, int skip, int limit)
Map<String,Object>	getGroupStats(String group)
Event	peekEvent(String id)
Event	peekEventByGroupAndName(String group, String name)
Event	putEvent(Event event)
Map<String,Object>	setCircuitBreakerThreshold(long circuitBreakerThreshold)

Methods inherited from interface java.io.Closeable

close

Method Detail

getEventBrokerIdMap

Map<String,Event> getEventBrokerIdMap()

getEventBrokerIdMap

Map<String,Event> getEventBrokerIdMap(int skip,
                                      int limit)

getEventBrokerGroupMap

Map<String,Set<Event>> getEventBrokerGroupMap()

getEventBrokerGroupMap

Map<String,Set<Event>> getEventBrokerGroupMap(int skip,
                                              int limit)

putEvent

Event putEvent(Event event)

peekEvent

Event peekEvent(String id)

peekEventByGroupAndName

Event peekEventByGroupAndName(String group,
                              String name)
                       throws Exception

Throws:

Exception

consumeEvent

Event consumeEvent(String id)

consumeEventByGroupAndName

Event consumeEventByGroupAndName(String group,
                                 String name)
                          throws Exception

Throws:

Exception

clear

Map<String,Boolean> clear()

clearGroup

Map<String,Boolean> clearGroup(String group)

getGlobalStats

Map<String,Object> getGlobalStats()

getGroupStats

Map<String,Object> getGroupStats(String group)

clearStats

Map<String,Object> clearStats()

getGroupSkipLimit

Set<Event> getGroupSkipLimit(String group,
                             int skip,
                             int limit)
                      throws Exception

Throws:

Exception

getFullGroup

Set<Event> getFullGroup(String group)

getDistinctGroupNames

Set<String> getDistinctGroupNames()

getGroupSize

int getGroupSize(String group)

setCircuitBreakerThreshold

Map<String,Object> setCircuitBreakerThreshold(long circuitBreakerThreshold)