1 21 package com.presumo.jms.plugin; 22 23 import com.presumo.jms.message.JmsMessage; 24 import java.io.IOException ; 25 26 29 public interface MessageQueue 30 { 31 36 public boolean isPersistent(); 37 38 public int size(); 39 40 public void push(JmsMessage msg) throws IOException ; 41 42 public void push(JmsMessage [] msgs) throws IOException ; 43 44 public JmsMessage getNext() throws IOException ; 45 46 public JmsMessage [] getNext(int batchsize) throws IOException ; 47 48 public void delete(String key) throws IOException ; 49 50 public void delete(String [] keys) throws IOException ; 51 52 public void close() throws IOException ; 53 } | Popular Tags |