@Override
    public void consume(String str)
    {
        /* New message received from the message board --> pass it to the client*/
        System.out.println(this.getClass().getSimpleName() +" Consume");
        if (!wasClosed)
        {
            if (output == null)
            {
                try
                {
                    output = new DataOutputStream(socket.getOutputStream());
                } catch (IOException e)
                {
                    e.printStackTrace();
                }
            }
            // if we are here the output and output streams are good

            try
            {
                output.writeUTF(str);
            } catch (IOException e)
            {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        else
        {
            System.out.println("Does not write to the connection, it was closed ");
        }


        // after we received the str from the GUI we need to sent it to the server, that he would be able to notify all
        // TODO Auto-generated method stub

    }