@Singleton
@Path(value="/eventbroker")
public class EventBrokerServices
extends step.core.deployment.AbstractServices
Constructor and Description |
---|
EventBrokerServices() |
Modifier and Type | Method and 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
|
@PostConstruct public void init() throws Exception
init
in class step.core.deployment.AbstractServices
Exception
@GET @Path(value="/events/asIdMap") @Produces(value="application/json") public Map<String,step.plugins.events.Event> getEventBrokerIdMap()
@GET @Path(value="/events/asGroupMap") @Produces(value="application/json") public Map<String,Set<step.plugins.events.Event>> getEventBrokerGroupMap()
@GET @Path(value="/events/asIdMap/skip/{skip}/limit/{limit}") @Produces(value="application/json") public Map<String,step.plugins.events.Event> getEventBrokerIdMap(@PathParam(value="skip") int skip, @PathParam(value="limit") int limit)
@GET @Path(value="/events/asGroupMap/skip/{skip}/limit/{limit}") @Produces(value="application/json") public Map<String,Set<step.plugins.events.Event>> getEventBrokerGroupMap(@PathParam(value="skip") int skip, @PathParam(value="limit") int limit)
@POST @Path(value="/event") @Consumes(value="application/json") @Produces(value="application/json") public step.plugins.events.Event putEvent(step.plugins.events.Event event) throws Exception
Exception
@GET @Path(value="/event/{id}") @Produces(value="application/json") @Consumes(value="application/json") public step.plugins.events.Event peekEvent(@PathParam(value="id") String id)
@GET @Path(value="/event/group/{group}/name/{name}") @Produces(value="application/json") @Consumes(value="application/json") public step.plugins.events.Event peekEventByGroupAndName(@PathParam(value="group") String group, @PathParam(value="name") String name)
@GET @Path(value="/events/group/{group}/skip/{skip}/limit/{limit}") @Produces(value="application/json") @Consumes(value="application/json") public Set<step.plugins.events.Event> getGroupSkipLimit(@PathParam(value="group") String group, @PathParam(value="skip") int skip, @PathParam(value="limit") int limit)
@GET @Path(value="/events/group/{group}") @Produces(value="application/json") @Consumes(value="application/json") public Set<step.plugins.events.Event> getFullGroup(@PathParam(value="group") String group)
@GET @Path(value="/events/groups") @Produces(value="application/json") @Consumes(value="application/json") public Set<String> getGroups()
@GET @Path(value="/events/group/{group}/size") @Produces(value="application/json") @Consumes(value="application/json") public int getGroupSize(@PathParam(value="group") String group)
@DELETE @Path(value="/event/{id}") @Produces(value="application/json") @Consumes(value="application/json") public step.plugins.events.Event consumeEvent(@PathParam(value="id") String id)
@DELETE @Path(value="/event/group/{group}/name/{name}") @Produces(value="application/json") @Consumes(value="application/json") public step.plugins.events.Event consumeEventByGroupAndName(@PathParam(value="group") String group, @PathParam(value="name") String name)
@DELETE @Path(value="/events") @Produces(value="application/json") public Map<String,Object> clear()
@DELETE @Path(value="/events/group/{group}") @Produces(value="application/json") @Consumes(value="application/json") public Map<String,Object> clearGroup(@PathParam(value="group") String group)
@GET @Path(value="/events/monitoring/global") @Produces(value="application/json") @Consumes(value="application/json") public Map<String,Object> getStats()
@GET @Path(value="/events/monitoring/group/{group}") @Produces(value="application/json") @Consumes(value="application/json") public Map<String,Object> getGroupStats(@PathParam(value="group") String group) throws Exception
Exception
@GET @Path(value="/events/monitoring/clear") @Produces(value="application/json") @Consumes(value="application/json") public Map<String,Object> clearStats()
@GET @Path(value="/events/config/circuitBreakerThreshold/{circuitBreakerThreshold}") @Produces(value="application/json") @Consumes(value="application/json") public Map<String,Object> setCircuitBreakerThreshold(@PathParam(value="circuitBreakerThreshold") long circuitBreakerThreshold)
Copyright © 2020. All rights reserved.