various fixes for broker and messaging in server (#1187)
* provide broker disconnect messages in server Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org> * broker/eats: another fix Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
This commit is contained in:
		
							
								
								
									
										6
									
								
								grpc.go
									
									
									
									
									
								
							
							
						
						
									
										6
									
								
								grpc.go
									
									
									
									
									
								
							| @@ -805,10 +805,7 @@ func (g *grpcServer) Start() error { | ||||
| 			return err | ||||
| 		} | ||||
|  | ||||
| 		baddr := config.Broker.Address() | ||||
| 		bname := config.Broker.String() | ||||
|  | ||||
| 		log.Logf("Broker [%s] Connected to %s", bname, baddr) | ||||
| 		log.Logf("Broker [%s] Connected to %s", config.Broker.String(), config.Broker.Address()) | ||||
| 	} | ||||
|  | ||||
| 	// announce self to the world | ||||
| @@ -876,6 +873,7 @@ func (g *grpcServer) Start() error { | ||||
| 		// close transport | ||||
| 		ch <- nil | ||||
|  | ||||
| 		log.Logf("Broker [%s] Disconnected from %s", config.Broker.String(), config.Broker.Address()) | ||||
| 		// disconnect broker | ||||
| 		config.Broker.Disconnect() | ||||
| 	}() | ||||
|   | ||||
		Reference in New Issue
	
	Block a user