While using https://github.com/mrniko/netty-socketio I'm using a queue and a thread pool to process the received data (sorry about the formatting stackoverflow is complaining about spaces when I put the code on different lines):
server.addEventListener("NEW_SELL_ORDER", SellOrder.class, (client, data, ackSender) -> actionQueue.add((connection) -> this.onNewSellOrder(connection, client, data, ackSender)));
The problem is that ackSender
isn't usable anymore because the threadpool is processing the request a split second later.
Resulting in the question: is it possible to delay sending an ack in netty's socket.io implementation?