Integer ibusy = (Integer) mBeanServer.getAttribute(objName, "currentThreadsBusy");
busy = ibusy.intValue();
- ready = imax.intValue() - ibusy;
+ ready = imax.intValue() - ibusy.intValue();
}
}
private Sender sender = null;
+ @Override
public void containerEvent(ContainerEvent event) {
}
+ @Override
public void lifecycleEvent(LifecycleEvent event) {
if (Lifecycle.PERIODIC_EVENT.equals(event.getType())) {
MulticastSocket s = null;
InetAddress group = null;
+ @Override
public void init(HeartbeatListener config) throws Exception {
this.config = config;
}
+ @Override
public int send(String mess) throws Exception {
if (s == null) {
try {
*/
public class Proxy {
- protected enum State { OK, ERROR, DOWN };
+ protected enum State { OK, ERROR, DOWN }
public InetAddress address = null;
public int port = 80;
protected BufferedWriter[] connectionWriters = null;
+ @Override
public void init(HeartbeatListener config) throws Exception {
this.config = config;
StringTokenizer tok = new StringTokenizer(config.getProxyList(), ",");
}
+ @Override
public int send(String mess) throws Exception {
if (connections == null) {
log.error("Not initialized");