#258 CommandListener needs to get injected dependencies

Author: Igor Polevoy

javalite-async/src/main/java/org/javalite/async/Async.java

@@ -197,6 +197,9 @@ private void configureListeners(Injector injector, List<QueueConfig> queueConfig
             for (int i = 0; i < queueConfig.getListenerCount(); i++) {
                 CommandListener listener = (CommandListener) queueConfig.getCommandListenerClass().newInstance();
                 listener.setInjector(injector);
+                if(injector != null){
+                    injector.injectMembers(listener);
+                }
                 Session session = consumerConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
                 MessageConsumer consumer = session.createConsumer(queue);
                 consumer.setMessageListener(listener);

javalite-async/src/test/java/org/javalite/async/AsyncSpec.java

@@ -158,4 +158,19 @@ public void shouldStartStopBroker() throws IOException, InterruptedException {
         async.stop();
         a(HelloCommand.counter()).shouldBeEqual(20);
     }
+
+    @Test
+    public void shouldInjectDependencyIntoCommandListener() throws InterruptedException {
+
+        Injector injector = Guice.createInjector(new GreetingModule());
+        Async async = new Async(filePath, false, injector, new QueueConfig(QUEUE_NAME, HelloCommandListener.class, 1));
+        async.start();
+
+        async.send(QUEUE_NAME, new HelloCommand("Hi, there"));
+
+        //SEE ASSERTION INSIDE HelloCommandListener.
+
+        Thread.sleep(1000);
+        async.stop();
+    }
 }

javalite-async/src/test/java/org/javalite/async/HelloCommandListener.java

@@ -0,0 +1,19 @@
+package org.javalite.async;
+
+import com.google.inject.Inject;
+import org.javalite.async.services.GreetingService;
+
+/**
+ * @author Igor Polevoy on 2/2/16.
+ */
+public class HelloCommandListener  extends CommandListener{
+
+    @Inject
+    private GreetingService greetingService;
+
+    @Override
+    public <T extends Command> void onCommand(T command) {
+        assert greetingService != null;
+        super.onCommand(command);
+    }
+}