// Process each message
                    for (int i = 0; i < messages.length && i < 1500; i++)
                    {
                        boolean deleteFlag = true;
                        if (!messages[i].isSet(Flags.Flag.SEEN))    
                        {
                            EmailData emailData = new EmailData();
                            try
                            {
                                EmailProcessing processer = new EmailProcessing();
                                processer.process(messages[i],queueData.user,queueData.pop_address,emailData,queueData);
                                PopMail pmail = new PopMail();
                                pmail.makeQuery(connEmail, emailData, queueData);
                                messages[i].setFlag(Flags.Flag.SEEN, true); 
                            }
                            catch (MessagingException mesg)
                            {
                                System.out.println("MessagingException: " + mesg + "
at message: "+i+"
");
                                deleteFlag = false;
                                RollBackEmail rBack = new RollBackEmail();
                                rBack.rollBackQuery(connEmail, emailData, queueData);
                            }
                        }
                        //will be enabled on live pop
                        messages[i].setFlag(Flags.Flag.DELETED, deleteFlag); 
                    }
                    folder.close(true);
                    popConn.store.close();