Skip to content

Commit

Permalink
Make sure we are set to RMSG for send to Gateways
Browse files Browse the repository at this point in the history
Signed-off-by: Derek Collison <derek@nats.io>
  • Loading branch information
derekcollison committed May 1, 2019
1 parent 1d736cc commit 1c8d4b4
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions server/gateway.go
Expand Up @@ -2139,6 +2139,9 @@ func (c *client) sendMsgToGateways(acc *Account, msg, subject, reply []byte, qgr
// Get a subscription from the pool
sub := subPool.Get().(*subscription)

// Make sure we are an 'R' proto
c.msgb[0] = 'R'

// Check if the subject is on "$GR.<cluster hash>.",
// and if so, send to that GW regardless of its
// interest on the real subject (that is, skip the
Expand Down

0 comments on commit 1c8d4b4

Please sign in to comment.