1 28 29 package com.caucho.jms; 30 31 import com.caucho.log.Log; 32 33 import javax.jms.JMSException ; 34 import javax.jms.Topic ; 35 import java.util.logging.Logger ; 36 37 40 abstract public class AbstractTopic extends AbstractDestination 41 implements Topic { 42 protected static Logger log = Log.open(AbstractTopic.class); 43 44 abstract public AbstractDestination createSubscriberQueue(String selector) 45 throws JMSException ; 46 47 abstract public AbstractDestination createDurableSubscriber(String name, 48 String selector) 49 throws JMSException ; 50 51 abstract public void removeSubscriber(AbstractDestination queue) 52 throws JMSException ; 53 } 54 | Popular Tags |