spring-amqp

0熱

1答えて

Spring AMQPを使用している場合、RabbitMQチャンネルでbasicAckのIOExceptionを正しく処理する方法は？春AMQPを使用して、このようなメソッドを宣言した

： @RabbitListener(..) public void myMethod(@Header(AmqpHeaders.CHANNEL) Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) Long tag, ...) やマニュアルを使用するにはどのように1が正常にACKをやったときにスローされる可能性がありIOExceptionに対

0熱

3答えて

RabbitMQを使用したSpring Cloud Springサービスコネクタ

CloudFoundryでRabbitmqサービスを接続するにはSpring Cloud Springサービスコネクタを使用します。 public class CloudConfig extends AbstractCloudConfig { @Bean public ConnectionFactory rabbitFactory() { return

0熱

1答えて

ウサギのリスナーは、RabbitMQのノードがダウンしているときは、常に消費者を実行するか、利用できるのRabbitMQサーバーがRabbitMQのExchangeにいくつかのメッセージを生成し、ウサギListener.butとQUEUENAMEにメッセージベースがキューIAMにメッセージが常に</p> <p>を取得していないときに消費していたときに

を停止します <bean id="rabbitListenerContainerFactory" class="org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory"> <property name="connectionFactory" ref="connectionFactory" /

2熱

1答えて

メッセージが正常に確認されたときを確実に知る方法はありますか？

私はSpring AMQPを使用するSpringブートアプリケーションを持っています。 AMQPの設定は次のようになります @Configuration public class AmqpConfig { @Bean DirectExchange directExchange() { return new DirectExchange("amq.direct"); }

0熱

1答えて

RabbitMQとSpringのために動的に排他的なコンシューマ/リスナを登録するには？

私は以下の問題を解決する必要があります。 RabbitMQメッセージングを使用して、単純な遅延再試行メカニズムを実装しようとしています。私はメッセージを配信するのが遅れているインフラを持っています。私は実行時にこの遅延再試行メカニズムを利用したいと思っている関心のある参加者をいくつでも持つことができます。参加者は、2つの詳細とメッセージ：のみを提供したいとします。1.遅延時間T秒後にメッセージ

0熱

2答えて

setMessageListenerでリスナーサービスを登録する

私は使用したい春のamqpアプリがありますが、リスナーサービスを登録する方法を知ることができないようです。これは私の注釈ベースの設定ファイルです。 package com.jerry.configuration; import org.springframework.amqp.core.AmqpAdmin; import org.springframework.amqp.core.Queue

0熱

1答えて

tomcatサーバーはrabbitmqサーバーに依存

私はカスタマイズされたspring-AmqpプロジェクトにRabbitMQサーバーを統合しています。これはspring mvc Designベースです。 RabbitMqサーバーがダウンしていますが、私のアプリケーションを起動しようとしていますが、Tomcatサーバーが起動していません。は、私は私の設定は、私は誰もが事前に、私はこの問題を解決するために感謝を助けることができる例外 org.spr

0熱

1答えて

デフォルトのcontent_type application/jsonにDefaultExceptionStatgyから無効化されたisFatalがあります

私はクライアントにcontent_type application/jsonを提供する必要はありませんが、デフォルトにしています。私はこれを働かせた。また、別の例と組み合わせて、ConditionalRejectingErrorHandlerからカスタムisFatal（Throwable t）を実装しようとしました。カスタムエラーハンドラを起動させることはできますが、それでもcontent_ty

0熱

2答えて

RabbitTemplate.send（）はRabbitMQへのメッセージ配信を保証しますか？

メソッドrabbitTemplate.send(message)への呼び出しが（org.springframework.amqp.rabbit.core.RabbitTemplateクラスから）返されるとき、Spring AMQPを使用して、メッセージがRabbitMQクラスタで配信され、複製されていることを確認できますか？