step.plugins.event

Class InMemoryEventBrokerClient

java.lang.Object

step.plugins.event.InMemoryEventBrokerClient

All Implemented Interfaces:

Closeable, AutoCloseable, EventBrokerClient

public class InMemoryEventBrokerClient
extends Object
implements EventBrokerClient

Constructor Summary

Constructors

Constructor and Description
InMemoryEventBrokerClient(EventBroker eb)

Method Summary

Modifier and Type	Method and Description
Map<String,Boolean>	clear()
Map<String,Boolean>	clearGroup(String group)
Map<String,Object>	clearStats()
void	close()
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 class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

InMemoryEventBrokerClient

public InMemoryEventBrokerClient(EventBroker eb)

Method Detail

getEventBrokerIdMap

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

Specified by:

getEventBrokerIdMap in interface EventBrokerClient

getEventBrokerIdMap

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

Specified by:

getEventBrokerIdMap in interface EventBrokerClient

getEventBrokerGroupMap

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

Specified by:

getEventBrokerGroupMap in interface EventBrokerClient

getEventBrokerGroupMap

public Map<String,Set<step.plugins.events.Event>> getEventBrokerGroupMap(int skip,
                                                                         int limit)

Specified by:

getEventBrokerGroupMap in interface EventBrokerClient

putEvent

public step.plugins.events.Event putEvent(step.plugins.events.Event event)

Specified by:

putEvent in interface EventBrokerClient

peekEvent

public step.plugins.events.Event peekEvent(String id)

Specified by:

peekEvent in interface EventBrokerClient

peekEventByGroupAndName

public step.plugins.events.Event peekEventByGroupAndName(String group,
                                                         String name)

Specified by:

peekEventByGroupAndName in interface EventBrokerClient

consumeEvent

public step.plugins.events.Event consumeEvent(String id)

Specified by:

consumeEvent in interface EventBrokerClient

consumeEventByGroupAndName

public step.plugins.events.Event consumeEventByGroupAndName(String group,
                                                            String name)

Specified by:

consumeEventByGroupAndName in interface EventBrokerClient

clear

public Map<String,Boolean> clear()

Specified by:

clear in interface EventBrokerClient

clearGroup

public Map<String,Boolean> clearGroup(String group)

Specified by:

clearGroup in interface EventBrokerClient

getGlobalStats

public Map<String,Object> getGlobalStats()

Specified by:

getGlobalStats in interface EventBrokerClient

getGroupStats

public Map<String,Object> getGroupStats(String group)

Specified by:

getGroupStats in interface EventBrokerClient

clearStats

public Map<String,Object> clearStats()

Specified by:

clearStats in interface EventBrokerClient

getGroupSkipLimit

public Set<step.plugins.events.Event> getGroupSkipLimit(String group,
                                                        int skip,
                                                        int limit)

Specified by:

getGroupSkipLimit in interface EventBrokerClient

getFullGroup

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

Specified by:

getFullGroup in interface EventBrokerClient

getDistinctGroupNames

public Set<String> getDistinctGroupNames()

Specified by:

getDistinctGroupNames in interface EventBrokerClient

getGroupSize

public int getGroupSize(String group)

Specified by:

getGroupSize in interface EventBrokerClient

setCircuitBreakerThreshold

public Map<String,Object> setCircuitBreakerThreshold(long circuitBreakerThreshold)

Specified by:

setCircuitBreakerThreshold in interface EventBrokerClient

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException