public void run(){
        for(String message = drop.take(); !message.equals("Done"); message = drop.take()){
            System.out.println("Message Received: " + message);
            try{
                Thread.sleep(1000);
            }catch (InterruptedException e){

            }
        }
    }