modified: client/core/kite_client_manager.go

modified: kiteq.go
songshubing · Mar 26, 2015 · 6ec40c1 · 6ec40c1
1 parent c5aa733
commit 6ec40c1
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/client/core/kite_client_manager.go b/client/core/kite_client_manager.go
@@ -39,7 +39,7 @@ func NewKiteClientManager(zkAddr, groupId, secretKey string, listen listener.ILi
 
 	rc := protocol.NewRemotingConfig(
 		"kiteclient-"+groupId,
-		1000, 16*1024,
+		50, 16*1024,
 		16*1024, 10000, 10000,
 		10*time.Second, 160000)
 

diff --git a/kiteq.go b/kiteq.go
@@ -41,11 +41,11 @@ func main() {
 
 	rc := protocol.NewRemotingConfig(
 		"KiteQ-"+*bindHost,
-		1000, 16*1024,
+		2000, 16*1024,
 		16*1024, 10000, 10000,
 		10*time.Second, 160000)
 
-	kc := server.NewKiteQConfig(*bindHost, *zkhost, 1*time.Second, 1000, 5*time.Second, strings.Split(*topics, ","), *db, rc)
+	kc := server.NewKiteQConfig(*bindHost, *zkhost, 1*time.Second, 5000, 5*time.Second, strings.Split(*topics, ","), *db, rc)
 
 	qserver := server.NewKiteQServer(kc)
 	qserver.Start()