knx-go TCP connection

gistfile1.txt

package main

import (
	"log"
	"os"

	"github.com/vapourismo/knx-go/knx"
	//"github.com/vapourismo/knx-go/knx/cemi"
	"github.com/vapourismo/knx-go/knx/dpt"
	"github.com/vapourismo/knx-go/knx/util"

	//"github.com/alexander-zimmermann/knx-go/knx"
	//"github.com/alexander-zimmermann/knx-go/knx/cemi"
	//"github.com/alexander-zimmermann/knx-go/knx/dpt"
	//"github.com/alexander-zimmermann/knx-go/knx/util"
)

func main() {
	// Setup logger for auxiliary logging. This enables us to see log messages from internal
	// routines.
	util.Logger = log.New(os.Stdout, "", log.LstdFlags)

	// Connect to the gateway.
	tunnelconfig := knx.DefaultTunnelConfig
	tunnelconfig.UseTCP = true
	client, err := knx.NewGroupTunnel("192.168.1.173:3671", tunnelconfig)
	if err != nil {
		log.Fatal(err)
	}

	// Close upon exiting. Even if the gateway closes the connection, we still have to clean up.
	defer client.Close()

	// Receive messages from the gateway. The inbound channel is closed with the connection.
	for msg := range client.Inbound() {
		var temp dpt.DPT_7012

		err := temp.Unpack(msg.Data)
		if err != nil {
			continue
		}

		util.Logger.Printf("%+v: %v", msg, temp)
	}
}