<dependency> <groupId>org.apache.activemq</groupId> <artifactId>activemq-all</artifactId> <version>${activemq.version}</version> </dependency> String brokerUrl = "tcp://localhost:61616"; String username = "admin"; String password = "admin"; ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(username, password, brokerUrl); Connection connection = connectionFactory.createConnection(); connection.start(); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); Destination destination = session.createQueue("myQueue"); MessageProducer producer = session.createProducer(destination); Message message = session.createTextMessage("Hello, JMS!"); producer.send(message);


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