step.client.eventbroker

Class RemoteEventBrokerClient

java.lang.Object

step.client.AbstractRemoteClient

step.client.eventbroker.RemoteEventBrokerClient

All Implemented Interfaces:

Closeable, AutoCloseable, EventBrokerClient

public class RemoteEventBrokerClient
extends step.client.AbstractRemoteClient
implements EventBrokerClient

Field Summary

Fields

Modifier and Type	Field and Description
static String	servicePath

Fields inherited from class step.client.AbstractRemoteClient

client, cookies, credentials

Constructor Summary

Constructors

Constructor and Description
RemoteEventBrokerClient()
RemoteEventBrokerClient(step.client.credentials.ControllerCredentials credentials)

Method Summary

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)
String	getEventBrokerStatus() Deprecated.
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 step.client.AbstractRemoteClient

close, executeRequest, notImplemented, requestBuilder, requestBuilder

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.io.Closeable

close

Field Detail

servicePath

public static String servicePath

Constructor Detail

RemoteEventBrokerClient

public RemoteEventBrokerClient(step.client.credentials.ControllerCredentials credentials)

RemoteEventBrokerClient

public RemoteEventBrokerClient()

Method Detail

getEventBrokerStatus

@Deprecated
public String getEventBrokerStatus()

Deprecated.

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)
                                                  throws Exception

Specified by:

peekEventByGroupAndName in interface EventBrokerClient

Throws:

Exception

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)
                                                     throws Exception

Specified by:

consumeEventByGroupAndName in interface EventBrokerClient

Throws:

Exception

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)
                                                 throws Exception

Specified by:

getGroupSkipLimit in interface EventBrokerClient

Throws:

Exception

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