soundvibe / reacto Goto Github PK

EventHandlers and CommandHandlers should be publishing their performance metrics.
These metrics then could be pushed using Server Sent Events.

Rewrite VertxWebSocketEventHandler to handle backpressure.

This issue occurs because of Observable.create usage.

Extract vert.x implementation into separate module.
Refactor main reacto source code to support other possible implementations for service discovery, event handlers, command executors.

Implement service discovery with simple client load balancing.

Investigate possibility to implement typed commands and events.
Executing command could look like this:

ServiceRegistry services = new TypedReactoServiceRegistry(ServiceDiscovery.create(vertx), mapper);
MakeDemo command = new MakeDemo("Hello, World!");
services.execute(command, DemoMade.class)
    .subscribe((DemoMade demoMade) -> System.out.println(demoMade.name));

TypedReactoServiceRegistry should register type info of commands and their typed events to service discovery registry so executing incompatible commands should not be possible.

Registering commands could look like this:

CommandRegistry.ofTyped(
    MakeDemo.class, 
    DemoMade.class, 
    makeDemo -> Observable.just(new DemoMade(makeDemo.name)))
    .withMapper(mapper);

Consider adding support for Reactive Streams API instead of directly coupling to rxJava Observables.

Consider implementing new communication method in addition to websockets. One of the simplest solutions could be using something similar to Webhooks.

Flow could be something like this:

1. Command invoked
2. Initial POST request (which contains given command and webhooksUrl where events should be pushed) is sent to the command handler
3. Command handler receives command and executes it
4. Each onNext, OnError or OnCompleted events send POST requests with given event data to registered webhooksUrl.

Some thoughts:

• Do we send the data in json format (preferred way when using Restful services) or just use protocol buffers?

Add code examples on how to use the library to the wiki.