ensure register ttl and interval are set
This commit is contained in:
parent
b021fcb130
commit
522e04840c
20
options.go
20
options.go
@ -66,15 +66,17 @@ func MaxMsgSize(s int) server.Option {
|
|||||||
|
|
||||||
func newOptions(opt ...server.Option) server.Options {
|
func newOptions(opt ...server.Option) server.Options {
|
||||||
opts := server.Options{
|
opts := server.Options{
|
||||||
Codecs: make(map[string]codec.NewCodec),
|
Codecs: make(map[string]codec.NewCodec),
|
||||||
Metadata: map[string]string{},
|
Metadata: map[string]string{},
|
||||||
Broker: http.NewBroker(),
|
Broker: http.NewBroker(),
|
||||||
Registry: mdns.NewRegistry(),
|
Registry: mdns.NewRegistry(),
|
||||||
Transport: transport.DefaultTransport,
|
Transport: transport.DefaultTransport,
|
||||||
Address: server.DefaultAddress,
|
Address: server.DefaultAddress,
|
||||||
Name: server.DefaultName,
|
Name: server.DefaultName,
|
||||||
Id: server.DefaultId,
|
Id: server.DefaultId,
|
||||||
Version: server.DefaultVersion,
|
Version: server.DefaultVersion,
|
||||||
|
RegisterInterval: server.DefaultRegisterInterval,
|
||||||
|
RegisterTTL: server.DefaultRegisterTTL,
|
||||||
}
|
}
|
||||||
|
|
||||||
for _, o := range opt {
|
for _, o := range opt {
|
||||||
|
Loading…
Reference in New Issue
Block a user