package org.jboss.test.messagedriven.support;
import javax.jms.Message;
import javax.jms.MessageProducer;
public class SendMessageOperation extends Operation
{
public static final String MESSAGEID = "jboss_test_MESSAGEID";
protected String id;
public SendMessageOperation(BasicMessageDrivenUnitTest test, String id)
{
super(test);
this.id = id;
}
public void run() throws Exception
{
MessageProducer producer = test.getMessageProducer();
Message message = test.getTestMessage();
message.setStringProperty(MESSAGEID, id);
producer.send(message);
}
}