Package step.plugins.events

Class EventBrokerServices

java.lang.Object

step.core.deployment.AbstractServices

step.plugins.events.EventBrokerServices

@Singleton
@Path("/eventbroker")
public class EventBrokerServices
extends step.core.deployment.AbstractServices

Field Summary

Fields inherited from class step.core.deployment.AbstractServices

configuration, controller

Constructor Summary

Constructors

Constructor	Description
EventBrokerServices()

Method Summary

Modifier and Type	Method	Description
Map<String,Object>	clear()
Map<String,Object>	clearGroup(String group)
Map<String,Object>	clearStats()
step.plugins.events.Event	consumeEvent(String id)
step.plugins.events.Event	consumeEventByGroupAndName(String group, String name)
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)
Set<String>	getGroups()
int	getGroupSize(String group)
Set<step.plugins.events.Event>	getGroupSkipLimit(String group, int skip, int limit)
Map<String,Object>	getGroupStats(String group)
Map<String,Object>	getStats()
void	init()
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)	Conf Services

Methods inherited from class step.core.deployment.AbstractServices

getContext, getExecutionRunnable, getObjectDrainer, getObjectEnricher, getScheduler, getSession, setSession

Methods inherited from class java.lang.Object

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

Constructor Detail

EventBrokerServices

public EventBrokerServices()

Method Detail

init

@PostConstruct
public void init()
          throws Exception

Overrides:

init in class step.core.deployment.AbstractServices

Throws:

Exception

getEventBrokerIdMap

@GET
@Path("/events/asIdMap")
@Produces("application/json")
public Map<String,step.plugins.events.Event> getEventBrokerIdMap()

getEventBrokerGroupMap

@GET
@Path("/events/asGroupMap")
@Produces("application/json")
public Map<String,Set<step.plugins.events.Event>> getEventBrokerGroupMap()

getEventBrokerIdMap

@GET
@Path("/events/asIdMap/skip/{skip}/limit/{limit}")
@Produces("application/json")
public Map<String,step.plugins.events.Event> getEventBrokerIdMap(@PathParam("skip")
                                                                       int skip,
                                                                       @PathParam("limit")
                                                                       int limit)

getEventBrokerGroupMap

@GET
@Path("/events/asGroupMap/skip/{skip}/limit/{limit}")
@Produces("application/json")
public Map<String,Set<step.plugins.events.Event>> getEventBrokerGroupMap(@PathParam("skip")
                                                                               int skip,
                                                                               @PathParam("limit")
                                                                               int limit)

putEvent

@POST
@Path("/event")
@Consumes("application/json")
@Produces("application/json")
public step.plugins.events.Event putEvent(step.plugins.events.Event event)
                                   throws Exception

Throws:

Exception

peekEvent

@GET
@Path("/event/{id}")
@Produces("application/json")
@Consumes("application/json")
public step.plugins.events.Event peekEvent(@PathParam("id")
                                           String id)

peekEventByGroupAndName

@GET
@Path("/event/group/{group}/name/{name}")
@Produces("application/json")
@Consumes("application/json")
public step.plugins.events.Event peekEventByGroupAndName(@PathParam("group")
                                                         String group,
                                                         @PathParam("name")
                                                         String name)

getGroupSkipLimit

@GET
@Path("/events/group/{group}/skip/{skip}/limit/{limit}")
@Produces("application/json")
@Consumes("application/json")
public Set<step.plugins.events.Event> getGroupSkipLimit(@PathParam("group")
                                                        String group,
                                                        @PathParam("skip")
                                                        int skip,
                                                        @PathParam("limit")
                                                        int limit)

getFullGroup

@GET
@Path("/events/group/{group}")
@Produces("application/json")
@Consumes("application/json")
public Set<step.plugins.events.Event> getFullGroup(@PathParam("group")
                                                   String group)

getGroups

@GET
@Path("/events/groups")
@Produces("application/json")
@Consumes("application/json")
public Set<String> getGroups()

getGroupSize

@GET
@Path("/events/group/{group}/size")
@Produces("application/json")
@Consumes("application/json")
public int getGroupSize(@PathParam("group")
                        String group)

consumeEvent

@DELETE
@Path("/event/{id}")
@Produces("application/json")
@Consumes("application/json")
public step.plugins.events.Event consumeEvent(@PathParam("id")
                                              String id)

consumeEventByGroupAndName

@DELETE
@Path("/event/group/{group}/name/{name}")
@Produces("application/json")
@Consumes("application/json")
public step.plugins.events.Event consumeEventByGroupAndName(@PathParam("group")
                                                            String group,
                                                            @PathParam("name")
                                                            String name)

clear

@DELETE
@Path("/events")
@Produces("application/json")
public Map<String,Object> clear()

clearGroup

@DELETE
@Path("/events/group/{group}")
@Produces("application/json")
@Consumes("application/json")
public Map<String,Object> clearGroup(@PathParam("group")
                                           String group)

getStats

@GET
@Path("/events/monitoring/global")
@Produces("application/json")
@Consumes("application/json")
public Map<String,Object> getStats()

getGroupStats

@GET
@Path("/events/monitoring/group/{group}")
@Produces("application/json")
@Consumes("application/json")
public Map<String,Object> getGroupStats(@PathParam("group")
                                              String group)
                                       throws Exception

Throws:

Exception

clearStats

@GET
@Path("/events/monitoring/clear")
@Produces("application/json")
@Consumes("application/json")
public Map<String,Object> clearStats()

setCircuitBreakerThreshold

@GET
@Path("/events/config/circuitBreakerThreshold/{circuitBreakerThreshold}")
@Produces("application/json")
@Consumes("application/json")
public Map<String,Object> setCircuitBreakerThreshold(@PathParam("circuitBreakerThreshold")
                                                           long circuitBreakerThreshold)

Conf Services