INNER CODE UNIT · Java

getDefaultQSize

RuedigerMoeller/kontraktor · attic/ElasticScheduler.java:68

    public int getDefaultQSize() {
        return defQSize;
    }

//    @Override
    public IPromise put2QueuePolling(CallEntry e) {
        final IPromise fut;
        if (e.hasFutureResult() && ! (e.getFutureCB() instanceof CallbackWrapper) ) {
            fut = new Promise();
            e.setFutureCB(new CallbackWrapper( e.getSendingActor() ,new Callback() {
                @Override
                public void complete(Object result, Object error) {
                    fut.complete(result, error);
                }
            }));
        } else
            fut = null;
        Actor targetActor = e.getTargetActor();

View source record →