package org.jboss.resource.adapter.jms;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.jms.Topic;
import javax.jms.TopicConnection;
import javax.jms.TopicPublisher;
import javax.jms.TopicSession;
import javax.naming.InitialContext;
import org.jboss.jms.jndi.JNDIProviderAdapter;
public class TestClient
{
public TestClient()
{
}
public static void main(String[] args)
{
try
{
JmsManagedConnectionFactory f = new JmsManagedConnectionFactory();
f.setJmsProviderAdapter(new JNDIProviderAdapter());
JmsConnectionFactory cf = (JmsConnectionFactory) f.createConnectionFactory();
TopicConnection con = cf.createTopicConnection();
TopicSession ses = con.createTopicSession(true, Session.AUTO_ACKNOWLEDGE);
Topic topic = (Topic) new InitialContext().lookup("topic/testTopic");
TopicPublisher pub = ses.createPublisher(topic);
TextMessage m = ses.createTextMessage("Hello world!");
pub.publish(m);
ses.commit();
ses.close();
}
catch (Exception ex)
{
System.err.println("Error: " + ex);
ex.printStackTrace();
}
}
}