mirror of
https://github.com/gogrlx/nats-server.git
synced 2026-04-02 03:38:42 -07:00
Merge pull request #1861 from nats-io/js-list-request-fix
js: consumer list request fix
This commit is contained in:
@@ -2724,6 +2724,18 @@ func (s *Server) jsClusteredConsumerListRequest(acc *Account, ci *ClientInfo, of
|
||||
defer s.sysUnsubscribe(rsub)
|
||||
|
||||
// Send out our requests here.
|
||||
var resp = JSApiConsumerListResponse{
|
||||
ApiResponse: ApiResponse{Type: JSApiConsumerListResponseType},
|
||||
Consumers: []*ConsumerInfo{},
|
||||
}
|
||||
|
||||
if len(consumers) == 0 {
|
||||
resp.Limit = JSApiListLimit
|
||||
resp.Offset = offset
|
||||
s.sendAPIResponse(ci, acc, subject, reply, string(rmsg), s.jsonResponse(resp))
|
||||
return
|
||||
}
|
||||
|
||||
for _, ca := range consumers {
|
||||
isubj := fmt.Sprintf(clusterConsumerInfoT, ca.Client.Account, stream, ca.Name)
|
||||
s.sendInternalMsgLocked(isubj, inbox, nil, nil)
|
||||
@@ -2733,11 +2745,6 @@ func (s *Server) jsClusteredConsumerListRequest(acc *Account, ci *ClientInfo, of
|
||||
notActive := time.NewTimer(timeout)
|
||||
defer notActive.Stop()
|
||||
|
||||
var resp = JSApiConsumerListResponse{
|
||||
ApiResponse: ApiResponse{Type: JSApiConsumerListResponseType},
|
||||
Consumers: []*ConsumerInfo{},
|
||||
}
|
||||
|
||||
LOOP:
|
||||
for {
|
||||
select {
|
||||
|
||||
Reference in New Issue
Block a user