Reactive Architecture Patterns Examples

To run these code samples you will need Java 1.7 or higher and RabbitMQ (3.5.4). I use the rabbitmq:latest docker image from Pivotal.

Be sure to go into common.AMQPCommon.java and update the connection info for RabbitMQ: (you can get this info from the RabbitMQ logs or doing a "docker ps" if you are using the docker image)

public static Channel connect() throws Exception {	
	ConnectionFactory factory = new ConnectionFactory();	

-->	factory.setHost("192.163.98.101");

-->	factory.setPort(32768);

	Connection conn = factory.newConnection();	
	return conn.createChannel();	
}

You will also need to be sure and run the AMQPInitialize class to setup all of the exchanges, queues, and bindings used by these examples.

If you want to run the scripts, you will need to set an environment variable REACT_HOME that points to the directory containing the src and lib directory where the class files and libraries are located in your local environment.

To run these examples you will need the latest RabbitMQ image (nuget, version 4.1.3 RabbitMQ Client). You can run RabbitMQ from a docker container (Pivotal latest is what I use) or natively.

Each directory under "reactive" should become a namespace for that context.

I created these examples using the latest .NET Core for MacOS Sierra using Visual Studio for the Mac.