[WinForm] rabbitMQ Queue Queue Nachrichtenpersistenz [mit Quellcode]

Unbehandelte Ausnahme: RabbitMQ.Client.Exceptions.OperationInterruptedException: Die AMQP-Operation wurde unterbrochen: AMQP close-reason, initiiert von Peer, code=406, text="PRECONDITION_FAILED - Inequivalent arg 'durable' für die Warteschlange 'hello' in vhost 'myserver': received 'true', aber current is 'false'", classId=50, methodId=10, cause=

/**
* Erstelle eine neue Warteschlange, mit Namen, Haltbarkeitsflag, Auto-Delete-Flag und Argumenten.
* @param Namen der Warteschlange – darf nicht null sein; Setze auf "", damit der Makler den Namen generiert.
* @param dauerhaft wahr, wenn wir eine dauerhafte Warteschlange deklarieren (die Warteschlange übersteht einen Server-Neustart)
* @param exklusiv wahr, wenn wir eine exklusive Warteschlange deklarieren (die Warteschlange wird nur vom Alleinschalter verwendet
* Verbindung)
* @param autoDelete true, wenn der Server die Warteschlange löschen sollte, wenn sie nicht mehr genutzt wird
* @param Argumente, die Argumente, die zur Deklaration der Warteschlange verwendet werden
*/
public Queue(String name, boolean durable, boolean exclusive, boolean autoDelete, Map<String, Object> arguments) {
   Assert.notNull(name, "'name' kann nicht null sein");
   this.name = Name;
   this.actualName = StringUtils.hasText(name) ? Name
         : (Base64UrlNamingStrategy.DEFAULT.generateName() + "_awaiting_declaration");
   this.durable = durable;
   this.exklusiv = exklusiv;
   this.autoDelete = autoDelete;
   this.arguments = argumente != null ? Argumente : neues HashMap<>();
}

Parameter-Einführung:
1. Name: Der Name der Warteschlange;
2. actualName: Der echte Name der Warteschlange, der Name-Parameter wird standardmäßig verwendet; ist der Name leer, wird einer gemäß den Regeln generiert;
3. Dauerhaft: ob es persistent ist;
4. Exklusiv: ob es exklusiv oder exklusiv ist;
5. autoDelete: ob automatisch gelöscht werden soll;
6. Argumente: Andere Attributparameter der Warteschlange haben folgende Optionen, siehe Argumente in Abbildung 2:
(1) x-message-ttl: die Ablaufzeit der Nachricht in Millisekunden;
(2) x-Ablauf: Warteschlangenablaufzeit, wie lange die Warteschlange gelöscht wird, wenn nicht auf sie zugegriffen wird, Einheit: Millisekunden;
(3) x-max-länge: Die maximale Warteschlange, wenn sie den maximalen Wert übersteigt, wird die Nachricht aus dem Warteschlangenkopf gelöscht;
(4) x-max-länge-Bytes: Der Inhalt der Warteschlangennachrichten nimmt den maximalen Speicherplatz ein, begrenzt durch die Speichergröße, und wenn er diesen Schwellenwert überschreitet, wird die Nachricht aus dem Warteschlangenkopf gelöscht;
(5) x-Overflow: Stellen Sie das Queue-Overflow-Verhalten ein. Dies bestimmt, was mit der Nachricht passiert, wenn die maximale Warteschlange erreicht ist. Gültige Werte sind Drop-Head, Reject-Publish oder Reject-Publish-DLX. Quorum-Warteschlangentypen unterstützen nur Drop-Head;
(6) x-tot-Buchstaben-Austausch: Der Name des toten Buchstabenaustauschs und die Nachrichten, die abgelaufen oder gelöscht wurden (aufgrund der langen Wartelänge oder des Platzes, der die Schwelle überschreitet), können als Senden an die Vermittlungsstelle angegeben werden;
(7) x-Totbrief-Routing-Key: Der Routing-Key der Dead-Letter-Nachricht, der verwendet wird, wenn die Nachricht an den Dead-Letter Exchanger gesendet wird; falls nicht gesetzt, wird der ursprüngliche Routing-Key-Wert der Nachricht verwendet
(8) x-einzelner-aktiver-Konsument: Gibt an, ob die Warteschlange ein einzelner aktiver Konsument ist; falls wahr, konsumiert nur ein Konsument in der registrierten Verbrauchergruppe Nachrichten, die anderen werden ignoriert, und falsch, wenn die Nachricht in einer Schleife an alle Konsumenten verteilt wird (Standard falsch)
(9) x-max-Priorität: die maximale Anzahl der von der Warteschlange unterstützten Prioritäten; Wenn nicht gesetzt, unterstützt die Warteschlange keine Nachrichtenpriorität;
(10) x-queue-mode (Lazy mode): Die Warteschlange auf Verzögerungsmodus setzen, so viele Nachrichten wie möglich auf der Festplatte speichern, um den RAM-Verbrauch zu reduzieren; Wenn nicht gesetzt, speichert die Warteschlange einen Speichercache, um Nachrichten so schnell wie möglich zuzustellen;
(11) x-queue-master-locator: Stellen Sie die Master-Node-Informationen der Spiegelwarteschlange im Cluster-Modus ein.