1 24 25 package org.mr.kernel.services.queues; 26 27 import org.mr.core.protocol.MantaBusMessage; 28 29 import java.util.List ; 30 31 32 41 42 public interface ForeignQueueImpl { 43 public void init(); 44 public void sendToHead(MantaBusMessage message); 45 public void send(MantaBusMessage message); 46 public MantaBusMessage receiveNoWait(); 47 public MantaBusMessage receive(); 48 public MantaBusMessage receive(int timeout); 49 public List getCopy(); 50 public boolean isEmpty(); 51 public void waitForMessages(); 52 } | Popular Tags |