MessageQueue<Integer> queue = QueueBuilder.newBuilder() .buildQueue(); if (message != null) { System.out.println("Received message: " + message); }