Mercurial > hg > Members > nobuyasu > jungle-network
annotate src/main/java/alice/jungle/persistent/PersistentChangeListWriter.java @ 135:2e8034524259
Added NetworkJournal and SingletonMessageFromAlice class
author | Nobuyasu Oshiro <dimolto@cr.ie.u-ryukyu.ac.jp> |
---|---|
date | Sun, 12 Jan 2014 06:18:37 +0900 |
parents | 895ab2907db3 |
children |
rev | line source |
---|---|
105 | 1 package alice.jungle.persistent; |
85 | 2 |
3 import java.io.IOException; | |
4 import java.io.OutputStream; | |
5 | |
105 | 6 import alice.jungle.operations.NetworkTreeOperationLog; |
7 | |
85 | 8 import org.msgpack.MessagePack; |
9 | |
10 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeList; | |
11 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeListWriter; | |
12 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.Result; | |
13 | |
14 public class PersistentChangeListWriter implements ChangeListWriter { | |
15 | |
135
2e8034524259
Added NetworkJournal and SingletonMessageFromAlice class
Nobuyasu Oshiro <dimolto@cr.ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
16 MessagePack msgpack = SingletonMessageFromAlice.getInstance(); |
85 | 17 OutputStream out; |
18 | |
19 public PersistentChangeListWriter(OutputStream _out) { | |
20 out = _out; | |
21 } | |
22 | |
23 @Override | |
88 | 24 public Result write(ChangeList cs) |
85 | 25 { |
88 | 26 NetworkTreeOperationLog log = new NetworkTreeOperationLog(cs.uuid(), cs.getTreeName(), cs); |
85 | 27 try { |
28 msgpack.write(out, log); | |
29 out.flush(); | |
87 | 30 return Result.SUCCESS; |
85 | 31 } catch (IOException e) { |
116 | 32 |
85 | 33 } |
87 | 34 return null; |
85 | 35 } |
36 } |