import javax.jms.*;
import org.jboss.mq.*;
public class JBossMQExample {
public static void main(String[] args) {
try {
ConnectionFactory factory = new ConnectionFactory();
factory.setProviderURL("jnp://localhost:1099");
Connection connection = factory.createConnection();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Queue queue = new Queue("exampleQueue");
MessageProducer producer = session.createProducer(queue);
MessageConsumer consumer = session.createConsumer(queue);
connection.start();
TextMessage message = session.createTextMessage();
message.setText("Hello, JBossMQ!");
producer.send(message);
Message receivedMessage = consumer.receive();
if (receivedMessage instanceof TextMessage) {
TextMessage textMessage = (TextMessage) receivedMessage;
System.out.println("Received message: " + textMessage.getText());
}
session.close();
connection.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
