Skip to content

Commit

Permalink
Refactored process management, implemented process restart.
Browse files Browse the repository at this point in the history
  • Loading branch information
nmihajlovski committed Jan 29, 2017
1 parent 77c4f21 commit 7c238ac
Show file tree
Hide file tree
Showing 7 changed files with 184 additions and 95 deletions.
@@ -0,0 +1,11 @@
package org.rapidoid.group;

import org.rapidoid.RapidoidThing;
import org.rapidoid.annotation.Authors;
import org.rapidoid.annotation.Since;

@Authors("Nikolche Mihajlovski")
@Since("5.3.0")
public abstract class AbstractManageable extends RapidoidThing implements Manageable {

}
23 changes: 16 additions & 7 deletions rapidoid-commons/src/main/java/org/rapidoid/group/GroupOf.java
Expand Up @@ -99,6 +99,22 @@ public E get(int index) {
return items.get(index);
}

public E get(String id) {
E item = find(id);
U.must(item != null, "Cannot find item with id='%s'!", id);
return item;
}

public E find(String id) {
U.notNull(id, "id");

for (E item : items) {
if (U.eq(id, item.id())) return item;
}

return null;
}

public E remove(int index) {
return items.remove(index);
}
Expand Down Expand Up @@ -160,11 +176,4 @@ public int hashCode() {
return result;
}

public E find(String id) {
for (E item : items) {
if (U.eq(item.id(), id)) return item;
}
return null;
}

}
4 changes: 4 additions & 0 deletions rapidoid-commons/src/main/java/org/rapidoid/process/Proc.java
Expand Up @@ -46,6 +46,10 @@ public static ProcessParams group(Processes group) {
return new ProcessParams().group(group);
}

public static ProcessParams id(String id) {
return new ProcessParams().id(id);
}

public ProcessParams printingOutput(boolean printingOutput) {
return new ProcessParams().printingOutput(printingOutput);
}
Expand Down

0 comments on commit 7c238ac

Please sign in to comment.