test_class.declarator: jobs
test_class.original_string: JobsBeingExecuted jobs;
test_class.type: JobsBeingExecuted
test_class.var_name: jobs
test_class.declarator: pjp
test_class.original_string: ProceedingJoinPoint pjp;
test_class.type: ProceedingJoinPoint
test_class.var_name: pjp
test_class.declarator: bus
test_class.original_string: EventBus bus;
test_class.type: EventBus
test_class.var_name: bus
test_class.declarator: data
test_class.original_string: SystemData data;
test_class.type: SystemData
test_class.var_name: data
test_class.declarator: incoming
test_class.original_string: SystemData incoming;
test_class.type: SystemData
test_class.var_name: incoming
test_class.declarator: start
test_class.original_string: JobStartEvent start;
test_class.type: JobStartEvent
test_class.var_name: start
test_class.declarator: complete
test_class.original_string: JobCompleteEvent complete;
test_class.type: JobCompleteEvent
test_class.var_name: complete
test_class.file: micro-events/src/test/java/com/oath/micro/server/events/JobsBeingExecutedTest.java
test_class.identifier: JobsBeingExecutedTest
test_case.body: @Test
      public void testExecute() throws Throwable {
          Signature sig = Mockito.mock(Signature.class);
          Mockito.when(pjp.getSignature())
                 .thenReturn(sig);
          when(pjp.getTarget()).thenReturn(this);
          Mockito.when(sig.getDeclaringType())
                 .thenReturn(String.class);
          jobs.aroundScheduledJob(pjp);
          verify(pjp, times(1)).proceed();
      }
test_case.class_method_signature: JobsBeingExecutedTest.testExecute()
test_case.full_signature: @Test public void testExecute()
test_case.identifier: testExecute
test_case.invocations: mock thenReturn when getSignature thenReturn when getTarget thenReturn when getDeclaringType aroundScheduledJob proceed verify times
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testExecute()
focal_class.declarator: r = new Random()
focal_class.modifier: private static final
focal_class.original_string: private static final Random r = new Random();
focal_class.type: Random
focal_class.var_name: r
focal_class.declarator: events = new ActiveEvents<JobExecutingData>()
focal_class.modifier: private final
focal_class.original_string: private final ActiveEvents<JobExecutingData> events = new ActiveEvents<JobExecutingData>();
focal_class.type: ActiveEvents<JobExecutingData>
focal_class.var_name: events
focal_class.declarator: statCounter = ConcurrentHashMultiset.create()
focal_class.modifier: @Getter(AccessLevel.PACKAGE)
      private final
focal_class.original_string: @Getter(AccessLevel.PACKAGE)
      private final ConcurrentHashMultiset<String> statCounter = ConcurrentHashMultiset.create();
focal_class.type: ConcurrentHashMultiset<String>
focal_class.var_name: statCounter
focal_class.declarator: eventBus
focal_class.modifier: private final
focal_class.original_string: private final EventBus eventBus;
focal_class.type: EventBus
focal_class.var_name: eventBus
focal_class.declarator: jobNameType
focal_class.modifier: private final
focal_class.original_string: private final JobName.Types jobNameType;
focal_class.type: JobName.Types
focal_class.var_name: jobNameType
focal_class.declarator: loggingRateLimiter
focal_class.modifier: private final
focal_class.original_string: private final LoggingRateLimiter<Class> loggingRateLimiter;
focal_class.type: LoggingRateLimiter<Class>
focal_class.var_name: loggingRateLimiter
focal_class.declarator: maxLoggingCapacity
focal_class.modifier: private final
focal_class.original_string: private final long maxLoggingCapacity;
focal_class.type: long
focal_class.var_name: maxLoggingCapacity
focal_class.file: micro-events/src/main/java/com/oath/micro/server/events/JobsBeingExecuted.java
focal_class.identifier: JobsBeingExecuted
focal_class.class_method_signature: JobsBeingExecuted.JobsBeingExecuted(@Qualifier("microserverEventBus") EventBus bus,
              @Value("${system.logging.max.per.hour:10}") long maxLoggingCapacity,
              @Value("${micro.events.job.name.format:SIMPLE}") JobName.Types jobNameType)
focal_class.full_signature: public  JobsBeingExecuted(@Qualifier("microserverEventBus") EventBus bus,
              @Value("${system.logging.max.per.hour:10}") long maxLoggingCapacity,
              @Value("${micro.events.job.name.format:SIMPLE}") JobName.Types jobNameType)
focal_class.identifier: JobsBeingExecuted
focal_class.modifiers: public
focal_class.parameters: (@Qualifier("microserverEventBus") EventBus bus,
              @Value("${system.logging.max.per.hour:10}") long maxLoggingCapacity,
              @Value("${micro.events.job.name.format:SIMPLE}") JobName.Types jobNameType)
focal_class.signature:  JobsBeingExecuted(@Qualifier("microserverEventBus") EventBus bus,
              @Value("${system.logging.max.per.hour:10}") long maxLoggingCapacity,
              @Value("${micro.events.job.name.format:SIMPLE}") JobName.Types jobNameType)
