|
1
51
52 package org.omg.CosActivity;
53
54 import javax.activity.ActivityCoordinator  ;
55 import javax.activity.CompletionStatus ;
56 import javax.activity.CoordinationInformation ;
57 import javax.activity.Outcome ;
58 import javax.activity.Signal ;
59 import javax.activity.SignalSetActiveException ;
60 import javax.activity.SignalSetInactiveException ;
61 import javax.activity.coordination.SignalSet;
62
63 public class Synchronization implements SignalSet {
64
65 public static final String SYNCHRONIZATION_SS_NAME =
67 "org.omg.CosActivity.Synchronization";
68
69
71 private String signalSetName;
72
73 private Signal signal;
74
75 private ActivityCoordinator ac;
76
77 private int completionStatus;
78
79 private int status;
80
81 private Outcome outcome;
82
83 private boolean started;
84
85
87 public Synchronization(String signalSetName) {
88 this.signalSetName = signalSetName;
89 this.outcome = null;
90 this.started = false;
91 }
92
93
95
97 public java.lang.String getSignalSetName() {
98 return this.signalSetName;
99 }
100
101 public Signal getSignal() {
102
103 Signal signal = null;
104 started = true;
105
106 if (this.completionStatus == CompletionStatus.CompletionStatusSuccess) {
107
108 signal =
109 new Signal (
110 "preCompletion",
111 this.signalSetName,
112 (java.io.Serializable ) null);
113
114 }
115 return signal;
116 }
117
118 public CoordinationInformation setResponse(Outcome response)
119 throws SignalSetInactiveException {
120
121 if (!started)
122 throw new SignalSetInactiveException ();
123
124 CoordinationInformation info = null;
125 if (response.getName().equals("preCompletitionSuccess")) {
126 info = new CoordinationInformation (false, false);
127 }
128
129 if (response.getName().equals("preCompletitionFailed")) {
130 info = new CoordinationInformation (false, false);
131 }
132 return info;
133 }
134
135 public Outcome getOutcome() throws SignalSetActiveException {
136 return this.outcome;
137 }
138
139 public void setCompletionStatus(int completionStatus, int status) {
140 this.completionStatus = completionStatus;
141 this.status = status;
142 }
143
144 public int getCompletionStatus() throws SignalSetActiveException {
145 return this.completionStatus;
146 }
147
148 public void setActivityCoordinator(ActivityCoordinator coord)
149 throws SignalSetActiveException {
150 this.ac = coord;
151 }
152
153 public void destroy() {
154
155 }
156 }
157 |
Popular Tags |
Java API By Example, From Geeks To Geeks.