1 18 package org.apache.activemq.test; 19 20 import javax.jms.JMSException ; 21 import javax.jms.Message ; 22 import javax.jms.MessageConsumer ; 23 24 27 public class JmsTopicSendReceiveWithTwoConnectionsAndByteSelectorTest extends JmsTopicSendReceiveWithTwoConnectionsTest { 28 29 30 protected void configureMessage(Message message) throws JMSException { 31 message.setByteProperty("dummy", (byte) 33); 32 } 33 34 protected MessageConsumer createConsumer() throws JMSException { 35 return receiveSession.createConsumer(consumerDestination, "dummy = 33", false); 36 } 37 38 } 39 | Popular Tags |