com/scalagent/kjoram/QueueBrowser.java

/*
 * JORAM: Java(TM) Open Reliable Asynchronous Messaging
 * Copyright (C) 2001 - ScalAgent Distributed Technologies
 * Copyright (C) 1996 - Dyade
 *
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation; either
 * version 2.1 of the License, or any later version.
 * 
 * This library is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * Lesser General Public License for more details.
 * 
 * You should have received a copy of the GNU Lesser General Public
 * License along with this library; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307
 * USA.
 *
 * Initial developer(s): Frederic Maistre (INRIA)
 * Contributor(s): Nicolas Tachker (ScalAgent)
 */
package com.scalagent.kjoram;

import com.scalagent.kjoram.jms.*;

import java.util.*;

import com.scalagent.kjoram.excepts.IllegalStateException;
import com.scalagent.kjoram.excepts.*;


public class QueueBrowser
{
  private Session sess;
  private Queue queue;
  private String selector;
  private boolean closed = false;

  QueueBrowser(Session sess, Queue queue, String selector) throws JMSException
  {
    if (queue == null)
      throw new InvalidDestinationException("Invalid queue: " + queue);

    this.sess = sess;
    this.queue = queue;
    this.selector = selector;

    if (sess.browsers == null)
      sess.browsers = new Vector();
    sess.browsers.addElement(this);

    if (JoramTracing.dbgClient)
      JoramTracing.log(JoramTracing.DEBUG, this + ": created.");
  }

  public String toString()
  {
    return "QueueBrowser:" + sess.ident;
  }

  public Queue getQueue() throws JMSException
  {
    if (closed)
      throw new IllegalStateException("Forbidden call on a closed browser.");

    return queue;
  }

  public String getMessageSelector() throws JMSException
  {
    if (closed)
      throw new IllegalStateException("Forbidden call on a closed browser.");

    return selector;
  }

  public Enumeration getEnumeration() throws JMSException
  {
    if (JoramTracing.dbgClient)
      JoramTracing.log(JoramTracing.DEBUG, this
                       + ": requests an enumeration.");
    if (closed)
      throw new IllegalStateException("Forbidden call on a closed browser.");

    // Sending a "browse" request:
    QBrowseRequest browReq = new QBrowseRequest(queue.getName(), selector);
    // Expecting an answer:
    QBrowseReply reply = (QBrowseReply) sess.cnx.syncRequest(browReq);

    if (JoramTracing.dbgClient)
      JoramTracing.log(JoramTracing.DEBUG, this
                       + ": received an enumeration.");

    // Processing the received messages:
    Vector momMessages = reply.getMessages();
    Vector messages = null;
    if (momMessages != null) {
      messages = new Vector();
      com.scalagent.kjoram.messages.Message momMsg;
      for (int i = 0; i < momMessages.size(); i++) {
        momMsg = (com.scalagent.kjoram.messages.Message) momMessages.elementAt(i);
        messages.addElement(Message.wrapMomMessage(null, momMsg));
      }
    }
                          
    // Return an enumeration:
    return new QueueEnumeration(messages);
  }

  public void close() throws JMSException
  {
    // Ignoring the call if the browser is already closed:
    if (closed)
      return;

    sess.browsers.removeElement(this);
    closed = true;

    if (JoramTracing.dbgClient)
      JoramTracing.log(JoramTracing.DEBUG, this + " closed.");
  }

  private class QueueEnumeration implements java.util.Enumeration
  {
    private Vector messages;

    private QueueEnumeration(Vector messages)
    {
      this.messages = messages;
    }

    public boolean hasMoreElements()
    {
      if (messages == null)
        return false;
      return (! messages.isEmpty());
    }

    public Object nextElement()
    {
      if (messages == null || messages.isEmpty())
        throw new NoSuchElementException();

      Object ret = messages.elementAt(0);
      messages.removeElementAt(0);
      return ret;
    }
  }
}

---