diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-04-28 02:05:32 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-04-28 02:05:32 -0700 |
| commit | 66effaed9e99b48255e1a0bc2373d2fa645919b3 (patch) | |
| tree | f6147a1071c79e7971a98dd43b8a822f0de59e2a | |
| parent | eab4c9219c066783c42f397c4cf94f5e11bf0d54 (diff) | |
| download | seaweedfs-66effaed9e99b48255e1a0bc2373d2fa645919b3.tar.xz seaweedfs-66effaed9e99b48255e1a0bc2373d2fa645919b3.zip | |
fix compilation
| -rw-r--r-- | weed/messaging/client/client.go | 4 |
1 files changed, 0 insertions, 4 deletions
diff --git a/weed/messaging/client/client.go b/weed/messaging/client/client.go index 910fd02e9..4a674a9fc 100644 --- a/weed/messaging/client/client.go +++ b/weed/messaging/client/client.go @@ -23,10 +23,6 @@ func NewMessagingClient(bootstrapBrokers []string) (*MessagingClient, error) { return nil, err } - util.OnInterrupt(func() { - grpcConnection.Close() - }) - return &MessagingClient{ bootstrapBrokers: bootstrapBrokers, grpcConnection: grpcConnection, |