私はrabbitTemplate
このように使用しています:
<bean id="rabbitConnFactory" class="org.springframework.amqp.rabbit.connection.SingleConnectionFactory">
<constructor-arg>
<value>localhost</value>
</constructor-arg>
</bean>
<!-- Spring AMQP Template -->
<bean id="rabbitTemplate" class="org.springframework.amqp.rabbit.core.RabbitTemplate">
<property name="connectionFactory" ref="rabbitConnFactory" />
</bean>
<!-- Spring AMQP Admin -->
<bean id="rabbitAdmin" class="org.springframework.amqp.rabbit.core.RabbitAdmin">
<constructor-arg ref="rabbitConnFactory" />
</bean>
交換に送る:
rabbitTemplate.setExchange(exchange);
rabbitTemplate.convertAndSend(message);
交換から読み取る:
rabbitTemplate.setExchange(exchange);
rabbitTemplate.setQueue(exchange); //?
Object msg = rabbitTemplate.receiveAndConvert();
return msg;
(データベースから取得したため、交換ランタイムを設定する必要があります)
しかしmsg
、常にnull
。