focal_class.class_method_signature: JobsBeingExecuted.JobsBeingExecuted(EventBus bus)
focal_class.full_signature: public  JobsBeingExecuted(EventBus bus)
focal_class.identifier: JobsBeingExecuted
focal_class.modifiers: public
focal_class.parameters: (EventBus bus)
focal_class.signature:  JobsBeingExecuted(EventBus bus)
focal_class.class_method_signature: JobsBeingExecuted.aroundScheduledJob(ProceedingJoinPoint pjp)
focal_class.full_signature: @Around("execution(* com.oath.micro.server.events.ScheduledJob.scheduleAndLog(..))") public Object aroundScheduledJob(ProceedingJoinPoint pjp)
focal_class.identifier: aroundScheduledJob
focal_class.modifiers: @Around("execution(* com.oath.micro.server.events.ScheduledJob.scheduleAndLog(..))") public
focal_class.parameters: (ProceedingJoinPoint pjp)
focal_class.return: Object
focal_class.signature: Object aroundScheduledJob(ProceedingJoinPoint pjp)
focal_class.class_method_signature: JobsBeingExecuted.size()
focal_class.full_signature: public int size()
focal_class.identifier: size
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: int
focal_class.signature: int size()
focal_class.class_method_signature: JobsBeingExecuted.events()
focal_class.full_signature: public int events()
focal_class.identifier: events
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: int
focal_class.signature: int events()
focal_class.class_method_signature: JobsBeingExecuted.toString()
focal_class.full_signature: @Override public String toString()
focal_class.identifier: toString
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: String
focal_class.signature: String toString()
focal_class.class_method_signature: JobsBeingExecuted.executeScheduledJob(final ProceedingJoinPoint pjp, final String type)
focal_class.full_signature: private Object executeScheduledJob(final ProceedingJoinPoint pjp, final String type)
focal_class.identifier: executeScheduledJob
focal_class.modifiers: private
focal_class.parameters: (final ProceedingJoinPoint pjp, final String type)
focal_class.return: Object
focal_class.signature: Object executeScheduledJob(final ProceedingJoinPoint pjp, final String type)
focal_class.class_method_signature: JobsBeingExecuted.logSystemEvent(final ProceedingJoinPoint pjp, final String type, JobExecutingData data,
              SystemData retVal)
focal_class.full_signature: private void logSystemEvent(final ProceedingJoinPoint pjp, final String type, JobExecutingData data,
              SystemData retVal)
focal_class.identifier: logSystemEvent
focal_class.modifiers: private
focal_class.parameters: (final ProceedingJoinPoint pjp, final String type, JobExecutingData data,
              SystemData retVal)
focal_class.return: void
focal_class.signature: void logSystemEvent(final ProceedingJoinPoint pjp, final String type, JobExecutingData data,
              SystemData retVal)
focal_class.class_method_signature: JobsBeingExecuted.postEvent(ProceedingJoinPoint pjp, String type, JobExecutingData data, SystemData retVal)
focal_class.full_signature: private void postEvent(ProceedingJoinPoint pjp, String type, JobExecutingData data, SystemData retVal)
focal_class.identifier: postEvent
focal_class.modifiers: private
focal_class.parameters: (ProceedingJoinPoint pjp, String type, JobExecutingData data, SystemData retVal)
focal_class.return: void
focal_class.signature: void postEvent(ProceedingJoinPoint pjp, String type, JobExecutingData data, SystemData retVal)
focal_class.class_method_signature: JobsBeingExecuted.addTypeToStatCounter(String type)
focal_class.full_signature: private void addTypeToStatCounter(String type)
focal_class.identifier: addTypeToStatCounter
focal_class.modifiers: private
focal_class.parameters: (String type)
focal_class.return: void
focal_class.signature: void addTypeToStatCounter(String type)
focal_class.class_method_signature: JobsBeingExecuted.buildId(String type, long threadId)
focal_class.full_signature: private String buildId(String type, long threadId)
focal_class.identifier: buildId
focal_class.modifiers: private
focal_class.parameters: (String type, long threadId)
focal_class.return: String
focal_class.signature: String buildId(String type, long threadId)
focal_method.body: @Around("execution(* com.oath.micro.server.events.ScheduledJob.scheduleAndLog(..))")
      public Object aroundScheduledJob(ProceedingJoinPoint pjp) throws Throwable {
  
          String type = jobNameType.getCreator()
                                   .getType(pjp.getSignature()
                                               .getDeclaringType());
  
          return executeScheduledJob(pjp, type);
  
      }
focal_method.class_method_signature: JobsBeingExecuted.aroundScheduledJob(ProceedingJoinPoint pjp)
focal_method.full_signature: @Around("execution(* com.oath.micro.server.events.ScheduledJob.scheduleAndLog(..))") public Object aroundScheduledJob(ProceedingJoinPoint pjp)
focal_method.identifier: aroundScheduledJob
focal_method.invocations: getType getCreator getDeclaringType getSignature executeScheduledJob
focal_method.modifiers: @Around("execution(* com.oath.micro.server.events.ScheduledJob.scheduleAndLog(..))") public
focal_method.parameters: (ProceedingJoinPoint pjp)
focal_method.return: Object
focal_method.signature: Object aroundScheduledJob(ProceedingJoinPoint pjp)