twitch: fix race in connect establishing multiple connections
This commit is contained in:
@@ -96,7 +96,7 @@ public class TwitchPlugin extends Plugin implements TwitchListener, ChatboxInput
|
||||
return configManager.getConfig(TwitchConfig.class);
|
||||
}
|
||||
|
||||
private void connect()
|
||||
private synchronized void connect()
|
||||
{
|
||||
if (twitchConfig.username() != null
|
||||
&& twitchConfig.oauthToken() != null
|
||||
@@ -108,6 +108,13 @@ public class TwitchPlugin extends Plugin implements TwitchListener, ChatboxInput
|
||||
channel = "#" + channel;
|
||||
}
|
||||
|
||||
log.debug("Connecting to Twitch as {}", twitchConfig.username());
|
||||
|
||||
if (twitchIRCClient != null)
|
||||
{
|
||||
twitchIRCClient.close();
|
||||
}
|
||||
|
||||
twitchIRCClient = new TwitchIRCClient(
|
||||
this,
|
||||
twitchConfig.username(),
|
||||
@@ -145,12 +152,6 @@ public class TwitchPlugin extends Plugin implements TwitchListener, ChatboxInput
|
||||
return;
|
||||
}
|
||||
|
||||
if (twitchIRCClient != null)
|
||||
{
|
||||
twitchIRCClient.close();
|
||||
twitchIRCClient = null;
|
||||
}
|
||||
|
||||
connect();
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user