diff --git a/examples/consul/go-client/config/client.yml b/examples/consul/go-client/config/client.yml index ad5747204c..8a7458c384 100644 --- a/examples/consul/go-client/config/client.yml +++ b/examples/consul/go-client/config/client.yml @@ -1,13 +1,3 @@ -# dubbo client yaml configure file - - -check: true -# client -request_timeout : "3s" -# connect timeout -connect_timeout : "3s" - -# application config application_config: organization : "ikurento.com" name : "BDTService" @@ -17,7 +7,7 @@ application_config: environment : "test" registries : - "hangzhouzk": + "consul": protocol: "consul" timeout : "3s" address: "127.0.0.1:8500" @@ -56,3 +46,7 @@ protocol_conf: wait_timeout: "1s" max_msg_len: 10240 session_name: "client" + +check: true +request_timeout : "3s" +connect_timeout : "3s" diff --git a/examples/consul/go-server/config/server.yml b/examples/consul/go-server/config/server.yml index dfefb30939..c12800e68d 100644 --- a/examples/consul/go-server/config/server.yml +++ b/examples/consul/go-server/config/server.yml @@ -1,7 +1,3 @@ -# dubbo server yaml configure file - - -# application config application_config: organization : "ikurento.com" name : "BDTService" @@ -11,7 +7,7 @@ application_config: environment : "test" registries : - "hangzhouzk": + "consul": protocol: "consul" timeout : "3s" address: "127.0.0.1:8500" @@ -33,10 +29,8 @@ services: protocols: "dubbo1": name: "dubbo" - # ip : "127.0.0.1" port: 20000 - protocol_conf: dubbo: session_number: 700 diff --git a/registry/consul/listener.go b/registry/consul/listener.go index 98cd8b3bde..b047a4c08c 100644 --- a/registry/consul/listener.go +++ b/registry/consul/listener.go @@ -94,8 +94,8 @@ func newConsulListener(registryUrl common.URL, consumerUrl common.URL) (*consulL consumerUrl: consumerUrl, plan: plan, urls: make([]common.URL, 0, 8), - eventCh: make(chan *registry.ServiceEvent), - errCh: make(chan error), + eventCh: make(chan *registry.ServiceEvent, 32), + errCh: make(chan error, 32), done: make(chan struct{}), }