Ocean/ICCC/Registrar.go

package ICCC

import (
	"fmt"
	"github.com/SommerEngineering/Ocean/Log"
	LM "github.com/SommerEngineering/Ocean/Log/Meta"
)

func Registrar(channel, command string, callback func(data map[string][]string)) {
	listenersLock.Lock()
	defer listenersLock.Unlock()

	register2Database(channel, command)
	listeners[fmt.Sprintf(`%s::%s`, channel, command)] = callback

	Log.LogShort(senderName, LM.CategorySYSTEM, LM.LevelINFO, LM.MessageNameCONFIGURATION, `The registrar has registered a new ICCC command.`, `channel=`+channel, `command=`+command)
}
Initial commit of Ocean's local development 2014-04-26 09:18:56 +00:00			`package ICCC`

Refactoring, Bugfix & Updates + Refactored all imports + Fixed a bug for the logging regarding removing \n \t \r + Updated to current MGO release + Changed the name of ICCC 2014-10-19 17:19:11 +00:00			`import (`
			`"fmt"`
			`"github.com/SommerEngineering/Ocean/Log"`
			`LM "github.com/SommerEngineering/Ocean/Log/Meta"`
			`)`
Initial commit of Ocean's local development 2014-04-26 09:18:56 +00:00
			`func Registrar(channel, command string, callback func(data map[string][]string)) {`
			`listenersLock.Lock()`
			`defer listenersLock.Unlock()`

			`register2Database(channel, command)`
			listeners[fmt.Sprintf(`%s::%s`, channel, command)] = callback

			Log.LogShort(senderName, LM.CategorySYSTEM, LM.LevelINFO, LM.MessageNameCONFIGURATION, `The registrar has registered a new ICCC command.`, `channel=`+channel, `command=`+command)
			`}`