spring-rabbitmq

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熱

1答えて

spring-streamは "application/json"の代わりに "text/plain" content-typeを持つメッセージを送信します

jsonオブジェクトがペイロードに含まれているため、content type application/jsonのキューに応答を生成します。（RabbitMQのに基づいて）私の春ストリームは、常に以下のヘッダ（ペイロードが正しいとJSON形式を持っている）とのメッセージを生成する理由しかし... は知ってはいけません。 (view from rabbit ui) properties:

0熱

3答えて

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

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

-1熱

1答えて

rabbit mqからの読み込みが遅い

私はrabbitmqキューから読み込んでデータストアに書き込む必要があります。現在、キューからメッセージを読み取るのにAmqpItemReaderを使用しています。私が読んだデータはJson形式であり、すべて私のItemProcessorは、jsonをJavaオブジェクトにシリアル化することです。私のシングルスレッドソリューションのパフォーマンスは非常に低いです。私は1秒あたり12msgの割合

0熱

1答えて

使用春の雲春のサービスコネクタおよびパブリッシャーの設定機能

を開始私はスプリンガーパクラウドの設定でのRabbitMQを接続します @Bean public ConnectionFactory rabbitConnectionFactory() { Map<String, Object> properties = new HashMap<String, Object>(); properties.put("publisherConfi

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" /

0熱

1答えて

サービスの再開後、Rabbitmqはメッセージを受信しません。

私のシステムでは、イベントの送受信にspring-cloud-streamとRabbitMQを使用しています。私はRabbitMQを実行して、サービスAをアップし、サービスBをダウンさせました。サービスは、サービスBにイベントを送信します。その後、私はサービスBになりました。そして今、私はRabbitがイベントを引き抜くことを期待していますが、何も起こりません。それは正しい行動ですか？私はRab

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熱

1答えて

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

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