613b459c52
When calling a consumer to receive message with a timeout (receive(long timeout), if the consumer's buffer is empty, it sends a 'forced delivery' the waiting forever, expecting the server to send back a 'forced delivery" message if the queue is empty. If the connection is disconnected as the arrived 'forced delivery' message is corrupted, this 'forced delivery' message never gets to consumer. After the session is reconnected, the consumer never knows that and stays waiting. To fix that we can send a 'forced delivery' to server right after the session is reconnected. |
||
|---|---|---|
| .. | ||
| src/test | ||
| pom.xml | ||