aeronic

Usage:

repositories {
    mavenCentral()
    maven {
        setUrl("https://dl.cloudsmith.io/public/lob-software/aeronic/maven/")
    }
}

dependencies {
    annotationProcessor("io.aeronic:aeronic:0.0.16")
    implementation("io.aeronic:aeronic:0.0.16")
}

Quickstart

Aeronic allows for flexible usage of Aeron by way of proxy generation for subscriptions and publications. Use @Aeronic to make the compiler generate subscriber and publisher proxies:

@Aeronic
public interface TradeEvents
{
    void onTrade(long price);
}

A subscriber, containing business logic can then be defined by implementing the interface:

public class TradeEventsImpl implements TradeEvents
{

    private long lastPrice;

    @Override
    public void onTrade(final long price)
    {
        this.lastPrice = price;
    }

    public long getLastPrice()
    {
        return lastPrice;
    }
}

AeronicWizard can then be used to create a publisher of type TradeEvents and bind a subscriber implemented above. The two will communicate via a given Aeron channel / stream ID:

final Aeron aeron = Aeron.connect(aeronCtx);
final AeronicImpl aeronic = new AeronicImpl(aeron);

final TradeEvents eventsPublisher = aeronic.createPublisher(TradeEvents.class, "aeron:ipc", 10);
final TradeEventsImpl subscriberImpl = new TradeEventsImpl();
aeronic.registerSubscriber(TradeEvents.class, subscriberImpl, "aeron:ipc", 10);

publisher.onTrade(123L);
subscriberImpl.getLastPrice(); // 123L