ConnectionFactory factory = new org.jboss.mq.SpyConnectionFactory(); factory.setServerURL("tcp://localhost:61616"); Connection connection = factory.createConnection(); connection.start(); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); MessageProducer producer = session.createProducer(null); Queue queue = session.createQueue("myQueue"); TextMessage message = session.createTextMessage(); message.setText("Hello, World!"); producer.send(queue, message); MessageConsumer consumer = session.createConsumer(queue); Message receivedMessage = consumer.receive(); consumer.close(); session.close(); connection.close();


上一篇:
下一篇:
切换中文