work method hasn't been called:
for (int i = 0; i < 1000; i++)
{
if (numberCount >= messagesCap)
{
transport.handle(transport.command(connectionId, CloseConnection.class));
return;
}
SendMessage sendMessage = transport.command(connectionId, SendMessage.class);
sendMessage.prepare().putLong(sendMessage.offset(), numberCount);
sendMessage.commit(8);
transport.handle(sendMessage);
// transport.work();
numberCount++;
}
work method hasn't been called: