<bean id="connectionFactory" class="org.apache.activemq.spring.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://localhost:61616" />
</bean>
<bean id="destination" class="org.apache.activemq.command.ActivemQQueue">
<constructor-arg value="myQueue" />
</bean>
@Bean
public ConnectionFactory connectionFactory() {
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory();
connectionFactory.setBrokerURL("tcp://localhost:61616");
return connectionFactory;
}
@Bean
public Queue destination() {
return new ActiveMQQueue("myQueue");
}
@JmsListener(destination = "myQueue")
public void sendMessage(String message) {
}
<bean id="messageProducer" class="com.example.MessageProducer" />
<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="connectionFactory" />
<property name="defaultDestination" ref="destination" />
</bean>
public class MessageProducer {
@Autowired
private JmsTemplate jmsTemplate;
public void sendMessage(String message) {
jmsTemplate.convertAndSend(message);
}
}
@JmsListener(destination = "myQueue")
public void receiveMessage(String message) {
}
<bean id="messageConsumer" class="com.example.MessageConsumer" />
<bean id="jmsListenerContainerFactory" class="org.springframework.jms.config.DefaultJmsListenerContainerFactory">
<property name="connectionFactory" ref="connectionFactory" />
<property name="destinationResolver" ref="destinationResolver" />
</bean>
<bean id="destinationResolver" class="org.springframework.jms.support.destination.DynamicDestinationResolver" />
public class MessageConsumer {
public void receiveMessage(String message) {
}
}
