4

Spring-AMQP を使用して RabbitMQ を実行しながら在庫を取得します。

Spring-AMQP を使用して AutomaticRecoveryEnabled と NetworkRecoveryInterval を構成する方法を取得する必要があります。ネイティブの RabbitMQ ライブラリを使用して開発している場合は、これらのフラグを設定する直接オプションがあります。しかし、春を使って同じことをするための回避策が見つかりませんでした

RabbitMQ ネイティブ ライブラリの使用 (ヘルプは必要ありません)

factory.setAutomaticRecoveryEnabled(true);
factory.setNetworkRecoveryInterval(10000);

Spring-AMPQ の使用 (助けが必要)

上記のように、Spring-AMPQ を試しているときにそのような方法は見つかりませんでした。これが私が今していることです。

@Bean(name="listener")
public SimpleMessageListenerContainer listenerContainer() 
{
    SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
    container.setConnectionFactory(connectionFactory());
    container.setQueueNames(env.getProperty("mb.queue"));
    container.setMessageListener(new MessageListenerAdapter(messageListener));
    return container;
}

この点での助けは非常に高く評価されています。前もって感謝します。

4

2 に答える 2

1

さて、CachingConnectionFactorya を適用する別のコンストラクターがありますcom.rabbitmq.client.ConnectionFactory。

@Beanしたがって、適切なオプションを使用して最後のものを追加として構成し、 CachingConnectionFactory.

于 2014-08-07T10:32:26.960 に答える