1 18 package org.apache.activemq.transport.http; 19 20 import org.apache.activemq.broker.BrokerService; 21 22 import javax.jms.DeliveryMode ; 23 24 public class HttpPersistentSendAndReceiveTest extends HttpJmsSendAndReceiveTest { 25 protected BrokerService broker; 26 27 protected void setUp() throws Exception { 28 this.topic = false; 29 this.deliveryMode = DeliveryMode.PERSISTENT; 30 super.setUp(); 31 } 32 33 protected BrokerService createBroker() throws Exception { 34 BrokerService answer = new BrokerService(); 35 answer.setPersistent(true); 36 answer.addConnector(getBrokerURL()); 37 return answer; 38 } 39 } 40 | Popular Tags |