LMig2k

timeout parameter doesn't work in DisqueJobCommands.getjobs method

2

biz.paluch.spinach.api.sync.DisqueJobCommands.getjobs(long **timeout**, TimeUnit timeUnit, long count, String... queues) -> biz.paluch.spinach.impl.FutureSyncInvocationHandler.handleInvocation(Object proxy, Method method, Object[] args) { LettuceFutures.await(command,connection.**getTimeout()**, connection.getTimeoutUnit());

This is the steps i took. 1. Start disque-server with one node only. 2. Adding 10000 jobs with RETRY 300 seconds to the que_0 one by one in a single...