From 14ab7462a35f95f6bbbce763f12faeb4f2945e22 Mon Sep 17 00:00:00 2001 From: James Moger <james.moger@gitblit.com> Date: Mon, 16 Jun 2014 09:21:31 -0400 Subject: [PATCH] Merge pull request #196 from giamma/release-v1.6.0 --- src/main/java/com/gitblit/fanout/FanoutServiceConnection.java | 18 +++++++++--------- 1 files changed, 9 insertions(+), 9 deletions(-) diff --git a/src/main/java/com/gitblit/fanout/FanoutServiceConnection.java b/src/main/java/com/gitblit/fanout/FanoutServiceConnection.java index f7f2c95..2515ab1 100644 --- a/src/main/java/com/gitblit/fanout/FanoutServiceConnection.java +++ b/src/main/java/com/gitblit/fanout/FanoutServiceConnection.java @@ -24,14 +24,14 @@ /** * FanoutServiceConnection handles reading/writing messages from a remote fanout * connection. - * + * * @author James Moger - * + * */ public abstract class FanoutServiceConnection implements Comparable<FanoutServiceConnection> { - + private static final Logger logger = LoggerFactory.getLogger(FanoutServiceConnection.class); - + public final String id; protected FanoutServiceConnection(Socket socket) { @@ -42,25 +42,25 @@ /** * Send the connection a debug channel connected message. - * + * * @param message */ protected void connected() { reply(FanoutConstants.CH_DEBUG, FanoutConstants.MSG_CONNECTED); } - + /** * Send the connection a debug channel busy message. - * + * * @param message */ protected void busy() { reply(FanoutConstants.CH_DEBUG, FanoutConstants.MSG_BUSY); } - + /** * Send the connection a message for the specified channel. - * + * * @param channel * @param message * @return the reply -- Gitblit v1.9.1