ActivemMQ Java onMessage

onmessage.java

@Override public void onMessage(Message msg) { 
    if (msg instanceof BytesMessage) { 
        BytesMessage bMsg = (BytesMessage) msg; 
	StringBuilder buffer = new StringBuilder(); 
		
	try { 
	    for (int i = 0; i < (int)bMsg.getBodyLength(); i++) { 
	        buffer.append((char) bMsg.readByte()); 
	    } 
	} catch (JMSException e) { 
	    System.out.println("Failed to convert byte msg to string"); 
	} 
		
	String text = buffer.toString().trim(); 
	FailoverPojo pojo = new FailoverPojo(); 
	Gson gson = new Gson(); 
	pojo = gson.fromJson(text, FailoverPojo.class); 
	System.out.println("Received message: " + pojo.asJson()); // Must call acknowledge on Message object specifically. 
		
	try { 
	    msg.acknowledge(); 
	} catch (JMSException e) { 
	    e.printStackTrace(); 
	} 
    } 
}