Guest User

Untitled

a guest
Oct 23rd, 2017
388
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 36.49 KB | None | 0 0
  1. ```
  2. Ayandas-MacBook-Pro:sbin ayandadube$
  3. Ayandas-MacBook-Pro:sbin ayandadube$
  4. Ayandas-MacBook-Pro:sbin ayandadube$ ./rabbitmqctl cluster_status
  5. Cluster status of node 'rabbit_1@Ayandas-MacBook-Pro' ...
  6. [{nodes,[{disc,['rabbit@Ayandas-MacBook-Pro','rabbit_1@Ayandas-MacBook-Pro',
  7. 'rabbit_2@Ayandas-MacBook-Pro']}]},
  8. {running_nodes,['rabbit_2@Ayandas-MacBook-Pro','rabbit@Ayandas-MacBook-Pro',
  9. 'rabbit_1@Ayandas-MacBook-Pro']},
  10. {cluster_name,<<"rabbit@ayandas-macbook-pro">>},
  11. {partitions,[]},
  12. {alarms,[{'rabbit_2@Ayandas-MacBook-Pro',[]},
  13. {'rabbit@Ayandas-MacBook-Pro',[]},
  14. {'rabbit_1@Ayandas-MacBook-Pro',[]}]}]
  15. Ayandas-MacBook-Pro:sbin ayandadube$
  16. Ayandas-MacBook-Pro:sbin ayandadube$
  17. Ayandas-MacBook-Pro:sbin ayandadube$
  18. Ayandas-MacBook-Pro:sbin ayandadube$ ./rabbitmqctl list_queues name pid slave_pids
  19. Listing queues ...
  20. test.queue.10 <rabbit@Ayandas-MacBook-Pro.3.663.0> [<rabbit_2@Ayandas-MacBook-Pro.3.1067.0>, <rabbit_1@Ayandas-MacBook-Pro.1.1190.0>]
  21. test.queue.5 <rabbit@Ayandas-MacBook-Pro.3.643.0> [<rabbit_2@Ayandas-MacBook-Pro.3.1093.0>, <rabbit_1@Ayandas-MacBook-Pro.1.1244.0>]
  22. test.queue.16 <rabbit@Ayandas-MacBook-Pro.3.687.0> [<rabbit_2@Ayandas-MacBook-Pro.3.1088.0>, <rabbit_1@Ayandas-MacBook-Pro.1.1193.0>]
  23. test.queue.3 <rabbit@Ayandas-MacBook-Pro.3.635.0> [<rabbit_2@Ayandas-MacBook-Pro.3.1102.0>, <rabbit_1@Ayandas-MacBook-Pro.1.1247.0>]
  24. test.queue.20 <rabbit@Ayandas-MacBook-Pro.3.703.0> [<rabbit_2@Ayandas-MacBook-Pro.3.1106.0>, <rabbit_1@Ayandas-MacBook-Pro.1.1221.0>]
  25. test.queue.8 <rabbit@Ayandas-MacBook-Pro.3.655.0> [<rabbit_2@Ayandas-MacBook-Pro.3.1112.0>, <rabbit_1@Ayandas-MacBook-Pro.1.1218.0>]
  26. test.queue.19 <rabbit@Ayandas-MacBook-Pro.3.699.0> [<rabbit_2@Ayandas-MacBook-Pro.3.1082.0>, <rabbit_1@Ayandas-MacBook-Pro.1.1187.0>]
  27. test.queue.1 <rabbit@Ayandas-MacBook-Pro.3.627.0> [<rabbit_2@Ayandas-MacBook-Pro.3.1097.0>, <rabbit_1@Ayandas-MacBook-Pro.1.1227.0>]
  28. test.queue.2 <rabbit@Ayandas-MacBook-Pro.3.631.0> [<rabbit_2@Ayandas-MacBook-Pro.3.1073.0>, <rabbit_1@Ayandas-MacBook-Pro.1.1209.0>]
  29. test.queue.15 <rabbit@Ayandas-MacBook-Pro.3.683.0> [<rabbit_2@Ayandas-MacBook-Pro.3.1125.0>, <rabbit_1@Ayandas-MacBook-Pro.1.1257.0>]
  30. test.queue.17 <rabbit@Ayandas-MacBook-Pro.3.691.0> [<rabbit_2@Ayandas-MacBook-Pro.3.1079.0>, <rabbit_1@Ayandas-MacBook-Pro.1.1196.0>]
  31. test.queue.9 <rabbit@Ayandas-MacBook-Pro.3.659.0> [<rabbit_2@Ayandas-MacBook-Pro.3.1070.0>, <rabbit_1@Ayandas-MacBook-Pro.1.1206.0>]
  32. test.queue.11 <rabbit@Ayandas-MacBook-Pro.3.667.0> [<rabbit_2@Ayandas-MacBook-Pro.3.1085.0>, <rabbit_1@Ayandas-MacBook-Pro.1.1203.0>]
  33. test.queue.7 <rabbit@Ayandas-MacBook-Pro.3.651.0> [<rabbit_2@Ayandas-MacBook-Pro.3.1134.0>, <rabbit_1@Ayandas-MacBook-Pro.1.1252.0>]
  34. test.queue.4 <rabbit@Ayandas-MacBook-Pro.3.639.0> [<rabbit_2@Ayandas-MacBook-Pro.3.1121.0>, <rabbit_1@Ayandas-MacBook-Pro.1.1239.0>]
  35. test.queue.18 <rabbit@Ayandas-MacBook-Pro.3.695.0> [<rabbit_2@Ayandas-MacBook-Pro.3.1109.0>, <rabbit_1@Ayandas-MacBook-Pro.1.1234.0>]
  36. test.queue.14 <rabbit@Ayandas-MacBook-Pro.3.679.0> [<rabbit_2@Ayandas-MacBook-Pro.3.1143.0>, <rabbit_1@Ayandas-MacBook-Pro.1.1264.0>]
  37. test.queue.6 <rabbit@Ayandas-MacBook-Pro.3.647.0> [<rabbit_2@Ayandas-MacBook-Pro.3.1117.0>, <rabbit_1@Ayandas-MacBook-Pro.1.1215.0>]
  38. test.queue.13 <rabbit@Ayandas-MacBook-Pro.3.675.0> [<rabbit_2@Ayandas-MacBook-Pro.3.1154.0>, <rabbit_1@Ayandas-MacBook-Pro.1.1261.0>]
  39. bench <rabbit@Ayandas-MacBook-Pro.3.582.0> [<rabbit_2@Ayandas-MacBook-Pro.3.1129.0>, <rabbit_1@Ayandas-MacBook-Pro.1.1279.0>]
  40. test.queue.12 <rabbit@Ayandas-MacBook-Pro.3.671.0> [<rabbit_2@Ayandas-MacBook-Pro.3.1137.0>, <rabbit_1@Ayandas-MacBook-Pro.1.1270.0>]
  41. Ayandas-MacBook-Pro:sbin ayandadube$
  42. Ayandas-MacBook-Pro:sbin ayandadube$
  43. Ayandas-MacBook-Pro:sbin ayandadube$
  44. Ayandas-MacBook-Pro:sbin ayandadube$ ./rabbitmq-plugins enable rabbitmq_queue_master_balancer
  45. The following plugins have been enabled:
  46. rabbitmq_queue_master_balancer
  47.  
  48. Applying plugin configuration to rabbit_1@Ayandas-MacBook-Pro... started 1 plugin.
  49. Ayandas-MacBook-Pro:sbin ayandadube$
  50. Ayandas-MacBook-Pro:sbin ayandadube$
  51. Ayandas-MacBook-Pro:sbin ayandadube$ ./rabbitmqctl eval 'rabbit_queue_master_balancer:info().'
  52. [{parent_pid,<10393.1436.0>},
  53. {phase,idle},
  54. {queues,[]},
  55. {balanced,[]},
  56. {operational_priority,5},
  57. {sync_timeout,3000},
  58. {policy_transition_delay,50},
  59. {last_balance_timestamp,undefined}]
  60. Ayandas-MacBook-Pro:sbin ayandadube$
  61. Ayandas-MacBook-Pro:sbin ayandadube$
  62. Ayandas-MacBook-Pro:sbin ayandadube$
  63. Ayandas-MacBook-Pro:sbin ayandadube$ ./rabbitmqctl eval 'rabbit_queue_master_balancer:load_queues().'
  64. {ok,21}
  65. Ayandas-MacBook-Pro:sbin ayandadube$
  66. Ayandas-MacBook-Pro:sbin ayandadube$
  67. Ayandas-MacBook-Pro:sbin ayandadube$ ./rabbitmqctl eval 'rabbit_queue_master_balancer:info().'
  68. [{parent_pid,<10393.1436.0>},
  69. {phase,ready},
  70. {queues,[{amqqueue,{resource,<<"/">>,queue,<<"test.queue.10">>},
  71. false,false,none,[],<10469.663.0>,
  72. [<10468.1067.0>,<10393.1190.0>],
  73. [<10393.1190.0>,<10468.1067.0>],
  74. ['rabbit_2@Ayandas-MacBook-Pro',
  75. 'rabbit_1@Ayandas-MacBook-Pro'],
  76. [{vhost,<<"/">>},
  77. {name,<<"ha-all">>},
  78. {pattern,<<".*">>},
  79. {'apply-to',<<"queues">>},
  80. {definition,[{<<"ha-mode">>,<<"all">>},
  81. {<<"ha-sync-mode">>,<<"automatic">>}]},
  82. {priority,1}],
  83. [{<10393.1198.0>,<10393.1190.0>},
  84. {<10468.1074.0>,<10468.1067.0>},
  85. {<10469.1297.0>,<10469.663.0>}],
  86. [],live,1},
  87. {amqqueue,{resource,<<"/">>,queue,<<"test.queue.5">>},
  88. false,false,none,[],<10469.643.0>,
  89. [<10468.1093.0>,<10393.1244.0>],
  90. [<10393.1244.0>,<10468.1093.0>],
  91. ['rabbit_2@Ayandas-MacBook-Pro',
  92. 'rabbit_1@Ayandas-MacBook-Pro'],
  93. [{vhost,<<"/">>},
  94. {name,<<"ha-all">>},
  95. {pattern,<<".*">>},
  96. {'apply-to',<<"queues">>},
  97. {definition,[{<<"ha-mode">>,<<"all">>},
  98. {<<"ha-sync-mode">>,<<"automatic">>}]},
  99. {priority,1}],
  100. [{<10393.1251.0>,<10393.1244.0>},
  101. {<10468.1101.0>,<10468.1093.0>},
  102. {<10469.1296.0>,<10469.643.0>}],
  103. [],live,1},
  104. {amqqueue,{resource,<<"/">>,queue,<<"test.queue.16">>},
  105. false,false,none,[],<10469.687.0>,
  106. [<10468.1088.0>,<10393.1193.0>],
  107. [<10393.1193.0>,<10468.1088.0>],
  108. ['rabbit_2@Ayandas-MacBook-Pro',
  109. 'rabbit_1@Ayandas-MacBook-Pro'],
  110. [{vhost,<<"/">>},
  111. {name,<<"ha-all">>},
  112. {pattern,<<".*">>},
  113. {'apply-to',<<"queues">>},
  114. {definition,[{<<"ha-mode">>,<<"all">>},
  115. {<<"ha-sync-mode">>,<<"automatic">>}]},
  116. {priority,1}],
  117. [{<10393.1201.0>,<10393.1193.0>},
  118. {<10468.1098.0>,<10468.1088.0>},
  119. {<10469.1314.0>,<10469.687.0>}],
  120. [],live,1},
  121. {amqqueue,{resource,<<"/">>,queue,<<"test.queue.3">>},
  122. false,false,none,[],<10469.635.0>,
  123. [<10468.1102.0>,<10393.1247.0>],
  124. [<10393.1247.0>,<10468.1102.0>],
  125. ['rabbit_2@Ayandas-MacBook-Pro',
  126. 'rabbit_1@Ayandas-MacBook-Pro'],
  127. [{vhost,<<"/">>},
  128. {name,<<"ha-all">>},
  129. {pattern,<<".*">>},
  130. {'apply-to',<<"queues">>},
  131. {definition,[{<<"ha-mode">>,<<"all">>},
  132. {<<"ha-sync-mode">>,<<"automatic">>}]},
  133. {priority,1}],
  134. [{<10393.1258.0>,<10393.1247.0>},
  135. {<10468.1114.0>,<10468.1102.0>},
  136. {<10469.1300.0>,<10469.635.0>}],
  137. [],live,1},
  138. {amqqueue,{resource,<<"/">>,queue,<<"test.queue.20">>},
  139. false,false,none,[],<10469.703.0>,
  140. [<10468.1106.0>,<10393.1221.0>],
  141. [<10393.1221.0>,<10468.1106.0>],
  142. ['rabbit_2@Ayandas-MacBook-Pro',
  143. 'rabbit_1@Ayandas-MacBook-Pro'],
  144. [{vhost,<<"/">>},
  145. {name,<<"ha-all">>},
  146. {pattern,<<".*">>},
  147. {'apply-to',<<"queues">>},
  148. {definition,[{<<"ha-mode">>,<<"all">>},
  149. {<<"ha-sync-mode">>,<<"automatic">>}]},
  150. {priority,1}],
  151. [{<10393.1224.0>,<10393.1221.0>},
  152. {<10468.1113.0>,<10468.1106.0>},
  153. {<10469.1311.0>,<10469.703.0>}],
  154. [],live,1},
  155. {amqqueue,{resource,<<"/">>,queue,<<"test.queue.8">>},
  156. false,false,none,[],<10469.655.0>,
  157. [<10468.1112.0>,<10393.1218.0>],
  158. [<10393.1218.0>,<10468.1112.0>],
  159. ['rabbit_2@Ayandas-MacBook-Pro',
  160. 'rabbit_1@Ayandas-MacBook-Pro'],
  161. [{vhost,<<"/">>},
  162. {name,<<"ha-all">>},
  163. {pattern,<<".*">>},
  164. {'apply-to',<<"queues">>},
  165. {definition,[{<<"ha-mode">>,<<"all">>},
  166. {<<"ha-sync-mode">>,<<"automatic">>}]},
  167. {priority,1}],
  168. [{<10393.1223.0>,<10393.1218.0>},
  169. {<10468.1122.0>,<10468.1112.0>},
  170. {<10469.1315.0>,<10469.655.0>}],
  171. [],live,1},
  172. {amqqueue,{resource,<<"/">>,queue,<<"test.queue.19">>},
  173. false,false,none,[],<10469.699.0>,
  174. [<10468.1082.0>,<10393.1187.0>],
  175. [<10393.1187.0>,<10468.1082.0>],
  176. ['rabbit_2@Ayandas-MacBook-Pro',
  177. 'rabbit_1@Ayandas-MacBook-Pro'],
  178. [{vhost,<<"/">>},
  179. {name,<<"ha-all">>},
  180. {pattern,<<".*">>},
  181. {'apply-to',<<"queues">>},
  182. {definition,[{<<"ha-mode">>,<<"all">>},
  183. {<<"ha-sync-mode">>,<<"automatic">>}]},
  184. {priority,1}],
  185. [{<10393.1197.0>,<10393.1187.0>},
  186. {<10468.1090.0>,<10468.1082.0>},
  187. {<10469.1298.0>,<10469.699.0>}],
  188. [],live,1},
  189. {amqqueue,{resource,<<"/">>,queue,<<"test.queue.1">>},
  190. false,false,none,[],<10469.627.0>,
  191. [<10468.1097.0>,<10393.1227.0>],
  192. [<10393.1227.0>,<10468.1097.0>],
  193. ['rabbit_2@Ayandas-MacBook-Pro',
  194. 'rabbit_1@Ayandas-MacBook-Pro'],
  195. [{vhost,<<"/">>},
  196. {name,<<"ha-all">>},
  197. {pattern,<<".*">>},
  198. {'apply-to',<<"queues">>},
  199. {definition,[{<<"ha-mode">>,<<"all">>},
  200. {<<"ha-sync-mode">>,<<"automatic">>}]},
  201. {priority,1}],
  202. [{<10393.1235.0>,<10393.1227.0>},
  203. {<10468.1103.0>,<10468.1097.0>},
  204. {<10469.1313.0>,<10469.627.0>}],
  205. [],live,1},
  206. {amqqueue,{resource,<<"/">>,queue,<<"test.queue.2">>},
  207. false,false,none,[],<10469.631.0>,
  208. [<10468.1073.0>,<10393.1209.0>],
  209. [<10393.1209.0>,<10468.1073.0>],
  210. ['rabbit_2@Ayandas-MacBook-Pro',
  211. 'rabbit_1@Ayandas-MacBook-Pro'],
  212. [{vhost,<<"/">>},
  213. {name,<<"ha-all">>},
  214. {pattern,<<".*">>},
  215. {'apply-to',<<"queues">>},
  216. {definition,[{<<"ha-mode">>,<<"all">>},
  217. {<<"ha-sync-mode">>,<<"automatic">>}]},
  218. {priority,1}],
  219. [{<10393.1212.0>,<10393.1209.0>},
  220. {<10468.1076.0>,<10468.1073.0>},
  221. {<10469.1310.0>,<10469.631.0>}],
  222. [],live,1},
  223. {amqqueue,{resource,<<"/">>,queue,<<"test.queue.15">>},
  224. false,false,none,[],<10469.683.0>,
  225. [<10468.1125.0>,<10393.1257.0>],
  226. [<10393.1257.0>,<10468.1125.0>],
  227. ['rabbit_2@Ayandas-MacBook-Pro',
  228. 'rabbit_1@Ayandas-MacBook-Pro'],
  229. [{vhost,<<"/">>},
  230. {name,<<"ha-all">>},
  231. {pattern,<<".*">>},
  232. {'apply-to',<<"queues">>},
  233. {definition,[{<<"ha-mode">>,<<"all">>},
  234. {<<"ha-sync-mode">>,<<"automatic">>}]},
  235. {priority,1}],
  236. [{<10393.1265.0>,<10393.1257.0>},
  237. {<10468.1133.0>,<10468.1125.0>},
  238. {<10469.1316.0>,<10469.683.0>}],
  239. [],live,1},
  240. {amqqueue,{resource,<<"/">>,queue,<<"test.queue.17">>},
  241. false,false,none,[],<10469.691.0>,
  242. [<10468.1079.0>,<10393.1196.0>],
  243. [<10393.1196.0>,<10468.1079.0>],
  244. ['rabbit_2@Ayandas-MacBook-Pro',
  245. 'rabbit_1@Ayandas-MacBook-Pro'],
  246. [{vhost,<<"/">>},
  247. {name,<<"ha-all">>},
  248. {pattern,<<".*">>},
  249. {'apply-to',<<"queues">>},
  250. {definition,[{<<"ha-mode">>,<<"all">>},
  251. {<<"ha-sync-mode">>,<<"automatic">>}]},
  252. {priority,1}],
  253. [{<10393.1202.0>,<10393.1196.0>},
  254. {<10468.1089.0>,<10468.1079.0>},
  255. {<10469.1312.0>,<10469.691.0>}],
  256. [],live,1},
  257. {amqqueue,{resource,<<"/">>,queue,<<"test.queue.9">>},
  258. false,false,none,[],<10469.659.0>,
  259. [<10468.1070.0>,<10393.1206.0>],
  260. [<10393.1206.0>,<10468.1070.0>],
  261. ['rabbit_2@Ayandas-MacBook-Pro',
  262. 'rabbit_1@Ayandas-MacBook-Pro'],
  263. [{vhost,<<"/">>},
  264. {name,<<"ha-all">>},
  265. {pattern,<<".*">>},
  266. {'apply-to',<<"queues">>},
  267. {definition,[{<<"ha-mode">>,<<"all">>},
  268. {<<"ha-sync-mode">>,<<"automatic">>}]},
  269. {priority,1}],
  270. [{<10393.1211.0>,<10393.1206.0>},
  271. {<10468.1075.0>,<10468.1070.0>},
  272. {<10469.1299.0>,<10469.659.0>}],
  273. [],live,1},
  274. {amqqueue,{resource,<<"/">>,queue,<<"test.queue.11">>},
  275. false,false,none,[],<10469.667.0>,
  276. [<10468.1085.0>,<10393.1203.0>],
  277. [<10393.1203.0>,<10468.1085.0>],
  278. ['rabbit_2@Ayandas-MacBook-Pro',
  279. 'rabbit_1@Ayandas-MacBook-Pro'],
  280. [{vhost,<<"/">>},
  281. {name,<<"ha-all">>},
  282. {pattern,<<".*">>},
  283. {'apply-to',<<"queues">>},
  284. {definition,[{<<"ha-mode">>,<<"all">>},
  285. {<<"ha-sync-mode">>,<<"automatic">>}]},
  286. {priority,1}],
  287. [{<10393.1210.0>,<10393.1203.0>},
  288. {<10468.1094.0>,<10468.1085.0>},
  289. {<10469.1309.0>,<10469.667.0>}],
  290. [],live,1},
  291. {amqqueue,{resource,<<"/">>,queue,<<"test.queue.7">>},
  292. false,false,none,[],<10469.651.0>,
  293. [<10468.1134.0>,<10393.1252.0>],
  294. [<10393.1252.0>,<10468.1134.0>],
  295. ['rabbit_2@Ayandas-MacBook-Pro',
  296. 'rabbit_1@Ayandas-MacBook-Pro'],
  297. [{vhost,<<"/">>},
  298. {name,<<"ha-all">>},
  299. {pattern,<<".*">>},
  300. {'apply-to',<<"queues">>},
  301. {definition,[{<<"ha-mode">>,<<"all">>},
  302. {<<"ha-sync-mode">>,<<"automatic">>}]},
  303. {priority,1}],
  304. [{<10393.1268.0>,<10393.1252.0>},
  305. {<10468.1144.0>,<10468.1134.0>},
  306. {<10469.1328.0>,<10469.651.0>}],
  307. [],live,1},
  308. {amqqueue,{resource,<<"/">>,queue,<<"test.queue.4">>},
  309. false,false,none,[],<10469.639.0>,
  310. [<10468.1121.0>,<10393.1239.0>],
  311. [<10393.1239.0>,<10468.1121.0>],
  312. ['rabbit_2@Ayandas-MacBook-Pro',
  313. 'rabbit_1@Ayandas-MacBook-Pro'],
  314. [{vhost,<<"/">>},
  315. {name,<<"ha-all">>},
  316. {pattern,<<".*">>},
  317. {'apply-to',<<"queues">>},
  318. {definition,[{<<"ha-mode">>,<<"all">>},
  319. {<<"ha-sync-mode">>,<<"automatic">>}]},
  320. {priority,1}],
  321. [{<10393.1253.0>,<10393.1239.0>},
  322. {<10468.1132.0>,<10468.1121.0>},
  323. {<10469.1317.0>,<10469.639.0>}],
  324. [],live,1},
  325. {amqqueue,{resource,<<"/">>,queue,<<"test.queue.18">>},
  326. false,false,none,[],<10469.695.0>,
  327. [<10468.1109.0>,<10393.1234.0>],
  328. [<10393.1234.0>,<10468.1109.0>],
  329. ['rabbit_2@Ayandas-MacBook-Pro',
  330. 'rabbit_1@Ayandas-MacBook-Pro'],
  331. [{vhost,<<"/">>},
  332. {name,<<"ha-all">>},
  333. {pattern,<<".*">>},
  334. {'apply-to',<<"queues">>},
  335. {definition,[{<<"ha-mode">>,<<"all">>},
  336. {<<"ha-sync-mode">>,<<"automatic">>}]},
  337. {priority,1}],
  338. [{<10393.1250.0>,<10393.1234.0>},
  339. {<10468.1118.0>,<10468.1109.0>},
  340. {<10469.1318.0>,<10469.695.0>}],
  341. [],live,1},
  342. {amqqueue,{resource,<<"/">>,queue,<<"test.queue.14">>},
  343. false,false,none,[],<10469.679.0>,
  344. [<10468.1143.0>,<10393.1264.0>],
  345. [<10393.1264.0>,<10468.1143.0>],
  346. ['rabbit_2@Ayandas-MacBook-Pro',
  347. 'rabbit_1@Ayandas-MacBook-Pro'],
  348. [{vhost,<<"/">>},
  349. {name,<<"ha-all">>},
  350. {pattern,<<".*">>},
  351. {'apply-to',<<"queues">>},
  352. {definition,[{<<"ha-mode">>,<<"all">>},
  353. {<<"ha-sync-mode">>,<<"automatic">>}]},
  354. {priority,1}],
  355. [{<10393.1272.0>,<10393.1264.0>},
  356. {<10468.1152.0>,<10468.1143.0>},
  357. {<10469.1329.0>,<10469.679.0>}],
  358. [],live,1},
  359. {amqqueue,{resource,<<"/">>,queue,<<"test.queue.6">>},
  360. false,false,none,[],<10469.647.0>,
  361. [<10468.1117.0>,<10393.1215.0>],
  362. [<10393.1215.0>,<10468.1117.0>],
  363. ['rabbit_2@Ayandas-MacBook-Pro',
  364. 'rabbit_1@Ayandas-MacBook-Pro'],
  365. [{vhost,<<"/">>},
  366. {name,<<"ha-all">>},
  367. {pattern,<<".*">>},
  368. {'apply-to',<<"queues">>},
  369. {definition,[{<<"ha-mode">>,<<"all">>},
  370. {<<"ha-sync-mode">>,<<"automatic">>}]},
  371. {priority,1}],
  372. [{<10393.1222.0>,<10393.1215.0>},
  373. {<10468.1126.0>,<10468.1117.0>},
  374. {<10469.1322.0>,<10469.647.0>}],
  375. [],live,1},
  376. {amqqueue,{resource,<<"/">>,queue,<<"test.queue.13">>},
  377. false,false,none,[],<10469.675.0>,
  378. [<10468.1154.0>,<10393.1261.0>],
  379. [<10393.1261.0>,<10468.1154.0>],
  380. ['rabbit_2@Ayandas-MacBook-Pro',
  381. 'rabbit_1@Ayandas-MacBook-Pro'],
  382. [{vhost,<<"/">>},
  383. {name,<<"ha-all">>},
  384. {pattern,<<".*">>},
  385. {'apply-to',<<"queues">>},
  386. {definition,[{<<"ha-mode">>,<<"all">>},
  387. {<<"ha-sync-mode">>,<<"automatic">>}]},
  388. {priority,1}],
  389. [{<10393.1269.0>,<10393.1261.0>},
  390. {<10468.1155.0>,<10468.1154.0>},
  391. {<10469.1326.0>,<10469.675.0>}],
  392. [],live,1},
  393. {amqqueue,{resource,<<"/">>,queue,<<"bench">>},
  394. false,false,none,
  395. [{<<"x-message-ttl">>,long,60000}],
  396. <10469.582.0>,
  397. [<10468.1129.0>,<10393.1279.0>],
  398. [<10393.1279.0>,<10468.1129.0>],
  399. ['rabbit_2@Ayandas-MacBook-Pro',
  400. 'rabbit_1@Ayandas-MacBook-Pro'],
  401. [{vhost,<<"/">>},
  402. {name,<<"ha-all">>},
  403. {pattern,<<".*">>},
  404. {'apply-to',<<"queues">>},
  405. {definition,[{<<"ha-mode">>,<<"all">>},
  406. {<<"ha-sync-mode">>,<<"automatic">>}]},
  407. {priority,1}],
  408. [{<10393.1291.0>,<10393.1279.0>},
  409. {<10468.1146.0>,<10468.1129.0>},
  410. {<10469.1325.0>,<10469.582.0>}],
  411. [],live,1},
  412. {amqqueue,{resource,<<"/">>,queue,<<"test.queue.12">>},
  413. false,false,none,[],<10469.671.0>,
  414. [<10468.1137.0>,<10393.1270.0>],
  415. [<10393.1270.0>,<10468.1137.0>],
  416. ['rabbit_2@Ayandas-MacBook-Pro',
  417. 'rabbit_1@Ayandas-MacBook-Pro'],
  418. [{vhost,<<"/">>},
  419. {name,<<"ha-all">>},
  420. {pattern,<<".*">>},
  421. {'apply-to',<<"queues">>},
  422. {definition,[{<<"ha-mode">>,<<"all">>},
  423. {<<"ha-sync-mode">>,<<"automatic">>}]},
  424. {priority,1}],
  425. [{<10393.1275.0>,<10393.1270.0>},
  426. {<10468.1151.0>,<10468.1137.0>},
  427. {<10469.1324.0>,<10469.671.0>}],
  428. [],live,1}]},
  429. {balanced,[]},
  430. {operational_priority,5},
  431. {sync_timeout,3000},
  432. {policy_transition_delay,50},
  433. {last_balance_timestamp,undefined}]
  434. Ayandas-MacBook-Pro:sbin ayandadube$
  435. Ayandas-MacBook-Pro:sbin ayandadube$
  436. Ayandas-MacBook-Pro:sbin ayandadube$
  437. Ayandas-MacBook-Pro:sbin ayandadube$ ./rabbitmqctl eval 'rabbit_queue_master_balancer:report().'
  438. {ok,[{'rabbit_2@Ayandas-MacBook-Pro',{queues,0}},
  439. {'rabbit@Ayandas-MacBook-Pro',{queues,21}},
  440. {'rabbit_1@Ayandas-MacBook-Pro',{queues,0}}]}
  441. Ayandas-MacBook-Pro:sbin ayandadube$
  442. Ayandas-MacBook-Pro:sbin ayandadube$
  443. Ayandas-MacBook-Pro:sbin ayandadube$ ./rabbitmqctl eval 'rabbit_queue_master_balancer:go().'
  444. ok
  445. Ayandas-MacBook-Pro:sbin ayandadube$
  446. Ayandas-MacBook-Pro:sbin ayandadube$
  447. Ayandas-MacBook-Pro:sbin ayandadube$ ./rabbitmqctl eval 'rabbit_queue_master_balancer:info().'
  448. [{parent_pid,<10393.1436.0>},
  449. {phase,balancing_queues},
  450. {queues,[{amqqueue,{resource,<<"/">>,queue,<<"test.queue.9">>},
  451. false,false,none,[],<10469.659.0>,
  452. [<10468.1070.0>,<10393.1206.0>],
  453. [<10393.1206.0>,<10468.1070.0>],
  454. ['rabbit_2@Ayandas-MacBook-Pro',
  455. 'rabbit_1@Ayandas-MacBook-Pro'],
  456. [{vhost,<<"/">>},
  457. {name,<<"ha-all">>},
  458. {pattern,<<".*">>},
  459. {'apply-to',<<"queues">>},
  460. {definition,[{<<"ha-mode">>,<<"all">>},
  461. {<<"ha-sync-mode">>,<<"automatic">>}]},
  462. {priority,1}],
  463. [{<10393.1211.0>,<10393.1206.0>},
  464. {<10468.1075.0>,<10468.1070.0>},
  465. {<10469.1299.0>,<10469.659.0>}],
  466. [],live,1},
  467. {amqqueue,{resource,<<"/">>,queue,<<"test.queue.11">>},
  468. false,false,none,[],<10469.667.0>,
  469. [<10468.1085.0>,<10393.1203.0>],
  470. [<10393.1203.0>,<10468.1085.0>],
  471. ['rabbit_2@Ayandas-MacBook-Pro',
  472. 'rabbit_1@Ayandas-MacBook-Pro'],
  473. [{vhost,<<"/">>},
  474. {name,<<"ha-all">>},
  475. {pattern,<<".*">>},
  476. {'apply-to',<<"queues">>},
  477. {definition,[{<<"ha-mode">>,<<"all">>},
  478. {<<"ha-sync-mode">>,<<"automatic">>}]},
  479. {priority,1}],
  480. [{<10393.1210.0>,<10393.1203.0>},
  481. {<10468.1094.0>,<10468.1085.0>},
  482. {<10469.1309.0>,<10469.667.0>}],
  483. [],live,1},
  484. {amqqueue,{resource,<<"/">>,queue,<<"test.queue.7">>},
  485. false,false,none,[],<10469.651.0>,
  486. [<10468.1134.0>,<10393.1252.0>],
  487. [<10393.1252.0>,<10468.1134.0>],
  488. ['rabbit_2@Ayandas-MacBook-Pro',
  489. 'rabbit_1@Ayandas-MacBook-Pro'],
  490. [{vhost,<<"/">>},
  491. {name,<<"ha-all">>},
  492. {pattern,<<".*">>},
  493. {'apply-to',<<"queues">>},
  494. {definition,[{<<"ha-mode">>,<<"all">>},
  495. {<<"ha-sync-mode">>,<<"automatic">>}]},
  496. {priority,1}],
  497. [{<10393.1268.0>,<10393.1252.0>},
  498. {<10468.1144.0>,<10468.1134.0>},
  499. {<10469.1328.0>,<10469.651.0>}],
  500. [],live,1},
  501. {amqqueue,{resource,<<"/">>,queue,<<"test.queue.4">>},
  502. false,false,none,[],<10469.639.0>,
  503. [<10468.1121.0>,<10393.1239.0>],
  504. [<10393.1239.0>,<10468.1121.0>],
  505. ['rabbit_2@Ayandas-MacBook-Pro',
  506. 'rabbit_1@Ayandas-MacBook-Pro'],
  507. [{vhost,<<"/">>},
  508. {name,<<"ha-all">>},
  509. {pattern,<<".*">>},
  510. {'apply-to',<<"queues">>},
  511. {definition,[{<<"ha-mode">>,<<"all">>},
  512. {<<"ha-sync-mode">>,<<"automatic">>}]},
  513. {priority,1}],
  514. [{<10393.1253.0>,<10393.1239.0>},
  515. {<10468.1132.0>,<10468.1121.0>},
  516. {<10469.1317.0>,<10469.639.0>}],
  517. [],live,1},
  518. {amqqueue,{resource,<<"/">>,queue,<<"test.queue.18">>},
  519. false,false,none,[],<10469.695.0>,
  520. [<10468.1109.0>,<10393.1234.0>],
  521. [<10393.1234.0>,<10468.1109.0>],
  522. ['rabbit_2@Ayandas-MacBook-Pro',
  523. 'rabbit_1@Ayandas-MacBook-Pro'],
  524. [{vhost,<<"/">>},
  525. {name,<<"ha-all">>},
  526. {pattern,<<".*">>},
  527. {'apply-to',<<"queues">>},
  528. {definition,[{<<"ha-mode">>,<<"all">>},
  529. {<<"ha-sync-mode">>,<<"automatic">>}]},
  530. {priority,1}],
  531. [{<10393.1250.0>,<10393.1234.0>},
  532. {<10468.1118.0>,<10468.1109.0>},
  533. {<10469.1318.0>,<10469.695.0>}],
  534. [],live,1},
  535. {amqqueue,{resource,<<"/">>,queue,<<"test.queue.14">>},
  536. false,false,none,[],<10469.679.0>,
  537. [<10468.1143.0>,<10393.1264.0>],
  538. [<10393.1264.0>,<10468.1143.0>],
  539. ['rabbit_2@Ayandas-MacBook-Pro',
  540. 'rabbit_1@Ayandas-MacBook-Pro'],
  541. [{vhost,<<"/">>},
  542. {name,<<"ha-all">>},
  543. {pattern,<<".*">>},
  544. {'apply-to',<<"queues">>},
  545. {definition,[{<<"ha-mode">>,<<"all">>},
  546. {<<"ha-sync-mode">>,<<"automatic">>}]},
  547. {priority,1}],
  548. [{<10393.1272.0>,<10393.1264.0>},
  549. {<10468.1152.0>,<10468.1143.0>},
  550. {<10469.1329.0>,<10469.679.0>}],
  551. [],live,1},
  552. {amqqueue,{resource,<<"/">>,queue,<<"test.queue.6">>},
  553. false,false,none,[],<10469.647.0>,
  554. [<10468.1117.0>,<10393.1215.0>],
  555. [<10393.1215.0>,<10468.1117.0>],
  556. ['rabbit_2@Ayandas-MacBook-Pro',
  557. 'rabbit_1@Ayandas-MacBook-Pro'],
  558. [{vhost,<<"/">>},
  559. {name,<<"ha-all">>},
  560. {pattern,<<".*">>},
  561. {'apply-to',<<"queues">>},
  562. {definition,[{<<"ha-mode">>,<<"all">>},
  563. {<<"ha-sync-mode">>,<<"automatic">>}]},
  564. {priority,1}],
  565. [{<10393.1222.0>,<10393.1215.0>},
  566. {<10468.1126.0>,<10468.1117.0>},
  567. {<10469.1322.0>,<10469.647.0>}],
  568. [],live,1},
  569. {amqqueue,{resource,<<"/">>,queue,<<"test.queue.13">>},
  570. false,false,none,[],<10469.675.0>,
  571. [<10468.1154.0>,<10393.1261.0>],
  572. [<10393.1261.0>,<10468.1154.0>],
  573. ['rabbit_2@Ayandas-MacBook-Pro',
  574. 'rabbit_1@Ayandas-MacBook-Pro'],
  575. [{vhost,<<"/">>},
  576. {name,<<"ha-all">>},
  577. {pattern,<<".*">>},
  578. {'apply-to',<<"queues">>},
  579. {definition,[{<<"ha-mode">>,<<"all">>},
  580. {<<"ha-sync-mode">>,<<"automatic">>}]},
  581. {priority,1}],
  582. [{<10393.1269.0>,<10393.1261.0>},
  583. {<10468.1155.0>,<10468.1154.0>},
  584. {<10469.1326.0>,<10469.675.0>}],
  585. [],live,1},
  586. {amqqueue,{resource,<<"/">>,queue,<<"bench">>},
  587. false,false,none,
  588. [{<<"x-message-ttl">>,long,60000}],
  589. <10469.582.0>,
  590. [<10468.1129.0>,<10393.1279.0>],
  591. [<10393.1279.0>,<10468.1129.0>],
  592. ['rabbit_2@Ayandas-MacBook-Pro',
  593. 'rabbit_1@Ayandas-MacBook-Pro'],
  594. [{vhost,<<"/">>},
  595. {name,<<"ha-all">>},
  596. {pattern,<<".*">>},
  597. {'apply-to',<<"queues">>},
  598. {definition,[{<<"ha-mode">>,<<"all">>},
  599. {<<"ha-sync-mode">>,<<"automatic">>}]},
  600. {priority,1}],
  601. [{<10393.1291.0>,<10393.1279.0>},
  602. {<10468.1146.0>,<10468.1129.0>},
  603. {<10469.1325.0>,<10469.582.0>}],
  604. [],live,1},
  605. {amqqueue,{resource,<<"/">>,queue,<<"test.queue.12">>},
  606. false,false,none,[],<10469.671.0>,
  607. [<10468.1137.0>,<10393.1270.0>],
  608. [<10393.1270.0>,<10468.1137.0>],
  609. ['rabbit_2@Ayandas-MacBook-Pro',
  610. 'rabbit_1@Ayandas-MacBook-Pro'],
  611. [{vhost,<<"/">>},
  612. {name,<<"ha-all">>},
  613. {pattern,<<".*">>},
  614. {'apply-to',<<"queues">>},
  615. {definition,[{<<"ha-mode">>,<<"all">>},
  616. {<<"ha-sync-mode">>,<<"automatic">>}]},
  617. {priority,1}],
  618. [{<10393.1275.0>,<10393.1270.0>},
  619. {<10468.1151.0>,<10468.1137.0>},
  620. {<10469.1324.0>,<10469.671.0>}],
  621. [],live,1}]},
  622. {balanced,[<<"test.queue.10">>,<<"test.queue.15">>,<<"test.queue.3">>,
  623. <<"test.queue.8">>,<<"test.queue.2">>,<<"test.queue.19">>,
  624. <<"test.queue.1">>,<<"test.queue.20">>,<<"test.queue.17">>,
  625. <<"test.queue.5">>,<<"test.queue.16">>]},
  626. {operational_priority,5},
  627. {sync_timeout,3000},
  628. {policy_transition_delay,50},
  629. {last_balance_timestamp,1508700386657}]
  630. Ayandas-MacBook-Pro:sbin ayandadube$
  631. Ayandas-MacBook-Pro:sbin ayandadube$
  632. Ayandas-MacBook-Pro:sbin ayandadube$
  633. Ayandas-MacBook-Pro:sbin ayandadube$
  634. Ayandas-MacBook-Pro:sbin ayandadube$
  635. Ayandas-MacBook-Pro:sbin ayandadube$
  636. Ayandas-MacBook-Pro:sbin ayandadube$ ./rabbitmqctl eval 'rabbit_queue_master_balancer:info().'
  637. [{parent_pid,<10393.1436.0>},
  638. {phase,idle},
  639. {queues,[]},
  640. {balanced,[<<"test.queue.9">>,<<"test.queue.10">>,<<"test.queue.15">>,
  641. <<"test.queue.3">>,<<"test.queue.8">>,<<"test.queue.14">>,
  642. <<"test.queue.2">>,<<"test.queue.7">>,<<"test.queue.19">>,
  643. <<"test.queue.13">>,<<"test.queue.1">>,<<"test.queue.20">>,
  644. <<"test.queue.6">>,<<"test.queue.18">>,<<"test.queue.12">>,
  645. <<"test.queue.17">>,<<"test.queue.5">>,<<"bench">>,
  646. <<"test.queue.11">>,<<"test.queue.4">>,<<"test.queue.16">>]},
  647. {operational_priority,5},
  648. {sync_timeout,3000},
  649. {policy_transition_delay,50},
  650. {last_balance_timestamp,1508700389882}]
  651. Ayandas-MacBook-Pro:sbin ayandadube$
  652. Ayandas-MacBook-Pro:sbin ayandadube$
  653. Ayandas-MacBook-Pro:sbin ayandadube$
  654. Ayandas-MacBook-Pro:sbin ayandadube$ ./rabbitmqctl eval 'rabbit_queue_master_balancer:report().'
  655. {ok,[{'rabbit_2@Ayandas-MacBook-Pro',{queues,7}},
  656. {'rabbit@Ayandas-MacBook-Pro',{queues,6}},
  657. {'rabbit_1@Ayandas-MacBook-Pro',{queues,8}}]}
  658. Ayandas-MacBook-Pro:sbin ayandadube$
  659. Ayandas-MacBook-Pro:sbin ayandadube$
  660. Ayandas-MacBook-Pro:sbin ayandadube$
  661. Ayandas-MacBook-Pro:sbin ayandadube$ ./rabbitmqctl eval 'rabbit_queue_master_balancer:info().'
  662. [{parent_pid,<10393.1436.0>},
  663. {phase,idle},
  664. {queues,[]},
  665. {balanced,[<<"test.queue.9">>,<<"test.queue.10">>,<<"test.queue.15">>,
  666. <<"test.queue.3">>,<<"test.queue.8">>,<<"test.queue.14">>,
  667. <<"test.queue.2">>,<<"test.queue.7">>,<<"test.queue.19">>,
  668. <<"test.queue.13">>,<<"test.queue.1">>,<<"test.queue.20">>,
  669. <<"test.queue.6">>,<<"test.queue.18">>,<<"test.queue.12">>,
  670. <<"test.queue.17">>,<<"test.queue.5">>,<<"bench">>,
  671. <<"test.queue.11">>,<<"test.queue.4">>,<<"test.queue.16">>]},
  672. {operational_priority,5},
  673. {sync_timeout,3000},
  674. {policy_transition_delay,50},
  675. {last_balance_timestamp,1508700389882}]
  676. Ayandas-MacBook-Pro:sbin ayandadube$ ./rabbitmqctl eval 'rabbit_queue_master_balancer:stop().'
  677. ok
  678. Ayandas-MacBook-Pro:sbin ayandadube$
  679. Ayandas-MacBook-Pro:sbin ayandadube$
  680. Ayandas-MacBook-Pro:sbin ayandadube$
  681. Ayandas-MacBook-Pro:sbin ayandadube$ ./rabbitmqctl eval 'rabbit_queue_master_balancer:info().'
  682. [{parent_pid,<10393.1436.0>},
  683. {phase,idle},
  684. {queues,[]},
  685. {balanced,[<<"test.queue.9">>,<<"test.queue.10">>,<<"test.queue.15">>,
  686. <<"test.queue.3">>,<<"test.queue.8">>,<<"test.queue.14">>,
  687. <<"test.queue.2">>,<<"test.queue.7">>,<<"test.queue.19">>,
  688. <<"test.queue.13">>,<<"test.queue.1">>,<<"test.queue.20">>,
  689. <<"test.queue.6">>,<<"test.queue.18">>,<<"test.queue.12">>,
  690. <<"test.queue.17">>,<<"test.queue.5">>,<<"bench">>,
  691. <<"test.queue.11">>,<<"test.queue.4">>,<<"test.queue.16">>]},
  692. {operational_priority,5},
  693. {sync_timeout,3000},
  694. {policy_transition_delay,50},
  695. {last_balance_timestamp,1508700389882}]
  696. Ayandas-MacBook-Pro:sbin ayandadube$
  697. Ayandas-MacBook-Pro:sbin ayandadube$
  698. Ayandas-MacBook-Pro:sbin ayandadube$
  699. Ayandas-MacBook-Pro:sbin ayandadube$ ./rabbitmqctl eval 'rabbit_queue_master_balancer:reset().'
  700. ok
  701. Ayandas-MacBook-Pro:sbin ayandadube$
  702. Ayandas-MacBook-Pro:sbin ayandadube$
  703. Ayandas-MacBook-Pro:sbin ayandadube$ ./rabbitmqctl eval 'rabbit_queue_master_balancer:info().'
  704. [{parent_pid,<10393.1436.0>},
  705. {phase,idle},
  706. {queues,[]},
  707. {balanced,[]},
  708. {operational_priority,5},
  709. {sync_timeout,3000},
  710. {policy_transition_delay,50},
  711. {last_balance_timestamp,1508700389882}]
  712. Ayandas-MacBook-Pro:sbin ayandadube$
  713. Ayandas-MacBook-Pro:sbin ayandadube$
  714. Ayandas-MacBook-Pro:sbin ayandadube$
  715. Ayandas-MacBook-Pro:sbin ayandadube$ ./rabbitmqctl eval 'rabbit_queue_master_balancer:report().'
  716. {ok,[{'rabbit_2@Ayandas-MacBook-Pro',{queues,7}},
  717. {'rabbit@Ayandas-MacBook-Pro',{queues,6}},
  718. {'rabbit_1@Ayandas-MacBook-Pro',{queues,8}}]}
  719. Ayandas-MacBook-Pro:sbin ayandadube$
  720. Ayandas-MacBook-Pro:sbin ayandadube$
  721. ```
Add Comment
Please, Sign In to add comment