James Moger
2013-09-30 699e71e76b15081baf746c6ce9c9144f7e5f1ff9
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