1 18 package org.apache.activemq.perf; 19 20 import javax.jms.ConnectionFactory ; 21 import javax.jms.DeliveryMode ; 22 import javax.jms.Destination ; 23 import javax.jms.JMSException ; 24 27 public class SimpleNonPersistentTopicTest extends SimpleTopicTest{ 28 29 protected PerfProducer createProducer(ConnectionFactory fac,Destination dest,int number, byte[] payload) throws JMSException { 30 PerfProducer pp = new PerfProducer(fac,dest,payload); 31 pp.setDeliveryMode(DeliveryMode.NON_PERSISTENT); 32 return pp; 33 } 34 } 35 | Popular Tags |