Skip to content
Snippets Groups Projects
Commit fb593321 authored by scott's avatar scott
Browse files

Fix missing protocol scheme bug

parent 0bf2a02f
No related branches found
No related tags found
No related merge requests found
...@@ -49,7 +49,12 @@ func (l *dataListener) AddInterestedURL(url *common.URL) { ...@@ -49,7 +49,12 @@ func (l *dataListener) AddInterestedURL(url *common.URL) {
func (l *dataListener) DataChange(eventType remoting.Event) bool { func (l *dataListener) DataChange(eventType remoting.Event) bool {
url := eventType.Path[strings.Index(eventType.Path, "/providers/")+len("/providers/"):] index := strings.Index(eventType.Path, "/providers/")
if index == -1 {
logger.Warnf("Listen with no url, event.path={%v}", eventType.Path)
return false
}
url := eventType.Path[index+len("/providers/"):]
serviceURL, err := common.NewURL(url) serviceURL, err := common.NewURL(url)
if err != nil { if err != nil {
logger.Warnf("Listen NewURL(r{%s}) = error{%v}", eventType.Path, err) logger.Warnf("Listen NewURL(r{%s}) = error{%v}", eventType.Path, err)
......
...@@ -53,7 +53,12 @@ func (l *dataListener) AddInterestedURL(url *common.URL) { ...@@ -53,7 +53,12 @@ func (l *dataListener) AddInterestedURL(url *common.URL) {
// notify listen, when interest event // notify listen, when interest event
func (l *dataListener) DataChange(eventType remoting.Event) bool { func (l *dataListener) DataChange(eventType remoting.Event) bool {
url := eventType.Path[strings.Index(eventType.Path, "/providers/")+len("/providers/"):] index := strings.Index(eventType.Path, "/providers/")
if index == -1 {
logger.Warnf("Listen with no url, event.path={%v}", eventType.Path)
return false
}
url := eventType.Path[index+len("/providers/"):]
serviceURL, err := common.NewURL(url) serviceURL, err := common.NewURL(url)
if err != nil { if err != nil {
logger.Warnf("Listen NewURL(r{%s}) = error{%v}", eventType.Path, err) logger.Warnf("Listen NewURL(r{%s}) = error{%v}", eventType.Path, err)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment