Чтение сообщения из очереди и отображение его пользователю? ⇐ JAVA

[Anonymous]

Сначала я хочу узнать, сколько сообщений уже существует в очереди. Следующий класс Browser вернет количество сообщений, существующих в очереди. Теперь я хочу, чтобы пользователь вводил количество сообщений, которые нужно прочитать из очереди, и отображал клиенту только это количество сообщений. Я не хочу читать все сообщения из очереди, а только то количество сообщений, которое хочет прочитать пользователь. Пожалуйста, проверьте код и ответьте, что нужно сделать.

public class Browser
{
public static void main(String[] args) throws Exception
{
| // get the initial context
| InitialContext ctx = new InitialContext();
|
| // lookup the queue object
| Queue queue = (Queue) ctx.lookup("queue/queue0");
|
| // lookup the queue connection factory
| QueueConnectionFactory connFactory = (QueueConnectionFactory) ctx.
| lookup("queue/connectionFactory");
|
| // create a queue connection
| QueueConnection queueConn = connFactory.createQueueConnection();
|
| // create a queue session
| QueueSession queueSession = queueConn.createQueueSession(false,
| Session.AUTO_ACKNOWLEDGE);
|
| // create a queue browser
| QueueBrowser queueBrowser = queueSession.createBrowser(queue);
|
| // start the connection
| queueConn.start();
|
| // browse the messages
| Enumeration e = queueBrowser.getEnumeration();
| int numMsgs = 0;
|
| // count number of messages
| while (e.hasMoreElements()) {
| | Message message = (Message) e.nextElement();
| | numMsgs++;
| }
|
| System.out.println(queue + " has " + numMsgs + " messages");
|
| // close the queue connection
| queueConn.close();
}
}

To read the number of messages as per user's requirements....
String NUMBER = request.getParameter("number");
.......
.......
.......
connection.start();
for (int s = 0; s

Подробнее здесь: https://stackoverflow.com/questions/611 ... o-the-user