advantageous / qbit

The Java microservice lib. QBit is a reactive programming lib for building microservices - JSON, HTTP, WebSocket, and REST. QBit uses reactive programming to build elastic REST, and WebSockets based cloud friendly, web services. SOA evolved for mobile and cloud. ServiceDiscovery, Health, reactive StatService, events, Java idiomatic reactive programming for Microservices.
http://advantageous.github.io/qbit/
Apache License 2.0
709 stars 140 forks source link

EMPTY should only get called once while IDLE should get called many times #725

Open RichardHightower opened 8 years ago

RichardHightower commented 8 years ago

    @QueueCallback({QueueCallbackType.LIMIT})
    public void process1() {
        System.out.println("PROCESS LIMIT");
        flushServiceProxy(auditor);
    }

    @QueueCallback({QueueCallbackType.EMPTY})
    public void process2() {
        System.out.println("PROCESS EMPTY");
        flushServiceProxy(auditor);
    }

    @QueueCallback({QueueCallbackType.IDLE})
    public void process3() {
        System.out.println("PROCESS IDLE");
        flushServiceProxy(auditor);
    }

PROCESS EMPTY PROCESS EMPTY PROCESS IDLE PROCESS EMPTY PROCESS IDLE PROCESS EMPTY PROCESS IDLE PROCESS EMPTY operations add, message added new todo log PROCESS EMPTY PROCESS IDLE PROCESS EMPTY PROCESS IDLE PROCESS EMPTY PROCESS IDLE PROCESS EMPTY operations list, message auditor added log PROCESS EMPTY PROCESS IDLE PROCESS EMPTY PROCESS IDLE PROCESS EMPTY PROCESS IDLE operations add, message removed new todo log PROCESS EMPTY operations list, message auditor added log PROCESS IDLE PROCESS EMPTY PROCESS IDLE PROCESS EMPTY PROCESS EMPTY PROCESS EMPTY PROCESS IDLE PROCESS EMPTY PROCESS IDLE PROCESS EMPTY PROCESS IDLE PROCESS EMPTY PROCESS IDLE operations add, message added new todo log PROCESS EMPTY operations add, message added new todo log operations add, message added new todo log PROCESS IDLE PROCESS EMPTY PROCESS IDLE PROCESS EMPTY