Skip to content
Snippets Groups Projects
Commit db9f4193 authored by bontric's avatar bontric
Browse files

cleanup

parent 213a3bfd
No related branches found
No related tags found
No related merge requests found
......@@ -50,8 +50,7 @@ public interface MailboxMessage {
* match responses to a request.
* <p>
* (NOTE: This identifier is only unique for "active" requests, which
* wer sent and await a response. Replay protection must be provided by the
* underlying protocol!)
* have benn sent and await a response)
*/
long getId();
......
......@@ -67,7 +67,7 @@ public class MailboxProtocol implements Runnable {
public void writeRequest(MailboxRequest req)
throws InterruptedException, IOException {
if (req.hasResponse())
pendingRequests.put(req.getId(), (MailboxRequest) req);
pendingRequests.put(req.getId(), req);
writeMailboxMessage(req);
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment