nicdex/goes
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Addr instead of port as flag, default to localhost only

Browse Source
This commit is contained in:
Nicolas Dextraze 2016-02-23 13:01:37 -08:00
parent 67fa052672
commit 02345ce91a
1 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
simpleserver/simpleserver.go
View File

@ -12,7 +12,7 @@ import (
"path" "path"
) )
var port = flag.Int("port", 12345, "port to listen to") var addr = flag.String("addr", "tcp://127.0.0.1:12345", "zeromq address to listen to")
var db = flag.String("db", fmt.Sprintf(".%cevents", os.PathSeparator), "path for storage") var db = flag.String("db", fmt.Sprintf(".%cevents", os.PathSeparator), "path for storage")
type Serializer struct {} type Serializer struct {}
@ -65,7 +65,7 @@ func main() {
storagePath = path.Join(wd, storagePath) storagePath = path.Join(wd, storagePath)
} }
fmt.Println("Listening on port:", *port) fmt.Println("Listening on:", *addr)
fmt.Println("Storage path:", storagePath) fmt.Println("Storage path:", storagePath)
goes.SetStorage(goes.NewReadableDiskStorage(storagePath)) goes.SetStorage(goes.NewReadableDiskStorage(storagePath))
goes.SetSerializer(NewSerializer()) goes.SetSerializer(NewSerializer())
@ -82,8 +82,7 @@ func main() {
} }
defer replySocket.Close() defer replySocket.Close()
listenAddr := fmt.Sprintf("tcp://*:%d", *port) err = replySocket.Bind(*addr)
err = replySocket.Bind(listenAddr)
if err != nil { if err != nil {
panic(err) panic(err)
} }