Package step.plugins.event

Class EventBrokerImpl

java.lang.Object

step.plugins.event.EventBrokerImpl

All Implemented Interfaces:

EventBroker

public class EventBrokerImpl
extends Object
implements EventBroker

Field Summary

Fields

Modifier and Type	Field	Description
static String	DEFAULT_GROUP_VALUE
static String	DEFAULT_NAME_VALUE

Constructor Summary

Constructors

Constructor	Description
EventBrokerImpl()
EventBrokerImpl(long circuitBreakerThreshold, boolean advancedStatsOn, boolean hashedGroupNameOn)

Method Summary

Modifier and Type	Method	Description
void	clear()
void	clearGroup(String group)
void	clearStats()
step.plugins.events.Event	findOldestEvent()
step.plugins.events.Event	findOldestEventForGroup(String group)
step.plugins.events.Event	findYoungestEvent()
step.plugins.events.Event	findYoungestEventForGroup(String group)
step.plugins.events.Event	get(String id)
step.plugins.events.Event	get(String group, String name)	Now using a sync-free optimistic version of the group lookup as an alternative to syncGroupOn
boolean	getAdvancedStatsOn()
long	getCircuitBreakerThreshold()
long	getCumulatedAttemptedGets()
long	getCumulatedAttemptedGroupGets()
long	getCumulatedGets()
long	getCumulatedPeeks()
long	getCumulatedPuts()
Set<String>	getDistinctGroupNames()
Map<String,Set<step.plugins.events.Event>>	getFullGroupBasedEventMap()
Map<String,Set<step.plugins.events.Event>>	getGroupBasedEventMap(int skip, int limit)
Set<step.plugins.events.Event>	getGroupEvents(String group)	Group access
Set<step.plugins.events.Event>	getGroupEvents(String group, int skip, int limit)
Map<String,Object>	getGroupStats(String group)
Map<String,step.plugins.events.Event>	getIdBasedEventMap()
Map<String,step.plugins.events.Event>	getIdBasedEventMap(int skip, int limit)
int	getSize()
int	getSizeForGroup(String group)
int	getSizeWaterMark()	Not fully reliable due to the nature of CHM
Map<String,Object>	getStats()
boolean	isUniqueGroupNameOn()
step.plugins.events.Event	peek(String id)
step.plugins.events.Event	peek(String group, String name)	Group primitives, adapted via lookup() to Id primitives
step.plugins.events.Event	put(step.plugins.events.Event event)	Main primitives, based on id
void	setAdvancedStatsOn(boolean statsOn)	Stats
void	setCircuitBreakerThreshold(long circuitBreakerThreshold)
void	setUniqueGroupNameOn(boolean hashedGroupNameOn)
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_GROUP_VALUE

public static String DEFAULT_GROUP_VALUE

DEFAULT_NAME_VALUE

public static String DEFAULT_NAME_VALUE

Constructor Detail

EventBrokerImpl

public EventBrokerImpl()

EventBrokerImpl

public EventBrokerImpl(long circuitBreakerThreshold,
                       boolean advancedStatsOn,
                       boolean hashedGroupNameOn)

Method Detail

clear

public void clear()

Specified by:

clear in interface EventBroker

toString

public String toString()

Overrides:

toString in class Object

getIdBasedEventMap

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

Specified by:

getIdBasedEventMap in interface EventBroker

getIdBasedEventMap

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

Specified by:

getIdBasedEventMap in interface EventBroker

getCircuitBreakerThreshold

public long getCircuitBreakerThreshold()

Specified by:

getCircuitBreakerThreshold in interface EventBroker

setCircuitBreakerThreshold

public void setCircuitBreakerThreshold(long circuitBreakerThreshold)

Specified by:

setCircuitBreakerThreshold in interface EventBroker

isUniqueGroupNameOn

public boolean isUniqueGroupNameOn()

Specified by:

isUniqueGroupNameOn in interface EventBroker

setUniqueGroupNameOn

public void setUniqueGroupNameOn(boolean hashedGroupNameOn)

Specified by:

setUniqueGroupNameOn in interface EventBroker

getSize

public int getSize()

Specified by:

getSize in interface EventBroker

put

public step.plugins.events.Event put(step.plugins.events.Event event)
                              throws Exception

Main primitives, based on id

Specified by:

put in interface EventBroker

Throws:

Exception

get

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

Specified by:

get in interface EventBroker

peek

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

Specified by:

peek in interface EventBroker

peek

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

Group primitives, adapted via lookup() to Id primitives

Specified by:

peek in interface EventBroker

clearGroup

public void clearGroup(String group)

Specified by:

clearGroup in interface EventBroker

get

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

Now using a sync-free optimistic version of the group lookup as an alternative to syncGroupOn

Specified by:

get in interface EventBroker

setAdvancedStatsOn

public void setAdvancedStatsOn(boolean statsOn)

Stats

Specified by:

setAdvancedStatsOn in interface EventBroker

getAdvancedStatsOn

public boolean getAdvancedStatsOn()

Specified by:

getAdvancedStatsOn in interface EventBroker

getCumulatedPuts

public long getCumulatedPuts()

Specified by:

getCumulatedPuts in interface EventBroker

getCumulatedGets

public long getCumulatedGets()

Specified by:

getCumulatedGets in interface EventBroker

getCumulatedAttemptedGets

public long getCumulatedAttemptedGets()

Specified by:

getCumulatedAttemptedGets in interface EventBroker

getCumulatedAttemptedGroupGets

public long getCumulatedAttemptedGroupGets()

Specified by:

getCumulatedAttemptedGroupGets in interface EventBroker

getCumulatedPeeks

public long getCumulatedPeeks()

Specified by:

getCumulatedPeeks in interface EventBroker

getStats

public Map<String,Object> getStats()

Specified by:

getStats in interface EventBroker

getGroupStats

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

Specified by:

getGroupStats in interface EventBroker

Parameters:

group -

Returns:

getSizeWaterMark

public int getSizeWaterMark()

Not fully reliable due to the nature of CHM

Specified by:

getSizeWaterMark in interface EventBroker

findOldestEvent

public step.plugins.events.Event findOldestEvent()

Specified by:

findOldestEvent in interface EventBroker

findYoungestEvent

public step.plugins.events.Event findYoungestEvent()

Specified by:

findYoungestEvent in interface EventBroker

getSizeForGroup

public int getSizeForGroup(String group)

Specified by:

getSizeForGroup in interface EventBroker

findYoungestEventForGroup

public step.plugins.events.Event findYoungestEventForGroup(String group)

Specified by:

findYoungestEventForGroup in interface EventBroker

findOldestEventForGroup

public step.plugins.events.Event findOldestEventForGroup(String group)

Specified by:

findOldestEventForGroup in interface EventBroker

clearStats

public void clearStats()

Specified by:

clearStats in interface EventBroker

getGroupEvents

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

Group access

Specified by:

getGroupEvents in interface EventBroker

getGroupEvents

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

Specified by:

getGroupEvents in interface EventBroker

getFullGroupBasedEventMap

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

Specified by:

getFullGroupBasedEventMap in interface EventBroker

getGroupBasedEventMap

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

Specified by:

getGroupBasedEventMap in interface EventBroker

getDistinctGroupNames

public Set<String> getDistinctGroupNames()

Specified by:

getDistinctGroupNames in interface EventBroker