Class EventBrokerServices


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

      • Fields inherited from class step.core.deployment.AbstractServices

        configuration, controller
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      java.util.Map<java.lang.String,​java.lang.Object> clear()  
      java.util.Map<java.lang.String,​java.lang.Object> clearGroup​(java.lang.String group)  
      java.util.Map<java.lang.String,​java.lang.Object> clearStats()  
      step.plugins.events.Event consumeEvent​(java.lang.String id)  
      step.plugins.events.Event consumeEventByGroupAndName​(java.lang.String group, java.lang.String name)  
      java.util.Map<java.lang.String,​java.util.Set<step.plugins.events.Event>> getEventBrokerGroupMap()  
      java.util.Map<java.lang.String,​java.util.Set<step.plugins.events.Event>> getEventBrokerGroupMap​(int skip, int limit)  
      java.util.Map<java.lang.String,​step.plugins.events.Event> getEventBrokerIdMap()  
      java.util.Map<java.lang.String,​step.plugins.events.Event> getEventBrokerIdMap​(int skip, int limit)  
      java.util.Set<step.plugins.events.Event> getFullGroup​(java.lang.String group)  
      java.util.Set<java.lang.String> getGroups()  
      int getGroupSize​(java.lang.String group)  
      java.util.Set<step.plugins.events.Event> getGroupSkipLimit​(java.lang.String group, int skip, int limit)  
      java.util.Map<java.lang.String,​java.lang.Object> getGroupStats​(java.lang.String group)  
      java.util.Map<java.lang.String,​java.lang.Object> getStats()  
      void init()  
      step.plugins.events.Event peekEvent​(java.lang.String id)  
      step.plugins.events.Event peekEventByGroupAndName​(java.lang.String group, java.lang.String name)  
      step.plugins.events.Event putEvent​(step.plugins.events.Event event)  
      java.util.Map<java.lang.String,​java.lang.Object> setCircuitBreakerThreshold​(long circuitBreakerThreshold)
      Conf Services
      • Methods inherited from class step.core.deployment.AbstractServices

        getContext, getExecutionRunnable, 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 java.lang.Exception
        Overrides:
        init in class step.core.deployment.AbstractServices
        Throws:
        java.lang.Exception
      • getEventBrokerIdMap

        @GET
        @Path("/events/asIdMap")
        @Produces("application/json")
        public java.util.Map<java.lang.String,​step.plugins.events.Event> getEventBrokerIdMap()
      • getEventBrokerGroupMap

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

        @GET
        @Path("/events/asIdMap/skip/{skip}/limit/{limit}")
        @Produces("application/json")
        public java.util.Map<java.lang.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 java.util.Map<java.lang.String,​java.util.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 java.lang.Exception
        Throws:
        java.lang.Exception
      • peekEvent

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

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

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

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

        @GET
        @Path("/events/groups")
        @Produces("application/json")
        @Consumes("application/json")
        public java.util.Set<java.lang.String> getGroups()
      • getGroupSize

        @GET
        @Path("/events/group/{group}/size")
        @Produces("application/json")
        @Consumes("application/json")
        public int getGroupSize​(@PathParam("group")
                                java.lang.String group)
      • consumeEvent

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

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

        @DELETE
        @Path("/events")
        @Produces("application/json")
        public java.util.Map<java.lang.String,​java.lang.Object> clear()
      • clearGroup

        @DELETE
        @Path("/events/group/{group}")
        @Produces("application/json")
        @Consumes("application/json")
        public java.util.Map<java.lang.String,​java.lang.Object> clearGroup​(@PathParam("group")
                                                                                 java.lang.String group)
      • getStats

        @GET
        @Path("/events/monitoring/global")
        @Produces("application/json")
        @Consumes("application/json")
        public java.util.Map<java.lang.String,​java.lang.Object> getStats()
      • getGroupStats

        @GET
        @Path("/events/monitoring/group/{group}")
        @Produces("application/json")
        @Consumes("application/json")
        public java.util.Map<java.lang.String,​java.lang.Object> getGroupStats​(@PathParam("group")
                                                                                    java.lang.String group)
                                                                             throws java.lang.Exception
        Throws:
        java.lang.Exception
      • clearStats

        @GET
        @Path("/events/monitoring/clear")
        @Produces("application/json")
        @Consumes("application/json")
        public java.util.Map<java.lang.String,​java.lang.Object> clearStats()
      • setCircuitBreakerThreshold

        @GET
        @Path("/events/config/circuitBreakerThreshold/{circuitBreakerThreshold}")
        @Produces("application/json")
        @Consumes("application/json")
        public java.util.Map<java.lang.String,​java.lang.Object> setCircuitBreakerThreshold​(@PathParam("circuitBreakerThreshold")
                                                                                                 long circuitBreakerThreshold)
        Conf Services