Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
 package org.jacorb.notification.queue;
 
 /*
  *        JacORB - a free Java ORB
  *
  *   Copyright (C) 1999-2012 Gerald Brose / The JacORB Team.
  *
  *   This library is free software; you can redistribute it and/or
  *   modify it under the terms of the GNU Library General Public
 *   License as published by the Free Software Foundation; either
 *   version 2 of the License, or (at your option) 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
 *   Library General Public License for more details.
 *
 *   You should have received a copy of the GNU Library General Public
 *   License along with this library; if not, write to the Free
 *   Software Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
 *
 */

Author(s):
Alphonse Bendt
public interface MessageQueue
    interface DiscardListener
    {
        void messageDiscarded(int maxSize);
    }
    
    void addDiscardListener(DiscardListener listener);
    
    void removeDiscardListener(DiscardListener listener);
    
    
get the next Message from this queue. which particular event is selected depends on the underlying implementation.

Parameters:
wait a boolean value. If this parameter is set to true the queue will block until an element is available. If the parameter is set to false the queue will return null in case it is empty.
Throws:
java.lang.InterruptedException
    Message getMessageboolean wait )
        throws InterruptedException;

    
get up to n events from this queue.

Parameters:
n number of requested messages
wait a boolean value. If this parameter is set to true the queue will block until an element is available. If the parameter is set to false the queue will return null in case it is empty.
    Message[] getMessagesint nboolean wait )
        throws InterruptedException;

    
get all Messages from this queue.

Parameters:
wait a boolean value. If this parameter is set to true the queue will block until an element is available. If the parameter is set to false the queue will return null in case it is empty.
    Message[] getAllMessagesboolean wait )
        throws InterruptedException;

    
put a Message into this queue.
    void putMessage event );

    
check if this queue is empty.
    boolean isEmpty();

    
access the current size of this queue.
    int getSize();
    
    
New to GrepCode? Check out our FAQ X