QueueFactory queueFactory = QueueFactory.getInstance(); Queue myQueue = queueFactory.createQueue("myQueue", QueueType.PERSISTENT); String message = "Hello, QueueJ!"; myQueue.sendMessage(message); String receivedMessage = myQueue.receiveMessage(); System.out.println("Received message: " + receivedMessage); String failedMessage = "Failed message"; myQueue.rejectMessage(failedMessage);