minor fixes

Author: Marcel Sauer

src/main/java/de/marcelsauer/profiler/processor/AbstractAsyncStackProcessor.java

@@ -59,7 +59,6 @@ public void process(RecordingEvent event) {
  @Override
  public void start() {
  logger.info("starting " + this.getClass().getName());
- addShutdownHook();
  startScheduler();
  doStart();
  }
@@ -92,15 +91,6 @@ public static int getSuccessfullyProcessedStacksCounter() {
  return successfullyProcessedStacksCounter.intValue();
  }
 
- private void addShutdownHook() {
- Runtime.getRuntime().addShutdownHook(new Thread("jca-writer-shutdown-thread") {
- @Override
- public void run() {
- AbstractAsyncStackProcessor.this.stop();
- }
- });
- }
-
  private void startScheduler() {
  scheduledExecutor.scheduleAtFixedRate(new WorkQueueProcessorTask(), 0, 1, TimeUnit.SECONDS);
  }

src/main/java/de/marcelsauer/profiler/processor/StackProcessorFactory.java

@@ -28,6 +28,19 @@ public static StackProcessor getStackProcessor() {
  logger.info("using stack processor of type: " + stackProcessor.getClass().getName());
 
  stackProcessor.start();
+
+ addShutdownHook();
+
  return stackProcessor;
  }
+
+ private static void addShutdownHook() {
+ Runtime.getRuntime().addShutdownHook(new Thread("jca-shutdown-thread") {
+ @Override
+ public void run() {
+ logger.info("shutting down jca processor " + stackProcessor.getClass().getName());
+ stackProcessor.stop();
+ }
+ });
+ }
 }

src/main/java/de/marcelsauer/profiler/processor/file/AsyncFileWritingStackProcessor.java

@@ -16,7 +16,7 @@
 import de.marcelsauer.profiler.processor.RecordingEvent;
 
 /**
- * writes data to configured fiel
+ * writes data to configured file
  */
 public class AsyncFileWritingStackProcessor extends AbstractAsyncStackProcessor {
 

src/test/java/integration/AbtractAsyncIntegrationTest.java

@@ -16,7 +16,7 @@
 /**
  * assumes you've build the project via <pre>mvn clean package</pre> so that ./target/ contains the agent jar
  */
-abstract class  AbtractAsyncIntegrationTest {
+abstract class AbtractAsyncIntegrationTest {
 
  @Test
  public void thatAsyncProcessorWorks() throws Exception {
@@ -63,7 +63,7 @@ private void randomSleep() {
  public boolean isTrue() {
  return expectedStackCount == AbstractAsyncStackProcessor.getSuccessfullyProcessedStacksCounter();
  }
- }, expectedStackCount).go();
+ }, expectedStackCount * 3).go();
 
  // give some more time ...
  Thread.sleep(2000);