Pytania oznaczone [rabbitmq]

0 głosów
0 odpowiedzi
Nie można wysyłać wiadomości przy użyciu selera
Próbuję użyć kompilacji selera do obsługi routingu rozgłoszeniowego, używając Broadcast i używając rabbitmq jako brokera. Udało mi się pomyślnie...
spytał 2 miesiące temu
1 głosów
0 odpowiedzi
RabbitMQ - Czy istnieje testowy system ack do radzenia sobie z ponowną dostawą?
W RabbitMQ, gdy konfiguracja z włączonymi pakietami ... Jeśli konsument zawiedzie swoje bicie serca, a królik ponownie ustawi kolejkę pracy,...
spytał 2 miesiące temu
0 głosów
1 odpowiedzi
Jak odczytywać wiadomości kolejki RabbitMQ jeden po drugim
Mam wymaganie, w którym muszę przeczytać komunikaty DLQ i podjąć odpowiednie działania w oparciu o to. Wcześniej poniżej fragment kodu działał d...
spytał 2 miesiące temu
-2 głosów
0 odpowiedzi
jak wysyłać i obsługiwać wiadomości w 2 deiffrent aplikacji symfony [zamknięte]
czy można wysyłać i odbierać w 2 różnych aplikacjach Symfony przez rabbitmq!? na przykład aplikacja 1 wysyła wiadomość i aplikacja 2 obsługuje w...
spytał 2 miesiące temu
0 głosów
1 odpowiedzi
Klient RabbitMQ w aplikacji ASP.NET Core z żądaniem internetowym
Podsumowanie Robię to, co rozwiązałem w Ustawienia RabbitMQ konsument w aplikacji ASP.NET Core ale mój Rabbit konsument online, jeśli wykonam...
spytał 2 miesiące temu
0 głosów
0 odpowiedzi
Dlaczego moja wiadomość RabbitMQ jest niemożliwa do serializacji za pomocą Apache Beam?
Próbuję odczytać kolejkę RabbitMQ za pomocą Apache Beam. Napisałem kod transformacji, aby wiadomości były zapisywane w Kafce. Przetestowałem naw...
spytał 2 miesiące temu
0 głosów
2 odpowiedzi
MassTransit / RabbitMQ - dlaczego tak wiele wiadomości zostało pominiętych?
Pracuję z 2 aplikacjami konsoli .NET Core w scenariuszu producent /konsument z MassTransit /RabbitMQ. Muszę upewnić się, że nawet jeśli żaden z...
spytał 2 miesiące temu
0 głosów
0 odpowiedzi
seler : dlaczego jest to przydatne, gdy usuwam element „search localdomain” w /etc/resolv.conf
gdy używam „informacji seler -A task worker -l”, wtedy węzeł roboczy pojawia się: [2019-04-26 20:27:00,290: ERROR/MainProcess] consumer: Can...
spytał 2 miesiące temu
0 głosów
1 odpowiedzi
Pobierz wiadomości według właściwości lub nagłówka w RabbitMQ
Jestem nowy w RabbitMQ i napotkałem problem. Próbuję pobrać wiadomości z kolejki metodą API. Zrobiłem, że do tej pory chcę otrzymywać wiadomości...
spytał 2 miesiące temu
0 głosów
1 odpowiedzi
Elastyczne przetwarzanie wiadomości od RabbitMQ
Nie jestem pewien, jak elastycznie obsługiwać wiadomości RabbitMQ w przypadku sporadycznej awarii. Subskrybuję usługę Windows, czytam wiadomo...
spytał 2 miesiące temu
0 głosów
1 odpowiedzi
RabbitMQ Wielu unikalnych konsumentów w usłudze Windows
Szukałem StackOverflow i nie sądzę, aby inne problemy związane z wieloma klientami pasowały do ​​tego, co próbuję. Mam usługę Windows, która...
spytał 2 miesiące temu
0 głosów
0 odpowiedzi
Dodawanie kolejek do Rabbitmq i pracowników do kolejek w selera
Próbuje wykonać około 66 skryptów Pythona, które wykonują pewne zadania związane z manipulowaniem danymi. Wykonanie trzech skryptów zajmuje bard...
spytał 2 miesiące temu
1 głosów
0 odpowiedzi
Jak uzyskać dostęp do wartości listy znajdującej się w task.py za pośrednictwem views.py, gdy lista jest wypełniona i zadanie nie zostało jeszcze zakończone?
Mam prostą funkcję w views.py i muszę wywołać zadanie w tej funkcji, aby coś zrobić i umieścić wynik na liście. Muszę więc przeczytać pierwszy...
0 głosów
2 odpowiedzi
Jak korzystać z wymiany nagłówków, aby wysyłać i odbierać obiekty Java jako wiadomości z kolejek w rabbitmq
Próbuję użyć wymiany nagłówków w rabbitmq, aby produkować i konsumować wiadomości. Kiedy próbuję wygenerować wiadomość, muszę przekonwertować wi...
spytał 2 miesiące temu
1 głosów
1 odpowiedzi
Spójność danych między Microservices a RabbitMq
Próbuję skonfigurować praktyczną wersję demonstracyjną Microservice dla kilku prostych systemów wewnętrznych, które zajmują się zarządzaniem zam...
spytał 2 miesiące temu
0 głosów
0 odpowiedzi
błąd Pythona 104 Resetowanie połączenia przez peera przy użyciu rabbitmq SSL
Próbuję skonfigurować SSL w połączeniu między Królemmq i klientem Pika (w Pythonie 2.7), dlatego zastosowałem samouczek w https://www.rabbitmq....
spytał 2 miesiące temu
0 głosów
1 odpowiedzi
Jak z wdziękiem zatrzymać używanie wiadomości za pomocą @RabbitListener
Czy istnieje sposób na bezpieczne zatrzymanie ListenerContainer i powiązanych z nim Consumers. Co próbuję osiągnąć. Przestań konsumować...
spytał 2 miesiące temu
2 głosów
2 odpowiedzi
Jak konsumować 100 wiadomości bez potwierdzenia, a następnie wykonać pracę i potwierdzić?
Używam wiadomości z królika z amqpem sprężynowym. Używam jednej wiadomości na raz i jest to dość powolne, ponieważ zapisuję ją w DB. Otwieranie...
spytał 2 miesiące temu
0 głosów
0 odpowiedzi
Ponowne dostarczenie niepotwierdzonej wiadomości do tego samego konsumenta bez zamykania kanału lub restartu brokera
Rozważ następujący scenariusz: Wiadomość jest umieszczana w kolejce. Kolejka została zadeklarowana jako trwała. Pojedynczy konsument ot...
spytał 2 miesiące temu
0 głosów
1 odpowiedzi
Nie można połączyć się z RabbitMQ za pomocą Dockera w programie C # (z RabbitMQ.Client)
Uruchomiłem kontener RabbitMQ po artykule: https://docs.docker.com/samples /library /rabbitmq przy użyciu obrazu zawierającego narzędzie do za...
spytał 2 miesiące temu
1 głosów
0 odpowiedzi
Przewodnik po CQRS i Event Sourcing
Chcę utworzyć architekturę CQRS i Event Sourcing , która jest bardzo tania i bardzo elastyczna i bardzo nieskomplikowana. Chcę się upewnić,...
spytał 2 miesiące temu
3 głosów
3 odpowiedzi
Niepowodzenie komunikatów ParseFrom w Javie z C ++
Mam pytanie /problem. Wysyłam wiadomości z C ++ do Java (framework Play) za pomocą RabbitMq. Tak więc po stronie C ++ użyłem funkcji Serializ...
spytał 2 miesiące temu
0 głosów
0 odpowiedzi
Jak współdziałać ze standardowym debugerem programu Visual Studio podczas debugowania aplikacji do tworzenia skryptu .NET?
Mam prosty projekt konsoli .NET C # zużywający RabbitMQ z MassTransit: using System; using MassTransit; namespace ConsoleApp1 { public st...
spytał 2 miesiące temu
0 głosów
0 odpowiedzi
Tworzenie klastra na pojedynczej maszynie, uruchamianie drugiego węzła ulega awarii, ponieważ używany port
Na moim pulpicie próbuję utworzyć klaster RabbitMQ. Po zainstalowaniu serwera RabbitMQ w wersji 3.7.14 (i Erlang v21.3) pierwszy węzeł rabbit@lo...
spytał 2 miesiące temu
0 głosów
0 odpowiedzi
Uczyń czekanie szarańczy między zadaniami
Używam Locust, aby przekazywać wiadomości do kolejki RabbitMQ. Mogę to łatwo zrobić, używając próbki RabbitMQ z locust.io-demo repozytorium, a...
spytał 2 miesiące temu