public boolean subscribe() throws Exception
    {
        Message message = connection.receive();
        System.out.println(message.getPayloadBuffer().toString());
        String[] tmp;
        tmp = message.getPayloadBuffer().toString().split(" ", 2);
        message.ack();
        if(firstMsg == false)
        {msgPrec = tmp[1];}
        if(tmp[1] != msgPrec || firstMsg==false)
        {
            firstMsg = true;
            msgPrec = tmp[1];
            if(tmp[1].charAt(0) == '{' && tmp[1].charAt(tmp[1].length()-1) == '}')
            {
                jsonMsg = new JSONObject(tmp[1]);
                System.out.println("jsonMsg: " + jsonMsg.toString());
            }
            else
            {
                String tmpS;
                tmpS = "{\"NORMALMESSAGE\" : \"" + tmp[1] + "\"}";
                jsonMsg = new JSONObject(tmpS);
                System.out.println("jsonMsg: " + jsonMsg.toString());
            }
            return(true);
        }
        else
            return(false);
    }