mirror of
https://github.com/gogrlx/nats-server.git
synced 2026-04-15 18:50:41 -07:00
@@ -2178,7 +2178,7 @@ func (c *client) checkForImportServices(acc *Account, msg []byte) {
|
||||
nrr = c.newServiceReply()
|
||||
rm.acc.addImplicitServiceImport(acc, string(nrr), string(c.pa.reply), true, nil)
|
||||
// If this is a client connection and we are in
|
||||
// gateway mode, we need to send RS+ to cluster
|
||||
// gateway mode, we need to send RS+ to local cluster
|
||||
// and possibly to inbound GW connections for
|
||||
// which we are in interest-only mode.
|
||||
if c.kind == CLIENT && c.srv.gateway.enabled {
|
||||
|
||||
@@ -2108,6 +2108,9 @@ func (c *client) processInboundGatewayMsg(msg []byte) {
|
||||
|
||||
// Check to see if we need to map/route to another account.
|
||||
if acc.imports.services != nil && isServiceReply(c.pa.subject) {
|
||||
// We are handling an response to a request that we mapped
|
||||
// via service imports, so if we are here we are the
|
||||
// origin server
|
||||
c.checkForImportServices(acc, msg)
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user