tidy

config.go

@@ -1,13 +1,13 @@
 package wsmsg
 
 type Config struct {
-  DebugMode      bool
-  VerboseMode    bool
-  Procs          int
-  LogDir         string
-  NatsLogStdout  bool
-  HttpLogStdout  bool
-  BindIP         string
-  BindPort       int
-  MaxMessageSize int
+	DebugMode      bool
+	VerboseMode    bool
+	Procs          int
+	LogDir         string
+	NatsLogStdout  bool
+	HttpLogStdout  bool
+	BindIP         string
+	BindPort       int
+	MaxMessageSize int
 }

default.go

@@ -1,11 +1,11 @@
 package wsmsg
 
-const(
-  DEFAULT_LOG_DIR           string = "/tmp"
-  DEFAULT_BIND_IP           string = "0.0.0.0"
-  DEFAULT_BIND_PORT            int = 8080
-  DEFAULT_MSG_MAX_PAYLOAD      int = 1024 * 1024
-  DEFAULT_PING_INTERVAL        int = 1000
-  DEFAULT_PING_OUT             int = 5
-  DEFAULT_WS_MAX_MESSAGE_SIZE  int = 1024 * 1024
+const (
+	DEFAULT_LOG_DIR             string = "/tmp"
+	DEFAULT_BIND_IP             string = "0.0.0.0"
+	DEFAULT_BIND_PORT           int    = 8080
+	DEFAULT_MSG_MAX_PAYLOAD     int    = 1024 * 1024
+	DEFAULT_PING_INTERVAL       int    = 1000
+	DEFAULT_PING_OUT            int    = 5
+	DEFAULT_WS_MAX_MESSAGE_SIZE int    = 1024 * 1024
 )

example/queue/subA.go

@@ -1,34 +1,34 @@
 package main
 
-import(
-  "fmt"
-  "flag"
+import (
+	"flag"
+	"fmt"
 
-  "github.com/gorilla/websocket"
+	"github.com/gorilla/websocket"
 )
 
 var addr = flag.String("addr", "localhost:8080", "websocket url")
 var topic = flag.String("topic", "test", "subscribe topic")
 var group = flag.String("group", "subA", "group name")
 
-func main(){
-  flag.Parse()
+func main() {
+	flag.Parse()
 
-  url := fmt.Sprintf("ws://%s/ws/sub/%s/%s", *addr, *topic, *group)
-  c, _, err := websocket.DefaultDialer.Dial(url, nil)
-  if err != nil {
-    fmt.Printf("dial error: %v\n", err)
-    return
-  }
-  defer c.Close()
+	url := fmt.Sprintf("ws://%s/ws/sub/%s/%s", *addr, *topic, *group)
+	c, _, err := websocket.DefaultDialer.Dial(url, nil)
+	if err != nil {
+		fmt.Printf("dial error: %v\n", err)
+		return
+	}
+	defer c.Close()
 
-  fmt.Printf("wait message for group %s\n", *group)
-  for {
-    t, msg, e := c.ReadMessage()
-    if e != nil {
-      fmt.Printf("read message error: %v", e)
-      return
-    }
-    fmt.Printf("recv: %s(type=%d)\n", msg, t)
-  }
+	fmt.Printf("wait message for group %s\n", *group)
+	for {
+		t, msg, e := c.ReadMessage()
+		if e != nil {
+			fmt.Printf("read message error: %v", e)
+			return
+		}
+		fmt.Printf("recv: %s(type=%d)\n", msg, t)
+	}
 }

example/queue/subB.go

@@ -1,35 +1,34 @@
 package main
 
-import(
-  "fmt"
-  "flag"
+import (
+	"flag"
+	"fmt"
 
-  "github.com/gorilla/websocket"
+	"github.com/gorilla/websocket"
 )
 
 var addr = flag.String("addr", "localhost:8080", "websocket url")
 var topic = flag.String("topic", "test", "subscribe topic")
 var group = flag.String("group", "subB", "group name")
 
-func main(){
-  flag.Parse()
+func main() {
+	flag.Parse()
 
-  url := fmt.Sprintf("ws://%s/ws/sub/%s/%s", *addr, *topic, *group)
-  c, _, err := websocket.DefaultDialer.Dial(url, nil)
-  if err != nil {
-    fmt.Printf("dial error: %v\n", err)
-    return
-  }
-  defer c.Close()
+	url := fmt.Sprintf("ws://%s/ws/sub/%s/%s", *addr, *topic, *group)
+	c, _, err := websocket.DefaultDialer.Dial(url, nil)
+	if err != nil {
+		fmt.Printf("dial error: %v\n", err)
+		return
+	}
+	defer c.Close()
 
-  fmt.Printf("wait message for group %s\n", *group)
-  for {
-    t, msg, e := c.ReadMessage()
-    if e != nil {
-      fmt.Printf("read message error: %v", e)
-      return
-    }
-    fmt.Printf("recv: %s(type=%d)\n", msg, t)
-  }
+	fmt.Printf("wait message for group %s\n", *group)
+	for {
+		t, msg, e := c.ReadMessage()
+		if e != nil {
+			fmt.Printf("read message error: %v", e)
+			return
+		}
+		fmt.Printf("recv: %s(type=%d)\n", msg, t)
+	}
 }
-

example/subscribe/sub.go

@@ -1,33 +1,33 @@
 package main
 
-import(
-  "fmt"
-  "flag"
+import (
+	"flag"
+	"fmt"
 
-  "github.com/gorilla/websocket"
+	"github.com/gorilla/websocket"
 )
 
 var addr = flag.String("addr", "localhost:8080", "websocket url")
 var topic = flag.String("topic", "test", "subscribe topic")
 
-func main(){
-  flag.Parse()
+func main() {
+	flag.Parse()
 
-  url := fmt.Sprintf("ws://%s/ws/sub/%s", *addr, *topic)
-  c, _, err := websocket.DefaultDialer.Dial(url, nil)
-  if err != nil {
-    fmt.Printf("dial error: %v\n", err)
-    return
-  }
-  defer c.Close()
+	url := fmt.Sprintf("ws://%s/ws/sub/%s", *addr, *topic)
+	c, _, err := websocket.DefaultDialer.Dial(url, nil)
+	if err != nil {
+		fmt.Printf("dial error: %v\n", err)
+		return
+	}
+	defer c.Close()
 
-  fmt.Printf("wait message\n")
-  for {
-    t, msg, e := c.ReadMessage()
-    if e != nil {
-      fmt.Printf("read message error: %v", e)
-      return
-    }
-    fmt.Printf("recv: %s(type=%d)\n", msg, t)
-  }
+	fmt.Printf("wait message\n")
+	for {
+		t, msg, e := c.ReadMessage()
+		if e != nil {
+			fmt.Printf("read message error: %v", e)
+			return
+		}
+		fmt.Printf("recv: %s(type=%d)\n", msg, t)
+	}
 }