Fix bye reply

dgomezferro · Oct 22, 2012 · ea2342d · ea2342d
1 parent db22ed3
commit ea2342d
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/main/java/com/yahoo/pasc/paxos/server/tcp/TcpServer.java b/src/main/java/com/yahoo/pasc/paxos/server/tcp/TcpServer.java
@@ -221,7 +221,9 @@ public void addClient(int clientId, Channel channel) {
         if (clientChannels.containsKey(clientId)) {
             Bye bye = new Bye(clientId, id);
             bye.storeReplica(bye);
-            forward(Arrays.<Message> asList(bye));
+            embedder.offer(bye);
+            ChannelBuffer encoded = embedder.poll();
+            channel.write(encoded);
         } else {
             LOG.debug("Adding client " + clientId + " " + channel);
             clientChannels.put(clientId, channel);