tailer7

A scalable tailer powered by Redis.

Installation

Maven

<dependency>
  <groupId>com.mayreh</groupId>
  <artifactId>tailer7</artifactId>
  <version>0.1.1</version>
</dependency>

Gradle

compile 'com.mayreh:tailer7:0.1.1'

Usage

See also Example.

LogSender

RedisClient client = RedisClient.create(RedisURI.create("127.0.0.1", 6379));
LogSender sender = new LogSender(client, LogSenderConfig.builder().build());

sender.open();
sender.send("foo", "seeeeeeennnnnnnd");

LogTailer

RedisClient client = RedisClient.create(RedisURI.create("127.0.0.1", 6379));
LogTailer tailer = new LogTailer(
        client,
        LogTailerConfig.builder().build(),
        log -> System.out.println(log.getLine()));

tailer.subscribe("foo");
// => will output "seeeeeeennnnnnnd"