Event Stream

Overview

Library to abstract publish and subscribe implementation in an event-based arquitecture.

Requisites

• Java 8+
• Maven 3+

Install

Gradle

    dependencies {
        compile 'com.github.malkomich:event-stream:1.0.2'
    }

Maven

    <dependency>
        <groupId>com.github.malkomich</groupId>
        <artifactId>event-stream</artifactId>
        <version>1.0.2</version>
    </dependency>

Usage

INITIALIZATION:

final KafkaConfig config = KafkaConfig.builder()
    .server("localhost:9092")
    .groupId("groupId")
    .build();

final EventService eventService = EventComponent.builder()
    .vertx(vertx)
    .kafkaConfig(config)
    .build();

PUBLISH:

final EventTopic topic = BetchainTopic.QUOTE; // You can build your own EventTopic implementation

final PublishRequest request = PublishRequest.builder()
    .topic(topic)
    .message(data.toJson())
    .build();

eventService.publish(request, onEventPublished -> {
    if (onEventPublished.succeeded()) {
        future.complete();
    } else {
        future.fail(onEventPublished.cause());
    }
});

SUBSCRIBE:

final EventTopic topic = BetchainTopic.QUOTE; // You can build your own EventTopic implementation

final SubscribeRequest request = SubscribeRequest.builder()
    .topic(topic)
    .handler(onEventReceived ->
            scrappingRepository.execute(onEventReceived.value(), Future.future()))
    .build();

eventService.subscribe(request, onSubscribed -> {
    if (onSubscribed.succeeded()) {
        handler.handle(Future.succeededFuture());
    } else {
        handler.handle(Future.failedFuture(onSubscribed.cause()));
    }
});

License

Apache License