Package step.client.eventbroker

Interface EventBrokerClient

All Superinterfaces:

AutoCloseable, Closeable

All Known Implementing Classes:

InMemoryEventBrokerClient, RemoteEventBrokerClient

public interface EventBrokerClient
extends Closeable

Method Summary

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)

Methods inherited from interface java.io.Closeable

close

Method Detail

getEventBrokerIdMap

Map<String,step.plugins.events.Event> getEventBrokerIdMap()

getEventBrokerIdMap

Map<String,step.plugins.events.Event> getEventBrokerIdMap(int skip,
                                                                int limit)

getEventBrokerGroupMap

Map<String,Set<step.plugins.events.Event>> getEventBrokerGroupMap()

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

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<step.plugins.events.Event> getGroupSkipLimit(String group,
                                                 int skip,
                                                 int limit)
                                          throws Exception

Throws:

Exception

getFullGroup

Set<step.plugins.events.Event> getFullGroup(String group)

getDistinctGroupNames

Set<String> getDistinctGroupNames()

getGroupSize

int getGroupSize(String group)

setCircuitBreakerThreshold

Map<String,Object> setCircuitBreakerThreshold(long circuitBreakerThreshold)