春のウサギのmqテンプレートベースのリスナーを使用しています
負荷が増加すると、リスナーは単純にシャットダウンします
リスナーがシャットダウンしないようにするにはどうすればよいですか?
または、シャットダウン直後にリスナーを再起動する方法は?
私は次の設定を使用しています:
<rabbit:connection-factory id="connectionFactory" host="localhost" password="guest" port="5672" username="guest" />
<rabbit:template id="amqpTemplate" connection-factory="connectionFactory"
exchange="${amqp_exchange_name}"/>
<rabbit:admin connection-factory="connectionFactory"/>
<rabbit:queue name="${amqp_queue_name}"/>
<rabbit:listener-container connection-factory="connectionFactory" concurrency="5">
<rabbit:listener ref="joblistener" queue-names="${amqp_queue_name}"/>
</rabbit:listener-container>
<bean id="joblistener" class="com.org.sample.Consumer"/>
消費者は、次の関数を含む私のリスナーです
@Override
public void onMessage(Message message) {
//do something
}