diff options
Diffstat (limited to 'src/main/java/com/gitblit/fanout/FanoutServiceConnection.java')
-rw-r--r-- | 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 f7f2c959..2515ab1d 100644 --- a/src/main/java/com/gitblit/fanout/FanoutServiceConnection.java +++ b/src/main/java/com/gitblit/fanout/FanoutServiceConnection.java @@ -24,14 +24,14 @@ import org.slf4j.LoggerFactory; /**
* 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 @@ public abstract class FanoutServiceConnection implements Comparable<FanoutServic /**
* 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
|