Consumer

Consumer.java

while(true){
            if(connection.isOpen()){
                logger.debug("MQ Connection is Opened");
            }else{
                logger.debug("MQ Connection is Closed");
            }
            messageFromQueue = rabbitmqUtil.getMessageFromQueue(waitTime, connection, exchangeName, routekeyName);
            logger.debug("messageFromQueue Obtained: "+messageFromQueue);
            if(messageFromQueue == null){
                boolStatus = false;
                break;
            }else{
                obtained_instanceid = xmlUtil.getValueFromXML(messageFromQueue, "instanceid");
                //obtained_processid = xmlUtil.getValueFromXML(messageFromQueue, "processid");
                obtained_taskid = xmlUtil.getValueFromXML(messageFromQueue, "taskid");
                status = xmlUtil.getValueFromXML(messageFromQueue, "status");

                if(own_instanceid.equals(obtained_instanceid) && own_taskid.equals(obtained_taskid) ){
                    logger.info("Message is for same step");
                    if(status.equals("SUCCESS")){
                        boolStatus = true;
                        if(requestName.equals("CleanDataRequest")){
                            String cleanData = xmlUtil.getValueFromXML(messageFromQueue,"cleandata");
                            returnMap.put("cleandata",cleanData);

                            if(stepRequestName.equals("CleanPrimaryFile")){
                            }else if(stepRequestName.equals("CleanSecondaryFile")){
                            }
                        }else if(requestName.equals("UpdateCleanDataRequest")){

                        }
                    }else{
                        boolStatus = false;
                    }
                }else{
                        logger.info("Message was not for this Step");
                        boolStatus = false;
                }
            } // else
        }   // while