Mercurial > hg > RemoteEditor > REPSessionManager
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); + } +