1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
|
dispatcher_add(function(sammy) {
sammy.get('#/federation', function() {
render({'links': {path: '/federation-links',
options:{vhost:true}},
'vhosts': '/vhosts'},
'federation', '#/federation');
});
sammy.get('#/federation-upstreams', function() {
render({'upstreams': {path: '/parameters/federation-upstream',
options:{vhost:true}},
'vhosts': '/vhosts',
'globals': '/parameters/federation'},
'federation-upstreams', '#/federation-upstreams');
});
sammy.get('#/federation-upstreams/:vhost/:id', function() {
render({'upstream': '/parameters/federation-upstream/' + esc(this.params['vhost']) + '/' + esc(this.params['id'])},
'federation-upstream', '#/federation');
});
sammy.put('#/fed-parameters', function() {
var num_keys = ['expires', 'message-ttl', 'max-hops',
'prefetch-count', 'reconnect-delay'];
var bool_keys = ['trust-user-id'];
var arrayable_keys = ['uri'];
put_parameter(this, [], num_keys, bool_keys, arrayable_keys);
return false;
});
sammy.del('#/fed-parameters', function() {
if (sync_delete(this, '/parameters/:component/:vhost/:name'))
go_to('#/federation-upstreams');
return false;
});
sammy.del("#/federation-restart-link", function(){
if(sync_delete(this, '/federation-links/vhost/:vhost/:id/:node/restart')){
update();
}
});
});
NAVIGATION['Admin'][0]['Federation Status'] = ['#/federation', "monitoring"];
NAVIGATION['Admin'][0]['Federation Upstreams'] = ['#/federation-upstreams', "policymaker"];
HELP['federation-uri'] =
'URI to connect to. If upstream is a cluster and can have several URIs, you can enter them here separated by spaces.';
HELP['federation-prefetch'] =
'Maximum number of unacknowledged messages that may be in flight over a federation link at one time. Defaults to 1000 if not set.';
HELP['federation-reconnect'] =
'Time in seconds to wait after a network link goes down before attempting reconnection. Defaults to 5 if not set.';
HELP['federation-ack-mode'] =
'<dl>\
<dt><code>on-confirm</code></dt>\
<dd>Messages are acknowledged to the upstream broker after they have been confirmed downstream. Handles network errors and broker failures without losing messages. The slowest option, and the default.</dd>\
<dt><code>on-publish</code></dt>\
<dd>Messages are acknowledged to the upstream broker after they have been published downstream. Handles network errors without losing messages, but may lose messages in the event of broker failures.</dd>\
<dt><code>no-ack</code></dt>\
<dd>Message acknowledgements are not used. The fastest option, but may lose messages in the event of network or broker failures.</dd>\
</dl>';
HELP['federation-trust-user-id'] =
'Set "Yes" to preserve the "user-id" field across a federation link, even if the user-id does not match that used to republish the message. Set to "No" to clear the "user-id" field when messages are federated. Only set this to "Yes" if you trust the upstream broker not to forge user-ids.';
HELP['exchange'] =
'The name of the upstream exchange. Default is to use the same name as the federated exchange.';
HELP['federation-max-hops'] =
'Maximum number of federation links that messages can traverse before being dropped. Defaults to 1 if not set.';
HELP['federation-expires'] =
'Time in milliseconds that the upstream should remember about this node for. After this time all upstream state will be removed. Leave this blank to mean "forever".';
HELP['federation-ttl'] =
'Time in milliseconds that undelivered messages should be held upstream when there is a network outage or backlog. Leave this blank to mean "forever".';
HELP['ha-policy'] =
'Determines the "x-ha-policy" argument for the upstream queue for a federated exchange. Default is "none", meaning the queue is not HA.';
HELP['queue'] =
'The name of the upstream queue. Default is to use the same name as the federated queue.';
HELP['consumer-tag'] =
'The consumer tag to use when consuming from upstream. Optional.';
function link_fed_conn(vhost, name) {
return _link_to(name, '#/federation-upstreams/' + esc(vhost) + '/' + esc(name));
}
|
