this.message = message;
}
+ @Override
public void readExternal(ObjectInput in) throws IOException,ClassNotFoundException {
reply = in.readBoolean();
int length = in.readInt();
message = (Serializable)in.readObject();
}
+ @Override
public void writeExternal(ObjectOutput out) throws IOException {
out.writeBoolean(reply);
out.writeInt(uuid.length);
public boolean addToQueue(ChannelMessage msg, Member[] destination, InterceptorPayload payload) {
final LinkObject obj = new LinkObject(msg,destination,payload);
Runnable r = new Runnable() {
+ @Override
public void run() {
sendAsyncData(obj);
}
super.stop(svc);
}
-
+
+ @Override
public void run() {
while ( run ) {
LinkObject link = removeFromQueue();
this.view = ((NonBlockingCoordinator)interceptor).view;
this.suggestedView = ((NonBlockingCoordinator)interceptor).suggestedView;
}
-
+
+ @Override
public int getEventType() {
return type;
}
-
+
+ @Override
public String getEventTypeDesc() {
switch (type) {
case EVT_START: return "EVT_START:"+info;
}
}
+ @Override
public ChannelInterceptor getInterceptor() {
return interceptor;
}