Skip to content

Commit

Permalink
modify yaml
Browse files Browse the repository at this point in the history
  • Loading branch information
高辛格 committed Aug 23, 2019
1 parent 21d7b15 commit 5dd2bd0
Show file tree
Hide file tree
Showing 3 changed files with 8 additions and 20 deletions.
16 changes: 5 additions & 11 deletions examples/consul/go-client/config/client.yml
Original file line number Diff line number Diff line change
@@ -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"
Expand All @@ -17,7 +7,7 @@ application_config:
environment : "test"

registries :
"hangzhouzk":
"consul":
protocol: "consul"
timeout : "3s"
address: "127.0.0.1:8500"
Expand Down Expand Up @@ -56,3 +46,7 @@ protocol_conf:
wait_timeout: "1s"
max_msg_len: 10240
session_name: "client"

check: true
request_timeout : "3s"
connect_timeout : "3s"
8 changes: 1 addition & 7 deletions examples/consul/go-server/config/server.yml
Original file line number Diff line number Diff line change
@@ -1,7 +1,3 @@
# dubbo server yaml configure file


# application config
application_config:
organization : "ikurento.com"
name : "BDTService"
Expand All @@ -11,7 +7,7 @@ application_config:
environment : "test"

registries :
"hangzhouzk":
"consul":
protocol: "consul"
timeout : "3s"
address: "127.0.0.1:8500"
Expand All @@ -33,10 +29,8 @@ services:
protocols:
"dubbo1":
name: "dubbo"
# ip : "127.0.0.1"
port: 20000


protocol_conf:
dubbo:
session_number: 700
Expand Down
4 changes: 2 additions & 2 deletions registry/consul/listener.go
Original file line number Diff line number Diff line change
Expand Up @@ -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{}),
}

Expand Down

0 comments on commit 5dd2bd0

Please sign in to comment.