RSocket AsyncAPI

Analyzes the RSocket controller and MessageMapping route to generate AsyncAPI 2.6.0 JSON.

Endpoint to analyze

CourtCaseRSocketController.java

java

@Controller
public class CourtCaseRSocketController {

  @MessageMapping("court-case.detail.stream")
  public Flux<CourtCaseDetailEvent> stream(CourtCaseDetailRequest request) {
    return service.stream(request);
  }
}

Watcher settings

java

var asyncConfig = RsoketAsyncApiJsonFileWatcher.Config.builder()
    .watchDirectory("src/main/java")
    .asyncApiOutputFile("src/main/resources/static/asyncapi-rsocket.json")
    .build();

watchDirectory

default source root

asyncApiOutputFile

default static asyncapi-rsocket.json

Current class name

Use the spelling Rsoket as is

The current public class is declared as Rsoket instead of Rsocket, like RsoketAsyncApiJsonFileWatcher. The documentation examples also maintain the actual importable names.

Frontend generator connection

The generated AsyncAPI JSON can be used as input for the @byeolnaerim/typed-rx-http/auto-node-script/asyncapi generator to create route request/response types and RSocket service functions.