Class EventBrokerServices


  • @Singleton
    @Path("/eventbroker")
    public class EventBrokerServices
    extends step.core.deployment.AbstractStepServices
    • Constructor Detail

      • EventBrokerServices

        public EventBrokerServices()
    • Method Detail

      • init

        @PostConstruct
        public void init()
                  throws Exception
        Overrides:
        init in class step.core.deployment.AbstractStepServices
        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()
      • getEventBrokerIdMapWithRange

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

        @GET
        @Path("/events/asGroupMap/skip/{skip}/limit/{limit}")
        @Produces("application/json")
        public Map<String,​Set<step.plugins.events.Event>> getEventBrokerGroupMapWithRange​(@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