Embedded AMQP Java Broker

Question

Ich versuche, einen Integrationstest für eine Scala/Java-Anwendung zu erstellen, die eine Verbindung zu einem RabbitMQ-Broker herstellt. Um dies zu erreichen, möchte ich einen eingebetteten Broker, der AMQP spricht und vor jedem Test startet und stoppt. Ursprünglich habe ich versucht, ActiveMQ als Embedded Broker mit AMQP einzuführen, aber die Anwendung verwendet RabbitMQ und spricht daher nur AMQP Version 0.9.3, während ActiveMQ AMQP Version 1.0 benötigt.

Gibt es einen anderen eingebetteten Broker, den ich anstelle von ActiveMQ verwenden kann?

Answer 1

Ich bin nicht bekannt, dass eingebettete RabbitMQ Server so dass ich glaube, Sie haben ein paar Optionen, dies zu umgehen:

1. Ihr RabbitMQ Server muss nicht auf dem CI-Server vorhanden ist, können Sie bringen ein neuer Server, der Ihr CI-Rabbitmq-Server ist. Wenn Sie nicht selbst einen bringen können, könnten Sie in CloudAMQP schauen. Das kostenlose Tier bietet heute: 1M Nachrichten pro Monat, 20 gleichzeitige Verbindungen, 100 Warteschlangen, 10.000 Nachrichten in der Warteschlange. Könnte für Ihren CI-Prozess ausreichen.

2. Wenn Ihre Tests nur Komponententests für RabbitMQ durchgeführt werden, können Sie Ihre RabbitMQ-Nachrichtenproduktion ausspionieren. Das machen wir in einigen unserer Unit-Tests. Wir überprüfen nur, ob eine bestimmte Operation den Methodenaufruf veranlasst, eine bestimmte Nachricht zu erzeugen, aber wir machen uns das etwas vor, so dass wir keine Nachricht veröffentlichen. Dann testen wir jeden der Konsumenten, indem wir die Consumer-Methoden explizit mit einer spezifischen Nachricht aufrufen, die wir erstellt haben.

Answer 2

Sie können versuchen Apache QPid Java broker. Dies kann als eingebetteter Broker verwendet werden.

-Setup in Scala in einer anderen Frage SO beschrieben - Example of standalone Apache Qpid (amqp) Junit Test

Answer 3

ich einen Wrapper des Herunterladens um den Prozess entwickelt habe, Extrahieren, das Startens und Verwalten von RabbitMQ so dass es wie ein eingebetteten Dienst gesteuert von einem JVM Projekt arbeiten kann .

Check it out: https://github.com/AlejandroRivera/embedded-rabbitmq

Es ist so einfach wie:

EmbeddedRabbitMqConfig config = new EmbeddedRabbitMqConfig.Builder() 
    .version(PredefinedVersion.V3_5_7) 
    .build(); 
EmbeddedRabbitMq rabbitMq = new EmbeddedRabbitMq(config); 
rabbitMq.start(); 
... 
rabbitMq.stop(); 

Arbeiten auf Linux, Mac und Windows.

Answer 4

Eine vollständige In-Memory-Lösung. Ersetzen Sie die Eigenschaften spring.* wie erforderlich.

<dependency> 
    <groupId>org.apache.qpid</groupId> 
    <artifactId>qpid-broker</artifactId> 
    <version>6.1.1</version> 
    <scope>test</scope> 
</dependency> 

public class EmbeddedBroker { 
    public void start() { 
    Broker broker = new Broker(); 
    BrokerOptions brokerOptions = new BrokerOptions(); 
    brokerOptions.setConfigProperty("qpid.amqp_port", environment.getProperty("spring.rabbitmq.port")); 
    brokerOptions.setConfigProperty("qpid.broker.defaultPreferenceStoreAttributes", "{\"type\": \"Noop\"}"); 
    brokerOptions.setConfigProperty("qpid.vhost", environment.getProperty("spring.rabbitmq.virtual-host")); 
    brokerOptions.setConfigurationStoreType("Memory"); 
    brokerOptions.setStartupLoggedToSystemOut(false); 
    broker.startup(brokerOptions); 
    } 
} 

hinzufügen initial-config.json als Ressource:

{ 
    "name": "Embedded Test Broker", 
    "modelVersion": "6.1", 
    "authenticationproviders" : [{ 
    "name": "password", 
    "type": "Plain", 
    "secureOnlyMechanisms": [], 
    "users": [{"name": "guest", "password": "guest", "type": "managed"}] 
    }], 
    "ports": [{ 
    "name": "AMQP", 
    "port": "${qpid.amqp_port}", 
    "authenticationProvider": "password", 
    "protocols": [ "AMQP_0_9_1" ], 
    "transports": [ "TCP" ], 
    "virtualhostaliases": [{ 
     "name": "${qpid.vhost}", 
     "type": "nameAlias" 
    }] 
    }], 
    "virtualhostnodes" : [{ 
    "name": "${qpid.vhost}", 
    "type": "Memory", 
    "virtualHostInitialConfiguration": "{ \"type\": \"Memory\" }" 
    }] 
}