collab/hmq
3
0
Fork 0
mirror of https://github.com/fhmq/hmq.git synced 2026-05-09 00:50:38 +00:00
Code Issues Packages Projects Releases Wiki Activity

remove no use

Browse Source
This commit is contained in:
joy.zhou
2019-08-06 18:15:47 +08:00
parent d963ce000d
commit e8ceea87b4
1 changed files with 0 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/rpc.go
-4
View File
@@ -138,10 +138,6 @@ func (h *HMQ) DeliverMessage(ctx context.Context, in *pb.DeliverMessageRequest)
return resp, nil return resp, nil
} }
func (b *Broker) DeliverMessage(packet *packets.PublishPacket, shareRemoteID string) {
}
func (b *Broker) QueryConnect(clientID string) { func (b *Broker) QueryConnect(clientID string) {
for _, client := range b.rpcClient { for _, client := range b.rpcClient {
client.QueryConnect(context.Background(), &pb.QueryConnectRequest{ClientID: clientID}) client.QueryConnect(context.Background(), &pb.QueryConnectRequest{ClientID: clientID})