unistack-org/micro-broker-nats
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 8 Wiki Activity

Update to match go-micro interface

Browse Source
This commit is contained in:
Asim 2016-03-16 10:08:10 +00:00 committed by Vasiliy Tolstov
parent 0745de181c
commit a0e851fa4d
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
nats.go
View File

@ -142,9 +142,14 @@ func (n *nbroker) String() string {
return "nats" return "nats"
} }
func NewBroker(addrs []string, opt ...broker.Option) broker.Broker { func NewBroker(opts ...broker.Option) broker.Broker {
var options broker.Options
for _, o := range opts {
o(&options)
}
var cAddrs []string var cAddrs []string
for _, addr := range addrs { for _, addr := range options.Addrs {
if len(addr) == 0 { if len(addr) == 0 {
continue continue
} }