start archiver
This commit is contained in:
@ -8,9 +8,11 @@ import "udi/handlers/ttn"
|
|||||||
|
|
||||||
|
|
||||||
var handlerMap map[string]handler.Handler = make(map[string]handler.Handler)
|
var handlerMap map[string]handler.Handler = make(map[string]handler.Handler)
|
||||||
|
var archiverChannel chan mqtt.Message = make(chan mqtt.Message, 100)
|
||||||
|
|
||||||
func InitDispatcher() {
|
func InitDispatcher() {
|
||||||
log.Printf("Initializing dispatcher")
|
log.Printf("Initializing dispatcher")
|
||||||
|
go archiver()
|
||||||
for _, handlerEntry := range config.Config.Handlers {
|
for _, handlerEntry := range config.Config.Handlers {
|
||||||
log.Printf("Trying %s", handlerEntry.Name)
|
log.Printf("Trying %s", handlerEntry.Name)
|
||||||
switch handlerEntry.Name {
|
switch handlerEntry.Name {
|
||||||
@ -23,11 +25,21 @@ func InitDispatcher() {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func archiver() {
|
||||||
|
for {
|
||||||
|
select {
|
||||||
|
case _ = <- archiverChannel:
|
||||||
|
log.Printf("Archiving message")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
func InputDispatcher() {
|
func InputDispatcher() {
|
||||||
for {
|
for {
|
||||||
select {
|
select {
|
||||||
case message := <- mqtt.InputChannel:
|
case message := <- mqtt.InputChannel:
|
||||||
log.Printf("Message arrived in inputDispatcher, topic: %s\n", message.Topic)
|
log.Printf("Message arrived in inputDispatcher, topic: %s\n", message.Topic)
|
||||||
|
archiverChannel <- message
|
||||||
|
|
||||||
for _, mapping := range config.Config.TopicMappings {
|
for _, mapping := range config.Config.TopicMappings {
|
||||||
log.Printf("Testing %s -> %s", mapping.Topics, mapping.Handler)
|
log.Printf("Testing %s -> %s", mapping.Topics, mapping.Handler)
|
||||||
|
Reference in New Issue
Block a user