[Doc] QBit microservice Java lib Using auto flushing client proxies

Richard Hightower edited this page Feb 24, 2015 · 1 revision

Mostly we show you how to flush method calls for microbatching. At times it is convenient to periodically flush method calls just in case you are not under high loads.

Instead of having you create a lot of boiler plate code, we provide a SendQueue that is auto-flushing. Then we also provide the ability to create service queue proxies that are also auto-flushing.

        ServiceQueue serviceQueue = ...

        TodoServiceClient todoServiceClient = 
                                               50, TimeUnit.MILLISECONDS);

        todoServiceClient.add(new TodoItem("foo", "foo", null));

        AtomicReference<List<TodoItem>> items = new AtomicReference<>();
        todoServiceClient.list(new Callback<List<TodoItem>>() {
            public void accept(List<TodoItem> todoItems) {

The new method is createProxyWithAutoFlush. There are two versions of createProxyWithAutoFlush. One that takes a PeriodicScheduler and one that does not take a PeriodicScheduler.

You can pass your own PeriodicScheduler or you can use the system one.

public interface PeriodicScheduler extends Startable, Stoppable{

    ScheduledFuture repeat(Runnable runnable, int interval, TimeUnit timeUnit);

    default void start() {}
    default void stop() {}





Getting Started




Callbacks and Reactor

Event Bus



QBit case studies

QBit 2 Roadmap

-- Related Projects

Kafka training, Kafka consulting, Cassandra training, Cassandra consulting, Spark training, Spark consulting

Clone this wiki locally
You can’t perform that action at this time.
You signed in with another tab or window. Reload to refresh your session. You signed out in another tab or window. Reload to refresh your session.
Press h to open a hovercard with more details.