fix compilation

This commit is contained in:
Chris Lu 2020-04-28 02:05:32 -07:00
parent eab4c9219c
commit 66effaed9e

View File

@ -23,10 +23,6 @@ func NewMessagingClient(bootstrapBrokers []string) (*MessagingClient, error) {
return nil, err
}
util.OnInterrupt(func() {
grpcConnection.Close()
})
return &MessagingClient{
bootstrapBrokers: bootstrapBrokers,
grpcConnection: grpcConnection,