-
Notifications
You must be signed in to change notification settings - Fork 5
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Asynchronous client using rlp_03 provided methods #113 #117
Conversation
FIXME executorService.shutdown(); |
…arameter for ServerFactory
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Added some comments
connectionContext.handleEvent(selectionKey); | ||
} | ||
catch (CancelledKeyException cke) { | ||
LOGGER.warn("SocketPoll.poll CancelledKeyException caught: {}", cke.getMessage()); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
<{}>
format
selector.close(); | ||
} | ||
catch (IOException ioException) { | ||
LOGGER.warn("selector close threw", ioException); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Clean up a bit
} | ||
catch (CancelledKeyException cke) { | ||
// thrown by accessing cancelled SelectionKey | ||
LOGGER.warn("SocketPoll.poll CancelledKeyException caught: {}", cke.getMessage()); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
<{}>
format
int txn = txnCounter.incrementAndGet(); | ||
relpFrameTX.setTransactionNumber(txn); | ||
if (transactions.containsKey(txn)) { | ||
throw new IllegalStateException("already pending txn <" + txn + ">"); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Cleanup this a bit, at least start with capital letter
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
No description provided.