ActiveMQ主题订阅是一种消息传递机制，它允许多个订阅者（消费者）订阅同一主题并接收相同的消息。以下是使用Java编写这种机制的代码示例：

1. 创建ActiveMQ的ConnectionFactory：

ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");

2. 创建一个Connection对象并启动：

Connection connection = connectionFactory.createConnection(); connection.start();

3. 创建Session对象：

Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

4. 创建一个Topic并命名：

Topic topic = session.createTopic("myTopic");

5. 创建一个MessageConsumer对象并设置它的MessageListener：

MessageConsumer consumer = session.createConsumer(topic); consumer.setMessageListener(new MessageListener() { public void onMessage(Message message) { try { System.out.println("Received message: " + ((TextMessage) message).getText()); } catch (JMSException e) { e.printStackTrace(); } } });

6. 发布消息到主题：

MessageProducer producer = session.createProducer(topic); TextMessage message = session.createTextMessage("Hello World!"); producer.send(message);

7. 关闭连接：

connection.close();

通过上述代码示例，我们可以实现ActiveMQ主题订阅的功能。