1 22 package org.jboss.test.messagedriven.support; 23 24 import javax.jms.Message ; 25 import javax.jms.MessageProducer ; 26 27 33 public class SendMessageOperation extends Operation 34 { 35 public static final String MESSAGEID = "jboss_test_MESSAGEID"; 36 37 protected String id; 38 39 public SendMessageOperation(BasicMessageDrivenUnitTest test, String id) 40 { 41 super(test); 42 this.id = id; 43 } 44 45 public void run() throws Exception  46 { 47 MessageProducer producer = test.getMessageProducer(); 48 Message message = test.getTestMessage(); 49 message.setStringProperty(MESSAGEID, id); 50 producer.send(message); 51 } 52 } 53 | Popular Tags |