1

私は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

4

1 に答える 1

0

ドキュメントによると、receiveAndConvert メソッドはnull、キューに何もない場合に返すことができます。

于 2013-10-22T20:04:42.817 に答える