Go/Ocean
Go/Ocean
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Improved the ICCC

Browse Source
This commit is contained in:
Thorsten Sommer 2015-06-21 10:29:49 +02:00
parent 6f58346f57
commit dcc1af2a23
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
ICCC/WriteMessage2Any.go
View File

@ -34,10 +34,11 @@ func WriteMessage2Any(channel, command string, message interface{}) {
// Case: Find at least one possible listener. Choose a random one and deliver: // Case: Find at least one possible listener. Choose a random one and deliver:
if len(entries) == 1 { if len(entries) == 1 {
listener := entries[0] listener := entries[0]
go sendMessage(listener, data)
} else { } else {
listener := entries[Tools.RandomInteger(count)] listener := entries[Tools.RandomInteger(count)]
go sendMessage(listener, data)
} }
go sendMessage(listener, data)
} else { } else {
// Case: Find no listener at all. // Case: Find no listener at all.
Log.LogFull(senderName, LM.CategorySYSTEM, LM.LevelWARN, LM.SeverityCritical, LM.ImpactUnknown, LM.MessageNameCONFIGURATION, `It was not able to deliver this message to any listener, because no listener was found!`, `channel=`+channel, `command=`+command) Log.LogFull(senderName, LM.CategorySYSTEM, LM.LevelWARN, LM.SeverityCritical, LM.ImpactUnknown, LM.MessageNameCONFIGURATION, `It was not able to deliver this message to any listener, because no listener was found!`, `channel=`+channel, `command=`+command)