listener: fix message queueing of last rework
This commit is contained in:
parent
73f2b2c2dd
commit
50473764c8
|
@ -54,11 +54,11 @@ namespace SparkleLib {
|
||||||
|
|
||||||
private void AnnounceBase (string message) {
|
private void AnnounceBase (string message) {
|
||||||
if (IsConnected) {
|
if (IsConnected) {
|
||||||
SparkleHelpers.DebugInfo ("Listener", "Announcing to " + this.channel + " on " + this.server);
|
SparkleHelpers.DebugInfo ("Listener", "Announcing to " + this.channel + " on " + this.server);
|
||||||
Announce (message);
|
Announce (message);
|
||||||
} else {
|
} else {
|
||||||
SparkleHelpers.DebugInfo ("Listener", "Not connected. Queuing message");
|
SparkleHelpers.DebugInfo ("Listener", "Not connected. Queuing message");
|
||||||
this.announce_queue.Add (message);
|
this.announce_queue.Add (message);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -105,7 +105,7 @@ namespace SparkleLib {
|
||||||
this.announce_queue = new List<string> ();
|
this.announce_queue = new List<string> ();
|
||||||
|
|
||||||
SparkleHelpers.DebugInfo ("Listener", "Delivering queued messages...");
|
SparkleHelpers.DebugInfo ("Listener", "Delivering queued messages...");
|
||||||
Announce (message);
|
AnnounceBase (message);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue