1 46 50 package org.mr.core.util; 51 52 57 public class StageParams { 58 61 private String stageName; 62 65 private boolean persistent = false; 66 69 private boolean blocking = false; 70 73 private int numberOfStartThreads = 1; 74 77 private int maxNumberOfThreads = 10; 78 81 private StageHandler handler; 82 83 84 private int stagePriority =0; 85 88 public boolean isBlocking() { 89 return blocking; 90 } 91 92 95 public void setBlocking(boolean blocking) { 96 this.blocking = blocking; 97 } 98 99 102 public int getMaxNumberOfThreads() { 103 return maxNumberOfThreads; 104 } 105 106 109 public void setMaxNumberOfThreads(int maxNumberOfThreads) { 110 this.maxNumberOfThreads = maxNumberOfThreads; 111 } 112 113 116 public int getNumberOfStartThreads() { 117 return numberOfStartThreads; 118 } 119 120 123 public void setNumberOfStartThreads(int numberOfStartThreads) { 124 this.numberOfStartThreads = numberOfStartThreads; 125 } 126 127 130 public boolean isPersistent() { 131 return persistent; 132 } 133 134 137 public void setPersistent(boolean persistent) { 138 this.persistent = persistent; 139 } 140 141 144 public String getStageName() { 145 return stageName; 146 } 147 148 151 public void setStageName(String stageName) { 152 this.stageName = stageName; 153 } 154 155 158 public StageHandler getHandler() { 159 return handler; 160 } 161 162 165 public void setHandler(StageHandler handler) { 166 this.handler = handler; 167 } 168 169 172 public int getStagePriority() { 173 return stagePriority; 174 } 175 176 179 public void setStagePriority(int stagePriority) { 180 if(stagePriority >5 || stagePriority < -4) 181 throw new IllegalArgumentException ("invalid priorety "+stagePriority+": (5> priorety <-4)"); 182 this.stagePriority = stagePriority; 183 } 184 185 } 186 | Popular Tags |