From 81c6dc288d90b2db25d7ad1af4c9afd4e38eeb0e Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=9D=8E=E5=BF=97=E4=BF=A1?=
<lizhixin@B-C0A1LVDL-2144.local>
Date: Thu, 31 Dec 2020 13:51:59 +0800
Subject: [PATCH] fix: base directory_test good
---
cluster/directory/base_directory.go | 3 +--
cluster/directory/base_directory_test.go | 5 ++++-
2 files changed, 5 insertions(+), 3 deletions(-)
diff --git a/cluster/directory/base_directory.go b/cluster/directory/base_directory.go
index caba0f3ba..309cd4429 100644
--- a/cluster/directory/base_directory.go
+++ b/cluster/directory/base_directory.go
@@ -45,11 +45,10 @@ type BaseDirectory struct {
// NewBaseDirectory Create BaseDirectory with URL
func NewBaseDirectory(url *common.URL) BaseDirectory {
- rc, _ := chain.NewRouterChain(url)
return BaseDirectory{
url: url,
destroyed: atomic.NewBool(false),
- routerChain: rc,
+ routerChain: &chain.RouterChain{},
}
}
diff --git a/cluster/directory/base_directory_test.go b/cluster/directory/base_directory_test.go
index 16e3c5a96..9208c6236 100644
--- a/cluster/directory/base_directory_test.go
+++ b/cluster/directory/base_directory_test.go
@@ -20,6 +20,7 @@ package directory
import (
"encoding/base64"
"fmt"
+ chain2 "github.com/apache/dubbo-go/cluster/router/chain"
"testing"
)
@@ -50,7 +51,9 @@ func TestBuildRouterChain(t *testing.T) {
regURL := url
regURL.AddParam(constant.INTERFACE_KEY, "mock-app")
directory := NewBaseDirectory(regURL)
-
+ var err error
+ directory.routerChain, err = chain2.NewRouterChain(regURL)
+ assert.Nil(t, err)
localIP := common.GetLocalIp()
rule := base64.URLEncoding.EncodeToString([]byte("true => " + " host = " + localIP))
routeURL := getRouteURL(rule, anyURL)
--
GitLab