mirror of
https://github.com/gogrlx/nats-server.git
synced 2026-04-02 03:38:42 -07:00
Added fixme for queue sub perf
This commit is contained in:
@@ -10,7 +10,6 @@ import (
|
||||
"net"
|
||||
"sync"
|
||||
"time"
|
||||
// "unsafe"
|
||||
|
||||
"github.com/apcera/gnatsd/hashmap"
|
||||
)
|
||||
@@ -344,6 +343,7 @@ func (c *client) processMsg(msg []byte) {
|
||||
for _, v := range r {
|
||||
sub := v.(*subscription)
|
||||
if sub.queue != nil {
|
||||
// FIXME, this can be more efficient
|
||||
if qmap == nil {
|
||||
qmap = make(map[string][]*subscription)
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user