|
478
|
1 package alice.topology.node;
|
|
|
2
|
|
|
3 import alice.codesegment.CodeSegment;
|
|
|
4 import alice.datasegment.CommandType;
|
|
|
5 import alice.datasegment.DataSegment;
|
|
|
6 import alice.datasegment.Receiver;
|
|
|
7
|
|
|
8 public class ReceiveCloseMessage extends CodeSegment {
|
|
|
9
|
|
|
10 private Receiver info = ids.create(CommandType.TAKE);
|
|
|
11
|
|
|
12 public ReceiveCloseMessage() {
|
|
|
13 info.setKey("_CLOSEMESSEAGE");
|
|
|
14 }
|
|
|
15
|
|
|
16 @Override
|
|
|
17 public void run() {
|
|
|
18 String managerKey = info.asString();
|
|
483
|
19 if (DataSegment.contains(managerKey)) {
|
|
|
20 DataSegment.get(managerKey).setSendError(false);
|
|
|
21 DataSegment.get(managerKey).shutdown();
|
|
|
22 } else {
|
|
|
23
|
|
|
24 }
|
|
|
25
|
|
|
26
|
|
478
|
27 new ReceiveCloseMessage();
|
|
|
28 }
|
|
|
29
|
|
|
30 }
|
