updated

Author: bit-whacker

src/main/java/com/rabbit/test/handler/App.java

@@ -11,33 +11,28 @@
  * Hello world!
  *
  */
-public class App 
-{
-    private static Logger LOG = LogManager.getRootLogger();
+public class App {
 
-    private RabbitConnectionManager rabbitConnectionManager;
-    public static void main( String[] args )
-    {
-        System.out.println( "Initializing Rabbit Request Handler" );
-        (new App()).init();
+    private static Logger LOG = LogManager.getRootLogger();
+    private RabbitConnectionManager rcm;
+
+    public static void main(String[] args) throws InterruptedException{
+        (new App()).initPro();
     }
-    private void init(){
-        rabbitConnectionManager = RabbitGateManager.getInstance().getRabbitConnectionManager();
-        try {
-            LOG.debug("waiting for five seconds...");
-            Thread.sleep(5 * 1000);
-        } catch (InterruptedException e) {
-            // TODO Auto-generated catch block
-            e.printStackTrace();
-        }
+
+    public void initPro() throws InterruptedException {
+        rcm = RabbitGateManager.getInstance().getRabbitConnectionManager();
+        Thread.sleep(3000);
+        
+        LOG.debug("rabbitConnectionManager is getting ready!");
         sleepUntilRabbitConnectionSucceed();
-        LOG.info("Rabbit connection is ready now!");
+        
+        LOG.debug("rabbitConnectionManager is ready to handle messages :D");
     }
-    
+
     private void sleepUntilRabbitConnectionSucceed() {
         for (;;) {
-            RabbitMessageConsumer rConsumer = rabbitConnectionManager
-                    .getRabbitMessageConsumer();
+            RabbitMessageConsumer rConsumer = rcm.getRabbitMessageConsumer();
             if (rConsumer == null) {
                 LOG.info("rConsumer is null. Rabbit connection is not ready yeat");
                 try {
@@ -51,5 +46,5 @@ private void sleepUntilRabbitConnectionSucceed() {
         }
 
     }
-    
+
 }

src/main/java/com/rabbit/test/handler/rabbitmq/NlpProcessingRequestHandler.java

@@ -7,7 +7,6 @@
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 
-import com.lacheff.commonutil.rabbitmq.RabbitGate;
 import com.lacheff.commonutil.rabbitmq.RabbitMessageHander;
 import com.lacheff.commonutil.rabbitmq.request.NlpProcessingRequest;
 import com.lacheff.commonutil.rabbitmq.request.NlpSummarizationRequest;
@@ -17,16 +16,11 @@
 import com.lacheff.commonutil.rabbitmq.support.RoutingKey;
 
 public class NlpProcessingRequestHandler implements RabbitMessageHander {
-    private static Logger LOG = LogManager.getLogger(NlpProcessingRequestHandler.class);
-
-
-
-	private RabbitGate rabbitGate = RabbitGateManager.getInstance().getRabbitGate();
+    private static Logger LOG = LogManager.getRootLogger();
 
 	@Override
 	public void handle(Object object) {
-		LOG.info("Seeing this in the log means that message was send and received");
-
+		
 		if (object instanceof NlpProcessingRequest) {
 			handleNlpProcessingRequest((NlpProcessingRequest) object);
 		} else if (object instanceof NlpSummarizationRequest){
@@ -38,24 +32,32 @@ public void handle(Object object) {
 	}
 
 	private void handleNlpProcessingRequest(NlpProcessingRequest nlpProcessingRequest) {
-		LOG.info("Got processing request: {}", nlpProcessingRequest.getReviewUUID());
+		LOG.info("[x] Got processing request: {}", nlpProcessingRequest);
 		try {
 
 			NlpProcessingResponse nlpProcessingResponse = new NlpProcessingResponse();
-			nlpProcessingResponse.setReviewUUID(new Date() + "");
-			LOG.debug("Shipping response after NLP processing: {}", nlpProcessingResponse);
-			rabbitGate.send(nlpProcessingResponse);
+			nlpProcessingResponse.setReviewUUID(nlpProcessingRequest.getReviewUUID());
+			
+			LOG.info("Shipping response after NLP processing: {}", nlpProcessingResponse);
+			RabbitGateManager.getInstance().getRabbitGate().send(nlpProcessingResponse);
 
 		} catch (Exception ex) {
 			LOG.error("Exception at handleNlpProcessingRequest:", ex);
 		}
 	}
 
 	private void handleNlpSummarizationRequest(NlpSummarizationRequest nlpSummarizationRequest){
-	    LOG.debug("Sending response after NLP Summarization Request");
-	    NlpSummarizationResponse nlpSummarizationResponse = new NlpSummarizationResponse();
-	    nlpSummarizationResponse.setRequestUUID(new Date() + "");
-	    rabbitGate.send(nlpSummarizationResponse);
+	    LOG.info("[x] Got nlpSummarization request: {}", nlpSummarizationRequest);
+	    try{
+    	    NlpSummarizationResponse nlpSummarizationResponse = new NlpSummarizationResponse();
+    	    nlpSummarizationResponse.setRequestUUID(new Date() + "");
+    	    
+    	    LOG.info("Shipping response after NLP Summarization: {}", nlpSummarizationResponse);
+    	    RabbitGateManager.getInstance().getRabbitGate().send(nlpSummarizationResponse);
+    	    
+	    } catch (Exception ex) {
+            LOG.error("Exception at handleSummarizationRequest:", ex);
+        }
 	}
 
 	@Override