fix: Broker's port is not registered.
Connecting to broker before registering.
This commit is contained in:
		
							
								
								
									
										10
									
								
								http.go
									
									
									
									
									
								
							
							
						
						
									
										10
									
								
								http.go
									
									
									
									
									
								
							| @@ -247,8 +247,14 @@ func (h *httpServer) Start() error { | |||||||
| 		return errors.New("Server required http.Handler") | 		return errors.New("Server required http.Handler") | ||||||
| 	} | 	} | ||||||
|  |  | ||||||
|  | 	if err = opts.Broker.Connect(); err != nil { | ||||||
|  | 		return err | ||||||
|  | 	} | ||||||
|  |  | ||||||
| 	// register | 	// register | ||||||
| 	h.Register() | 	if err = h.Register(); err != nil { | ||||||
|  | 		return err | ||||||
|  | 	} | ||||||
|  |  | ||||||
| 	go http.Serve(ln, handler) | 	go http.Serve(ln, handler) | ||||||
|  |  | ||||||
| @@ -286,7 +292,7 @@ func (h *httpServer) Start() error { | |||||||
| 		opts.Broker.Disconnect() | 		opts.Broker.Disconnect() | ||||||
| 	}() | 	}() | ||||||
|  |  | ||||||
| 	return opts.Broker.Connect() | 	return nil | ||||||
| } | } | ||||||
|  |  | ||||||
| func (h *httpServer) Stop() error { | func (h *httpServer) Stop() error { | ||||||
|   | |||||||
		Reference in New Issue
	
	Block a user