Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
d749de989c |
@@ -74,6 +74,9 @@ func dialNats(ctx context.Context, m Membership, timeout time.Duration) (Link, e
|
|||||||
// the server refused the bare name the first time a machine dialled it: "authentication
|
// the server refused the bare name the first time a machine dialled it: "authentication
|
||||||
// error - User". The same string the mesh composed into the user list, or nothing connects.
|
// error - User". The same string the mesh composed into the user list, or nothing connects.
|
||||||
nats.UserInfo("node."+m.Node, m.Password),
|
nats.UserInfo("node."+m.Node, m.Password),
|
||||||
|
// Replies to what this client asks the server arrive on its inbox, and the mesh grants a
|
||||||
|
// machine exactly its own: the same prefix the user list was composed with.
|
||||||
|
nats.CustomInboxPrefix("_INBOX.node." + m.Node),
|
||||||
nats.Name("mesh-host/" + m.Node),
|
nats.Name("mesh-host/" + m.Node),
|
||||||
nats.Timeout(timeout),
|
nats.Timeout(timeout),
|
||||||
// A node that has silently lost its route notices, rather than holding a connection the
|
// A node that has silently lost its route notices, rather than holding a connection the
|
||||||
|
|||||||
Reference in New Issue
Block a user