From b4d9581961d219f6a8fbfd0e391b39d7e45e8e10 Mon Sep 17 00:00:00 2001 From: Vitaliy Filippov <vitalif@yourcmc.ru> Date: Thu, 01 Oct 2015 06:10:51 -0400 Subject: [PATCH] Add "all repositories" parameter --- 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