Questions marquées [rabbitmq]

0 votes
0 réponses
Impossible de diffuser un message à l'aide de céleri
J'essaie d'utiliser la prise en charge intégrée du céleri pour le routage de diffusion à l'aide de Broadcast et de rabbitmq en tant que courtier...
a demandé il y a 2 mois
1 votes
0 réponses
RabbitMQ - Existe-t-il un système de test permettant de gérer une nouvelle livraison?
Dans RabbitMQ, lorsque la configuration est activée avec acks ... Si un consommateur ne parvient pas à battre son cœur et qu'un lapin remet e...
a demandé il y a 2 mois
0 votes
1 réponses
Comment lire les messages de la file d'attente RabbitMQ un par un
J'ai une exigence selon laquelle je dois lire les messages de DLQ et prendre les mesures appropriées en conséquence. Auparavant, l'extrait de co...
a demandé il y a 2 mois
-2 votes
0 réponses
comment envoyer et gérer un message dans 2 applications deiffrent symfony [fermé]
est-il possible d’envoyer et de recevoir dans 2 applications Symfony différentes par rabbitmq!? Par exemple, l'application 1 envoie un message e...
a demandé il y a 2 mois
0 votes
1 réponses
Consommateur RabbitMQ dans l'application ASP.NET Core avec la requête Web
Résumé Je résous comment résoudre le problème dans Setup RabbitMQ. consommateur dans l'application ASP.NET Core mais mon consommateur Rabbit e...
a demandé il y a 2 mois
0 votes
0 réponses
Pourquoi mon message RabbitMQ ne peut-il pas être sérialisé avec Apache Beam?
J'essaie de lire une file d'attente RabbitMQ à l'aide d'Apache Beam. J'ai écrit un code de transformation pour avoir des messages écrits à Kafka...
a demandé il y a 2 mois
0 votes
2 réponses
MassTransit / RabbitMQ - pourquoi autant de messages sont ignorés?
Je travaille avec 2 applications de console .NET Core dans un scénario producteur /consommateur avec MassTransit /RabbitMQ. Je dois m'assurer qu...
a demandé il y a 2 mois
0 votes
0 réponses
celery: pourquoi est-il utile de supprimer l'élément "search localdomain" dans /etc/resolv.conf
lorsque j'utilise "céleri -A tâches worker -l info", le noeud de travail se produit ensuite: [2019-04-26 20:27:00,290: ERROR/MainProcess] co...
a demandé il y a 2 mois
0 votes
1 réponses
Obtenir des messages par propriété ou en-tête dans RabbitMQ
Je suis nouveau dans RabbitMQ et j'ai rencontré un problème. J'essaie d'obtenir des messages de la file d'attente par la méthode API. C'est ce q...
a demandé il y a 2 mois
0 votes
1 réponses
Traitement résilient des messages de RabbitMQ
Je ne sais pas comment gérer de manière résiliente les messages RabbitMQ en cas de panne intermittente. Je m'abonne à un service Windows, lis...
a demandé il y a 2 mois
0 votes
1 réponses
RabbitMQ plusieurs consommateurs uniques sur le service Windows
J'ai effectué une recherche sur StackOverflow et je ne pense pas que les autres problèmes concernant plusieurs consommateurs correspondent à ce...
a demandé il y a 2 mois
0 votes
0 réponses
Ajout de files d'attente à Rabbitmq et de travailleurs aux files d'attente de céleri
Essayer d'exécuter environ 66 scripts python qui effectuent certaines tâches de manipulation de données. Trois scripts prennent énormément de te...
a demandé il y a 2 mois
1 votes
0 réponses
Comment accéder aux valeurs d'une liste à l'intérieur de tasks.py via views.py pendant que la liste est en train de se remplir et que la tâche n'est pas encore terminée?
J'ai une fonction simple dans views.py et je dois appeler une tâche de cette fonction pour effectuer une opération et mettre le résultat dans...
0 votes
2 réponses
Comment utiliser l'échange d'en-têtes pour envoyer et recevoir des objets Java sous forme de messages provenant de files d'attente dans rabbitmq
J'essaie d'utiliser l'en-tête d'échange dans rabbitmq pour produire et consommer des messages. Lorsque j'essaie de produire le message, je dois...
a demandé il y a 2 mois
1 votes
1 réponses
Cohérence des données entre Microservices avec RabbitMq
J'essaie de mettre en place une démonstration pratique de Microservice pour quelques systèmes internes simples traitant de la gestion des comman...
a demandé il y a 2 mois
0 votes
0 réponses
erreur python 104 Connexion réinitialisée par un homologue à l'aide de rabbitmq SSL
J'essaie de configurer SSL dans la connexion entre rabbitmq et le client Pika (en python 2.7). J'ai donc suivi le didacticiel présenté dans htt...
a demandé il y a 2 mois
0 votes
1 réponses
Comment arrêter gracieusement de consommer des messages avec @RabbitListener
Existe-t-il un moyen d'arrêter gracieusement un ListenerContainer et son associé 0600350991111101035062. Ce que j'essaie de réaliser. A...
a demandé il y a 2 mois
2 votes
2 réponses
Comment consommer 100 messages sans accusé de réception, puis travailler et ensuite les reconnaître?
Je consomme des messages d'un rabbitmq avec un amplificateur de printemps. Je consomme un message à la fois et sa lenteur est due au fait que je...
a demandé il y a 2 mois
0 votes
0 réponses
Renouvellement du message sans accusé de réception au même consommateur sans fermer le canal ni le redémarrage du courtier
Envisagez le scénario suivant: Un message est mis en file d'attente. La file d'attente est déclarée durable. Un seul consommateur obtie...
a demandé il y a 2 mois
0 votes
1 réponses
Impossible de se connecter à RabbitMQ démarré avec Docker dans un programme C # (avec RabbitMQ.Client)
J'ai créé un conteneur RabbitMQ après l'article suivant: https://docs.docker.com/samples /library /rabbitmq en utilisant l'image, y compris l'...
a demandé il y a 2 mois
1 votes
0 réponses
CQRS et Guide de sourcing d'événements
Je souhaite créer une architecture CQRS et Event Sourcing très économique, très souple et très simple. Je veux m'assurer que les événements...
a demandé il y a 2 mois
3 votes
3 réponses
Echec des messages ParseFrom en java à partir de C ++
J'ai une question /un problème. J'envoie des messages de C ++ à Java (Play framework) à l'aide de RabbitMq. Donc, en C ++, j'ai utilisé la fo...
a demandé il y a 2 mois
0 votes
0 réponses
Comment interagir avec le débogueur Visual Studio stdin lors du débogage d'une application de composition de docker .NET?
J'ai un simple projet de console .NET C # utilisant RabbitMQ avec MassTransit: using System; using MassTransit; namespace ConsoleApp1 { p...
a demandé il y a 2 mois
0 votes
0 réponses
Formation de cluster sur une seule machine, le deuxième nœud commençant à tomber en panne, car le port est utilisé
Sur mon bureau, j'essaie de créer un cluster RabbitMQ. Après avoir installé le serveur RabbitMQ v3.7.14 (et Erlang v21.3), le premier noeud rabb...
a demandé il y a 2 mois
0 votes
0 réponses
Faire attendre les criquets pèlerins
J'utilise Locust pour envoyer des messages dans une file d'attente RabbitMQ. Je peux le faire facilement en utilisant l'exemple RabbitMQ de la...
a demandé il y a 2 mois