MessageQueueAdapter


1   /*
2    *        JacORB - a free Java ORB
3    *
4    *   Copyright (C) 1999-2004 Gerald Brose
5    *
6    *   This library is free software; you can redistribute it and/or
7    *   modify it under the terms of the GNU Library General Public
8    *   License as published by the Free Software Foundation; either
9    *   version 2 of the License, or (at your option) any later version.
10   *
11   *   This library is distributed in the hope that it will be useful,
12   *   but WITHOUT ANY WARRANTY; without even the implied warranty of
13   *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
14   *   Library General Public License for more details.
15   *
16   *   You should have received a copy of the GNU Library General Public
17   *   License along with this library; if not, write to the Free
18   *   Software Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
19   *
20   */
21  
22  package org.jacorb.notification.queue;
23  
24  import org.jacorb.notification.interfaces.Message;
25  
26  /**
27   * @author Alphonse Bendt
28   * @version $Id: MessageQueueAdapter.java,v 1.2 2005/04/16 23:20:04 alphonse.bendt Exp $
29   */
30  public interface MessageQueueAdapter
31  {
32      void enqeue(Message message) throws InterruptedException  ;
33  
34      boolean hasPendingMessages() throws InterruptedException  ;
35  
36      int getPendingMessagesCount() throws InterruptedException  ;
37  
38      Message getMessageBlocking() throws InterruptedException  ;
39  
40      Message getMessageNoBlock() throws InterruptedException  ;
41  
42      Message[] getAllMessages() throws InterruptedException  ;
43  
44      Message[] getUpToMessages(int max) throws InterruptedException  ;
45  
46      Message[] getAtLeastMessages(int min) throws InterruptedException  ;
47      
48      void clear();
49  }

A to Z: JavaDoc & Examples Daily Java News & Articles Open Source Projects Open Source Codes Free Computer Books Remove Frame

Popular Tags