Ensuring lossless queues using sessions