- sendMessage(message);
- }
- }
-
- private void sendMessage(final String message) {
- try {
- output.write(new OutboundEvent.Builder().data(String.class, message).build());
- } catch (IOException e) {
- LOG.warn("Connection from client {} is closed", this);
- LOG.debug("Connection from client is closed:", e);
- }
- }
-
- private void sendComment(final String message) {
- try {
- output.write(new OutboundEvent.Builder().comment(message).build());
- } catch (IOException e) {
- LOG.warn("Connection from client {} is closed", this);
- LOG.debug("Connection from client is closed:", e);