Riptide is a super-simple multiplatform messaging-bus with built-in

• Thread-safe dispatch so you don't have to worry about concurrency
• Message correlation so your related messages can be handled together
• Multi platform implementations so you can have polyglot components
• Easy to use API which hides the complexity of message passing

Check the Wiki [here][mavenlink].

Note that this guide details the usage of the reference implementation which is written in Kotlin and can be used by any JVM language capable of Java interop.

• Grab a copy of Riptide using either Maven:

  <dependency>
      <groupId>org.codetome.riptide</groupId>
      <artifactId>riptide.core.java</artifactId>
      <version>2017.1.0</version>
  </dependency>
  

  or Gradle:

  compile group: 'org.codetome.riptide', name: 'riptide.core.java', version: '2017.1.0'
  

• Configure and create the RiptideService:

  RiptideService rs = new RiptideServiceBuilder()
      .useRabbit(new RabbitConfig("localhost", 5672))
      // this optional switch makes all correlated messages dispatch on a single thread but concurrently with non-related messages
      // useful when you don't want to handle race conditions with your related messages and want them to be processed serially
      .dispatchProcessesOnSingleThread()
      .build();