message-queue

3熱

1答えて

Laravelには、サービス（beanstalkd、Amazon SQS、Rabbit MQ）を使用して、長時間実行されているタスクをバックグラウンドワーカーに委任する、Queuesという機能があります。簡単な例では、コントローラからではなく、キューに入れられたジョブから電子メールを送信します。前記キューに入れられたジョブは、タスクが完了したかどうかを識別することができ、失敗した場合は、一定時間再

0熱

1答えて

Masstransit。ハンドラは、メッセージを認めない

私が持っている出版社： static void Main() { var bus = ServiceBusFactory.New(sbc => { sbc.UseRabbitMq(); sbc.UseJsonSerializer(); sbc.EnableMessageTracing(); sbc.Recei

0熱

1答えて

Masstransit + RabbitMQ。 2つの異なるメッセージタイプの間で1つのキューを共有する

私は出版社を持っており、rabbitmq：// localhost/test123キューにメッセージを発行しています。 1つのメッセージはTestMessageタイプで、もう1つはTestMessage2タイプです。出版社の設定： sbc.UseRabbitMq(r => r.ConfigureHost(new MessageUrn("rabbitmq://localhost/test123")

2熱

1答えて

Twitter HeronとStorm Fluxの使い方

私はapache-stormからtwitter-heronにプロジェクトを移行しようとしています。多くの苦闘の末、className: "storm.kafka.ZkHosts"の代わりにclassName: "org.apache.storm.kafka.ZkHosts"を使用するなど、ほとんどのエラーを取り除くことができました。しかし、私はトポロジを提出することに悩まされています。 Fluxを

1熱

1答えて

MSMQメッセージは配信されません - 一時停止すると発信に入ります

私は3台のマシンを持っています。それらをA、B（両方のサーバー）、Dev（私のローカルマシン）と呼んでみましょう。私はからB. に私が持っている実際のC＃コードをメッセージキューアイテムを送信するには、かなりシンプルで、正直、私は本当にそれがここでの問題ではないと思います。（POSTされたオブジェクトを受け取り、それをキューに押し込むwebapiです）。私はこれらのメッセージをDevからBに

0熱

1答えて

複数のユーザーにフィードを再送信する

解決するには次の問題があります。基本的に私はソケットを介して私に来て、私は複数のコンピュータにそれを再送信する必要があるフィードがあります。まず、ベータ版をできるだけ早く簡単に、最大250の接続で作成したいと考えています。それから、将来的には、接続数の拡張やパッケージのサイズの多少の拡張をサポートするアーキテクチャを備えたフルバージョンを構築します。いくつかのより詳細なデータ：パッケージは約

0熱

1答えて

Springインテグレーション：MQSeriesメッセージ駆動アダプタが動作しない

ActiveMQ（バインドメッセージ駆動チャネル）とKafka（アウトバウンドチャネル）を正常に統合できました。それは正常に動作します。 ActiveMQとMQ Seriesの両方がJMSに準拠しているので、移行がより簡単になると思いました。しかし、エラー以下の投げ： Setup of JMS Message listener invoker failed for destination 'que

0熱

2答えて

カプセル化とメッセージオブジェクト

MediatorやObserverパターンなどの内部メッセージシステムを開発する場合、渡されたメッセージオブジェクトをカプセル化する最良の方法は何ですか？いくつかのサービスに新しいJobを実行するように指示する次のメッセージオブジェクトを考えてみましょう。メッセージには、実行する必要があるJobが含まれています。 bool JobService::handleMessage(Message* m