Aloha

Aloha is a message bus facade written in Java. You can simply extend it to implement your own facade.

Of course, like any other libraries, some built-in message bus facade are included in the extension package which are listed below.

Aloha Spring

An aloha extension package provides easy integration with spring boot. For now we provide two kinds of message buses listed below.

1. LocalSpringMessageBus

LocalSpringMessageBus is just a wrapper of Spring's ApplicationEventPublisher. You can easily post a Spring event through the interface.

Usage

LocalSpringMessageBus bus = new LocalSpringMessageBus(this.applicationContext);
bus.register(subscriber);
bus.publish(new SomeEvent());
bus.start();

2. RedisMessageBus

RedisMessageBus is based on redis template, so make sure that you've imported spring-boot-starter-data-redis lib to your project.

Usage

RedisMessageBus bus = new RedisMessageBus(this.applicationContext);
bus.register(subscriber);
bus.produce(new SomeEvent());
bus.start();

3. Subscriber/Consumer

Besides, we also need some subscribers/consumers to listen to channels so that we can subscribe/consume messages from local or remote message buses.

Usage

@Executor(maxCount = 2)
@Subscribe
public void onMessage(Message message) {
    //handle message
}

@Executor(maxCount = 2)
@Consume
public void onMessage(Message message) {
    //handle message
}

The @Executor annotation is optional. When you use it, aloha will create muitl threads to handle your message.