class TextDelay implements Runnable
{
+ enum LinkType
+ {
+ SPLIT,
+ RELINK,
+ UNKNOWN
+ }
+
public static final int delay = 5;
@Inject
}
for (String email : conf.split_emails)
- mail.send(email, "Split", buf);
-
- servermonitor.texts = null;
+ {
+ switch (this.type)
+ {
+ case SPLIT:
+ mail.send(email, "Split", buf);
+ servermonitor.splitTexts = null;
+ break;
+ case RELINK:
+ mail.send(email, "Relink", buf);
+ servermonitor.linkTexts = null;
+ break;
+ default:
+ break;
+ }
+ }
}
protected LinkedList<String> messages = new LinkedList<String>();
-}
\ No newline at end of file
+ protected LinkType type = LinkType.UNKNOWN;
+}
package net.rizon.moo.plugin.servermonitor;
-import net.rizon.moo.plugin.servermonitor.server.CommandServer;
import com.google.common.eventbus.Subscribe;
import com.google.inject.multibindings.Multibinder;
import io.netty.util.concurrent.ScheduledFuture;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
import javax.inject.Inject;
-
import net.rizon.moo.Command;
import net.rizon.moo.Moo;
import net.rizon.moo.Plugin;
import net.rizon.moo.irc.Server;
import net.rizon.moo.irc.ServerManager;
import net.rizon.moo.plugin.servermonitor.conf.ServerMonitorConfiguration;
+import net.rizon.moo.plugin.servermonitor.server.CommandServer;
import org.slf4j.Logger;
class Requester implements Runnable
private ScheduledFuture requester;
private ServerMonitorConfiguration conf;
-
- protected TextDelay texts;
+
+ protected TextDelay splitTexts;
+ protected TextDelay linkTexts;
public servermonitor() throws Exception
{
}
if (!pypsd)
{
- if (texts == null)
+ if (linkTexts == null)
{
- texts = new TextDelay();
- Moo.injector.injectMembers(texts);
- Moo.schedule(texts, TextDelay.delay, TimeUnit.SECONDS);
+ linkTexts = new TextDelay();
+ linkTexts.type = TextDelay.LinkType.RELINK;
+ Moo.injector.injectMembers(linkTexts);
+ Moo.schedule(linkTexts, TextDelay.delay, TimeUnit.SECONDS);
}
- texts.messages.add(serv.getName() + " introduced by " + to.getName());
+ linkTexts.messages.add(serv.getName() + " introduced by " + to.getName());
}
}
if (!pypsd)
{
- if (texts == null)
+ if (splitTexts == null)
{
- texts = new TextDelay();
- Moo.injector.injectMembers(texts);
- Moo.schedule(texts, TextDelay.delay, TimeUnit.SECONDS);
+ splitTexts = new TextDelay();
+ splitTexts.type = TextDelay.LinkType.SPLIT;
+ Moo.injector.injectMembers(splitTexts);
+ Moo.schedule(splitTexts, TextDelay.delay, TimeUnit.SECONDS);
}
- texts.messages.add(serv.getName() + " split from " + from.getName());
+ splitTexts.messages.add(serv.getName() + " split from " + from.getName());
}
if (conf.reconnect && !serv.isServices())