Tag: rabbitmq
RabbitMQ ist eine open-source-message-broker, die ursprünglich Implementierung des AMQP-Protokoll mit zusätzlichen messaging-Protokolle unterstützt, die über eine plug-in-Architektur. Dieser tag sollte verwendet werden, mit Fragen, die die RabbitMQ-server message broker Produkt oder Fragen bezüglich des Quellcodes und die Implementierung der RabbitMQ-Produkt. Eine bestimmte Protokoll-tag wie amqp oder mqtt können ebenfalls geeignet sein, sowie das Betriebssystem und die Programmiersprache, die verwendet wird.
2
Antworten
ich bin mit Rabbitmq-Java-client-API.ich möchte legen Sie die Grundlegenden Eigenschaften für die Nachricht und auch die Nachricht-Id der Nachricht.wenn möglich bitte etwas code, um die Dinge verstehen. Dank InformationsquelleAutor Sameek Mishra | 2010-11-11
1
Antworten
Ich versuche zu verstehen, einige Aspekte des AMQP-Protokoll. Derzeit habe ich ein Projekt mit RabbitMQ und Nutzung von python-pika-Bibliothek. Also Frage ist im Hinblick auf die Anerkennung und die Nachricht prefetching. Betrachten wir eine Warteschlange mit nur
1
Antworten
Baue ich einen Kolben app mit Sellerie, mit rabbitmq als Sellerie-backend. meine conf für Sellerie ist CELERY_BROKER_URL='amqp://localhost:5672', CELERY_RESULT_BACKEND='amqp://', CELERY_QUEUE_HA_POLICY='all', CELERY_TASK_RESULT_EXPIRES=None Dann, deklarieren eine Warteschlange produziert eine ganze Reihe von Fehler connection = pika.BlockingConnection(pika.ConnectionParameters('localhost')) channel = connection.channel() channel.queue_declare(queue=new_task_id)
1
Antworten
manchmal fand ich Folgen Eintrag in meine log-Datei. Ich habe keine Ahnung, was das problem ist. Meine Vermutung ist, zum einstellen einer niedrigeren Anforderung Herzschlag. Irgendwelche anderen Ideen? Darüber hinaus hatte ich die Situation, dass nach einem
2
Antworten
Ich versuche eine Verbindung von meinem Android-app auf eine queue namens "Nachrichten". Den Hersteller (eines webservices unter AMQP-Protokoll) ist schon angeschlossen, kann es sein, überprüfen Sie über RabbitMQ admin-panel. Verbindung von meinem Android-Gerät bin ich die Codierung
6
Antworten
Habe ich installiert, rabbitmq-Dienst auf dem server und auf meinem system. Ich möchte die Verwendung der RPC-Muster: var factory = new ConnectionFactory() { HostName = "158.2.14.42", Port = Protocols.DefaultProtocol.DefaultPort, UserName = "Administrator", Password = "@server@", VirtualHost =
1
Antworten
Wie lade ich ein rabbitmq-config beim Start, um zu bestätigen, dass die broker-Objekte (queues, exchanges, Bindungen, Benutzer, virtuelle hosts, Berechtigungen und Parameter) erstellt werden. Nach dem rabbitmq-Dokumentation es kann getan werden, über load_definitions http://www.rabbitmq.com/management.html#load-definitions Aber ich kann
2
Antworten
Ich versuche zu erstellen, die Verbraucher würden abonnieren Sie mehrere Warteschlangen, und dann die Verarbeitung von Nachrichten, wie Sie ankommen. Das problem ist, dass, wenn es einige Daten, die bereits in der ersten Warteschlange verbraucht er die
4
Antworten
Ich habe versucht, herauszufinden, genau das, was message-oriented middleware ist, aber nicht in der Lage zu finden, alle nicht-enterprise real world Beispiele, die für mich Sinn machen. Kann mir jemand eine eindeutige und leicht verständliche Erläuterung, was
1
Antworten
ConnectionFactory factory = new ConnectionFactory {HostName = "localhost"}; using (IConnection connection = factory.CreateConnection()) using (IModel channel = connection.CreateModel()) { channel.QueueDeclare("hello", false, false, false, null); for (int i = 0; i < 100000; i++) { MemoryStream stream =
2
Antworten
Bin ich mit Spring amqp version 1.1 als mein java-client. Ich habe eine Warteschlange, die rund 2000 Meldungen. Ich will einen service haben die Prüfungen dieser queue-Größe und und wenn es leer ist, sendet Sie eine Meldung
2
Antworten
Ich versuche, um zu überprüfen, ob eine gegebene rabbitmq Warteschlange leer ist oder nicht. Für die, die ich versuche zu verwenden: channel.queueDeclarePassive(queueName).getMessageCount(). Mit diesem bin ich immer 0 als Antwort, unabhängig von der Anzahl der angezeigten Nachrichten
1
Antworten
Ich bin mit amqplib in Node.js und ich bin nicht klar über die besten Praktiken in meinem code. Im Grunde meinem aktuellen code ruft die amqp.connect() wenn Sie den Node-server gestartet wird, und dann verwendet einen anderen
1
Antworten
Mit RabbitMQ gibt es einen Weg, es zu benutzen, ähnlich MSSMQ wo kann man pop 1000 Nachrichten aus der Warteschlange, dann machen Sie Ihre Einsätze, um die Datenbank und von dort aus weiter. Ich kann nicht scheinen
1
Antworten
Ich bin auf der Suche nach einer beraten, wie man am besten konfigurieren Sie meine rabbitMQ Austausch. Ich versuche, ein Thema exchange in einer round-robin-Methode. Jeder Verbraucher hat seine eigenen (eindeutigen) namens-Warteschlange angefügt, um ein Thema exchange.
3
Antworten
Ich habe Gegoogelt so viel, und nicht bekam keine richtige Antwort.So , ich bin Entsendung diese Frage für das bessere Ergebnis. Habe ich schon getötet, die RabbitMQ server-Prozess . Nun, wenn ich versuche ihn neu zu starten,
3
Antworten
Ich habe einen rabbitmq-consumer-Anwendung implementieren "publish/subscribe-pattern .net, das läuft perfekt, wie eine Konsole-Anwendung, aber wenn ich bereitstellen, die als windows-Dienst scheint es nicht zu sein, die Speicherung der Daten in mongodb. protected override void OnStart(string args) {
2
Antworten
Wissen wollen, das Verhalten von rabbitmq mehrere publisher und Verbraucher. Tut rabbitmq-server gibt eine Nachricht an einen der Verbraucher zu einer Zeit, und andere Verbraucher sind ideal in dieser Zeit? ODER Verbraucher wählen Sie eine unbeaufsichtigte Nachricht
2
Antworten
Ich habe eine Anwendung veröffentlicht, die Veranstaltung zu RabbitMQ und einem Verbraucher verbraucht der Veranstaltung. Meine Frage ist gibt es eine Möglichkeit zum schreiben eines unit-Tests testen die Funktionalität der Verbraucher. Nur zum hinzufügen dieser, der Verbraucher
2
Antworten
Ich habe ein problem mit der Ausführung Sellerie auf rabbitmq-server. Ich suchte und fand ein link, aber es hilft mir nicht. Mein env ist ubuntu 14.04, python 2.7.6, Sellerie 3.1.15, Django 1.7. Referenzierung ein link, die ich
2
Antworten
Ich bin derzeit auf der Implementierung rabbitMQ für ein tracking-system mit mehreren front-Produzenten schreiben auf der gleichen Warteschlange. Im Grunde habe ich zwei Arten von Nachrichten in der Warteschlange, als die tracking-workflow besteht aus zwei Schritten :
5
Antworten
Ich habe geerbt ein Projekt mit einer Puppe/Landstreicher/Virtual box-setup. Der Landstreicher Bestimmung brechen um meine erlangs umliegenden rabbitmq-server. den Fehler: ==> default: err: /Stage[main]/Rabbitmq::Install/Package[rabbitmq-server]/ensure: change from purged to present failed: Execution of '/usr/bin/apt-get -q -y -o DPkg::Options::=--force-confold
1
Antworten
Ich habe eine Spring AMQP message-listener läuft. public class ConsumerService implements MessageListener { @Autowired RabbitTemplate rabbitTemplate; @Override public void onMessage(Message message) { try { testService.process(message); //This process method can throw Business Exception } catch (BusinessException e) {
3
Antworten
Meines Wissens Sellerie wirkt sowohl als Produzent und konsument von Nachrichten. Dies ist nicht das, was ich erreichen will. Ich will Sellerie zu handeln, wie der Verbraucher ist, nur, um Feuer zu bestimmten Aufgaben auf der Grundlage
4
Antworten
Ich würde gerne eine Nachricht senden, die eine RabbitMQ-server und warten dann auf eine Antwort-Nachricht (auf eine "reply-to" - Warteschlange). Natürlich, ich will nicht ewig warten, falls die Anwendung die Verarbeitung dieser Nachrichten ist down - muss
1
Antworten
Mein grobes Verständnis ist, dass Redis ist besser, wenn Sie die in-memory key-value-store-Funktion, jedoch bin ich nicht sicher, wie das zu tun hat mit der Verteilung von Aufgaben? Heißt das, wir sollten verwenden Redis als message-broker, WENN
1
Antworten
Ich bin nicht in der Lage zu führen Sie die befestigt Spring-Boot-Anwendung sampler. Es verfügt über einen AMQP-starter, erfordern RabbitMQ. Grundsätzlich ist es eine einfache Anwendung, die nur sendet eine Nachricht an einen RabbitMQ-Austausch mit einer queue
1
Antworten
Habe ich installiert RabbitMQ Server installiert CentOS 6.6 und hab ich auch installiert und aktiviert-Management-plugin. Wenn ich den Befehl ausführen rabbitmq-plugins list dies ist es, was ich in der Konsole: Configured: E = explicitly enabled; e =
1
Antworten
Baue ich ein webchat mit Spring Boot, RabbitMQ und WebSocket als POC, aber ich bin stucked ein letzter Punkt: WebSockets Ich möchte meine ws-clients die Verbindung zu einem bestimmten Endpunkt, wie /room/{id} und wenn eine neue Nachricht
4
Antworten
Ich bauen will ein RabbitMQ-cluster in meine dev-Maschine (windows). Grund ist, dass ich möchte, um zu testen und zu untersuchen. Ist es möglich, mehr als eine rabbitmq-Instanz auf einem Rechner? Ich vermute, ich muss: Ändern Sie den
1
Antworten
Möchte ich set message header beim senden einer Nachricht an Kaninchen. Ich verwende folgenden code, aber verwirrt, wie man set-message-header in es. public static <T> void sendMessage(String routingKey,final Object message,Class<T> type){ DefaultClassMapper typeMapper = new DefaultClassMapper(); typeMapper.setDefaultType(type);
4
Antworten
Ich bin mit RabbitMQ als meine message broker und meine Arbeiter sind Sellerie Aufgaben. Ich bin versuchen, um ein Problem zu diagnostizieren, wo ich bin enqueue Aufgaben zu RabbitMQ aber Sellerie nicht abholen, dann nach oben. Gibt
3
Antworten
Ich Schreibe ein python-client für die Aufnahme einer Arbeit, die Nachrichten aus einer RabbitMQ-broker und verarbeiten die Aufträge, für die Rückgabe der Ergebnisse auf einen anderen server. Mein script sendet Nachrichten an den RabbitMQ-broker startet gut, aber
2
Antworten
Ich habe eine web-service-Schnittstelle, die abstracts ein RabbitMQ-server (fragt mich nicht warum, ich weiss es ist ein unnötiger Schritt, aber ich muss). Das ist, ich Umfrage die Nachrichten aus der Warteschlange über einen web-service aufrufen, nicht direkt
1
Antworten
Ich versuche zu laufen RabbitMQ Python-tutorial aber mit Absender auf der virtualbox-host-Maschine und-Empfänger und die Warteschlange auf der virtualbox-Gast-Maschine. Also modifizierte ich erwähnt send.py code nur ersetzt localhost mit 192.168.1.5. Wenn ich es laufen lasse, erhalte ich
3
Antworten
Macht die RabbitMQ .NET-client haben irgendeine Art von asynchroner support? Ich möchte in der Lage, eine Verbindung herstellen und konsumieren Nachrichten asynchron, aber habe noch keinen Weg gefunden, um zu tun, entweder so weit. (Für das konsumieren
3
Antworten
Habe ich eine generische standalone-JMS-Anwendung, die arbeitet mit folgenden JMS-Provider WebSphere, HornetQ und ActiveMq. Ich pass Kontext.INITIAL_CONTEXT_FACTORY und Kontext.PROVIDER_URL, die als Parameter an meine Anwendung, und erstellen Sie ein naming context, aus Ihnen etwas zu tun, wie
2
Antworten
Ich bin versuchen, RabbitMQ für ein paar Windows-Dienste, die ich Schreibe, zur Erleichterung der Kommunikation zwischen Ihnen auf eine schnelle und zuverlässige Art und Weise. Allerdings bin ich im laufen in ein problem, wenn die versuchen, die
1
Antworten
Habe ich ein Produzent und Makler, die auf der gleichen Maschine. Der Produzent sendet die Nachrichten etwa so: channel = connection.createChannel(); //Create a durable queue (if not already present) channel.queueDeclare(merchantId, true, false, false, null); //Publish message onto
1
Antworten
Ich bin neu RabbitMQ, und ich bin etwas verloren in der Dokumentation. Derzeit als ein Beispiel, den ich versuche zu bauen, ein kleines mailer-Dienst, der überwacht eine Warteschlange. Aber ich bin etwas stecken, wo sollte ich die
1
Antworten
Implementiert habe ich mehrere Verbraucher, die das abrufen von Nachrichten aus einer Warteschlange, ich mache das mit etwas ähnlich dieses Beispiel, außer, dass ich das Tue basic.Holen Sie sich in eine unendliche Schleife für die Abfrage an.
4
Antworten
RabbitMQ-Cluster ist nicht zu akzeptieren, neue verbindungen! Die Anzahl der Steckdosen angeschlossen ist niedrig, die einzige Nachricht in Rabbitmq Protokoll: * * * ACHTUNG * * Mnesia ist überlastet Was bedeutet das? Wie kann ich es lösen?
2
Antworten
Ich würde gerne überprüfen, ob eine Verbraucher/Arbeitnehmer anwesend ist, um zu konsumieren, ein Nachricht ich bin zu senden. Wenn es keine Arbeiter, würde ich anfangen, einige Arbeiter (sowohl die Konsumenten als auch Publisher sind auf einer einzigen
1
Antworten
Ich bin mit Federn SimpleMessageListenerContainer zu konsumieren-Nachrichten von einem RabbitMQ Warteschlange. Alles funktioniert gut, aber wenn eine ungültige Nachricht an die Warteschlange gesendet wird (z.B. ungültige json) den Hörer einfach abgebrochen wird, ist das Herunterfahren des Arbeitnehmers
1
Antworten
Ich bin auf der Suche für einen messaging-Dienst für ein neues Projekt, an der Schnittstelle einige C# - Anwendungen einige Java-Anwendungen. Ich wirklich wie RabbitMQ, weil es scheint, um beeindruckende Unterstützung für beide Technologien. Ich sehe in
2
Antworten
Wenn ich bin immer in Verbindung zu RabbitMQ und das warten auf Ereignisse mit einem EventingBasicConsumer, wie kann ich feststellen, ob ich schon vom server getrennt? Ich weiß, es ist ein Shutdown-event, aber es hat nicht Feuer,
3
Antworten
Bin ich mit pika-python-Bibliothek, um eine Verbindung zu rabbitmq-server auf localhost. class BaseRabbitSender(MessageSender): __metaclass__ = ABCMeta def __init__(self, host): self.node = BaseMessagingNode(host) self.connection = pika.BlockingConnection(pika.ConnectionParameters( host=host)) self.channel = self.connection.channel() @abstractmethod def send_message(self, message): pass def close_connection(self): self.connection.close()
3
Antworten
Ich hatte Schwierigkeiten, also ging ich in die registry und entfernt den service-Eintrag für rabbitmq. Wenn ich jetzt versuche neu zu installieren, es sagt, es ist bereits vorhanden aber es startet nicht (da habe ich es entfernt)
1
Antworten
Ich bin mit Sellerie mit django und rabbitmq zum erstellen einer message queue. Ich habe auch ein Arbeiter, der ursprünglich aus einer anderen Maschine. In einem django, das ich beginne einem Prozess wie diesem: def processtask(request, name):
1
Antworten
Was ist der nutzen von Gebäude oben auf MassTransit im Vergleich zu Gebäude direkt auf RabbitMQ? Ich glaube, dass der Vorteil von MassTransit ist " Typ " exchange (das publish-subscribe-interface /Typ), damit der Inhalt der Nachricht strukturiert