diff rep/handler/Forwarder.java @ 450:21cb16b7f3df

block message in Editor.write()
author one
date Thu, 23 Sep 2010 18:15:37 +0900
parents 1bb59652d89c
children c83af820eb62
line wrap: on
line diff
--- a/rep/handler/Forwarder.java	Wed Sep 22 22:11:58 2010 +0900
+++ b/rep/handler/Forwarder.java	Thu Sep 23 18:15:37 2010 +0900
@@ -42,7 +42,7 @@
 		assert(command!=null);
 		assert(channel!=null);
 		REPCommand c = new REPCommand(command);
-		manager.addWriteQueue(new PacketSet(channel,null,  c));
+		manager.addWriteQueue(new PacketSet(this, c));
 	}
 	
 	public void sendWithSeq(REPCommand command) {
@@ -50,7 +50,7 @@
 		assert(channel!=null);
 		REPCommand c = new REPCommand(command);
 		c.setSEQID(seq());
-		manager.addWriteQueue(new PacketSet(channel,null,  c));
+		manager.addWriteQueue(new PacketSet(this, c));
 	}
 	
 	public REPSocketChannel<REPCommand> getChannel() {
@@ -151,6 +151,11 @@
 		return null;
 	}
 
+	@Override
+	public void write(REPCommand command) {
+		channel.write(command);		
+	}
+