1 package org.jacorb.notification.queue; 2 3 23 24 import org.jacorb.notification.interfaces.Message; 25 26 30 31 public interface MessageQueue 32 { 33 44 Message getMessage( boolean wait ) 45 throws InterruptedException ; 46 47 57 Message[] getMessages( int n, boolean wait ) 58 throws InterruptedException ; 59 60 68 Message[] getAllMessages( boolean wait ) 69 throws InterruptedException ; 70 71 74 void put( Message event ); 75 76 79 boolean isEmpty(); 80 81 84 int getSize(); 85 } 86 | Popular Tags |