Package step.plugins.events

Class EventBrokerServices

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

    • Field Summary

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

        configuration, SESSION

    • 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>> getEventBrokerGroupMapWithRange​(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> getEventBrokerIdMapWithRange​(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.AbstractStepServices

        getContext, getExecutionRunnable, getObjectEnricher, getObjectFilter, getScheduler

      • Methods inherited from class step.framework.server.AbstractServices

        getAbstractContext, getHttpSession, getSession, getSession, invalidateSession, setHttpServletRequest, 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.AbstractStepServices
        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()

      • getEventBrokerIdMapWithRange

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