1
2
3
4
5
6
7
8
9
10
11 package psiprobe.model.jmx;
12
13 import java.util.ArrayList;
14 import java.util.Collection;
15 import java.util.List;
16
17
18
19
20 public class Cluster {
21
22
23 private String name;
24
25
26 private String info;
27
28
29 private String managerClassName;
30
31
32 private String mcastAddress;
33
34
35 private String mcastBindAddress;
36
37
38 private String mcastClusterDomain;
39
40
41 private long mcastDropTime;
42
43
44 private long mcastFrequency;
45
46
47 private int mcastPort;
48
49
50 private int mcastSoTimeout;
51
52
53 private int mcastTtl;
54
55
56 private List<ClusterSender> members = new ArrayList<>();
57
58
59 private int tcpThreadCount;
60
61
62 private String tcpListenAddress;
63
64
65 private int tcpListenPort;
66
67
68 private long tcpSelectorTimeout;
69
70
71 private long nrOfMsgsReceived;
72
73
74 private long totalReceivedBytes;
75
76
77 private long senderAckTimeout;
78
79
80 private boolean senderAutoConnect;
81
82
83 private long senderFailureCounter;
84
85
86 private long senderNrOfRequests;
87
88
89 private String senderReplicationMode;
90
91
92 private long senderTotalBytes;
93
94
95
96
97
98
99 public String getName() {
100 return name;
101 }
102
103
104
105
106
107
108 public void setName(String name) {
109 this.name = name;
110 }
111
112
113
114
115
116
117 public String getInfo() {
118 return info;
119 }
120
121
122
123
124
125
126 public void setInfo(String info) {
127 this.info = info;
128 }
129
130
131
132
133
134
135 public String getManagerClassName() {
136 return managerClassName;
137 }
138
139
140
141
142
143
144 public void setManagerClassName(String managerClassName) {
145 this.managerClassName = managerClassName;
146 }
147
148
149
150
151
152
153 public String getMcastAddress() {
154 return mcastAddress;
155 }
156
157
158
159
160
161
162 public void setMcastAddress(String mcastAddress) {
163 this.mcastAddress = mcastAddress;
164 }
165
166
167
168
169
170
171 public String getMcastBindAddress() {
172 return mcastBindAddress;
173 }
174
175
176
177
178
179
180 public void setMcastBindAddress(String mcastBindAddress) {
181 this.mcastBindAddress = mcastBindAddress;
182 }
183
184
185
186
187
188
189 public String getMcastClusterDomain() {
190 return mcastClusterDomain;
191 }
192
193
194
195
196
197
198 public void setMcastClusterDomain(String mcastClusterDomain) {
199 this.mcastClusterDomain = mcastClusterDomain;
200 }
201
202
203
204
205
206
207 public List<ClusterSender> getMembers() {
208 return members == null ? List.of() : new ArrayList<>(members);
209 }
210
211
212
213
214
215
216 public void setMembers(Collection<ClusterSender> members) {
217 this.members = members == null ? List.of() : new ArrayList<>(members);
218 }
219
220
221
222
223
224
225 public String getTcpListenAddress() {
226 return tcpListenAddress;
227 }
228
229
230
231
232
233
234 public void setTcpListenAddress(String tcpListenAddress) {
235 this.tcpListenAddress = tcpListenAddress;
236 }
237
238
239
240
241
242
243 public int getTcpListenPort() {
244 return tcpListenPort;
245 }
246
247
248
249
250
251
252 public void setTcpListenPort(int tcpListenPort) {
253 this.tcpListenPort = tcpListenPort;
254 }
255
256
257
258
259
260
261 public long getTcpSelectorTimeout() {
262 return tcpSelectorTimeout;
263 }
264
265
266
267
268
269
270 public void setTcpSelectorTimeout(long tcpSelectorTimeout) {
271 this.tcpSelectorTimeout = tcpSelectorTimeout;
272 }
273
274
275
276
277
278
279 public long getNrOfMsgsReceived() {
280 return nrOfMsgsReceived;
281 }
282
283
284
285
286
287
288 public void setNrOfMsgsReceived(long nrOfMsgsReceived) {
289 this.nrOfMsgsReceived = nrOfMsgsReceived;
290 }
291
292
293
294
295
296
297 public long getSenderAckTimeout() {
298 return senderAckTimeout;
299 }
300
301
302
303
304
305
306 public void setSenderAckTimeout(long senderAckTimeout) {
307 this.senderAckTimeout = senderAckTimeout;
308 }
309
310
311
312
313
314
315 public boolean isSenderAutoConnect() {
316 return senderAutoConnect;
317 }
318
319
320
321
322
323
324 public void setSenderAutoConnect(boolean senderAutoConnect) {
325 this.senderAutoConnect = senderAutoConnect;
326 }
327
328
329
330
331
332
333 public long getSenderFailureCounter() {
334 return senderFailureCounter;
335 }
336
337
338
339
340
341
342 public void setSenderFailureCounter(long senderFailureCounter) {
343 this.senderFailureCounter = senderFailureCounter;
344 }
345
346
347
348
349
350
351 public long getSenderNrOfRequests() {
352 return senderNrOfRequests;
353 }
354
355
356
357
358
359
360 public void setSenderNrOfRequests(long senderNrOfRequests) {
361 this.senderNrOfRequests = senderNrOfRequests;
362 }
363
364
365
366
367
368
369 public String getSenderReplicationMode() {
370 return senderReplicationMode;
371 }
372
373
374
375
376
377
378 public void setSenderReplicationMode(String senderReplicationMode) {
379 this.senderReplicationMode = senderReplicationMode;
380 }
381
382
383
384
385
386
387 public long getSenderTotalBytes() {
388 return senderTotalBytes;
389 }
390
391
392
393
394
395
396 public void setSenderTotalBytes(long senderTotalBytes) {
397 this.senderTotalBytes = senderTotalBytes;
398 }
399
400
401
402
403
404
405 public long getMcastDropTime() {
406 return mcastDropTime;
407 }
408
409
410
411
412
413
414 public void setMcastDropTime(long mcastDropTime) {
415 this.mcastDropTime = mcastDropTime;
416 }
417
418
419
420
421
422
423 public long getMcastFrequency() {
424 return mcastFrequency;
425 }
426
427
428
429
430
431
432 public void setMcastFrequency(long mcastFrequency) {
433 this.mcastFrequency = mcastFrequency;
434 }
435
436
437
438
439
440
441 public int getMcastPort() {
442 return mcastPort;
443 }
444
445
446
447
448
449
450 public void setMcastPort(int mcastPort) {
451 this.mcastPort = mcastPort;
452 }
453
454
455
456
457
458
459 public int getMcastSoTimeout() {
460 return mcastSoTimeout;
461 }
462
463
464
465
466
467
468 public void setMcastSoTimeout(int mcastSoTimeout) {
469 this.mcastSoTimeout = mcastSoTimeout;
470 }
471
472
473
474
475
476
477 public int getMcastTtl() {
478 return mcastTtl;
479 }
480
481
482
483
484
485
486 public void setMcastTtl(int mcastTtl) {
487 this.mcastTtl = mcastTtl;
488 }
489
490
491
492
493
494
495 public int getTcpThreadCount() {
496 return tcpThreadCount;
497 }
498
499
500
501
502
503
504 public void setTcpThreadCount(int tcpThreadCount) {
505 this.tcpThreadCount = tcpThreadCount;
506 }
507
508
509
510
511
512
513 public long getTotalReceivedBytes() {
514 return totalReceivedBytes;
515 }
516
517
518
519
520
521
522 public void setTotalReceivedBytes(long totalReceivedBytes) {
523 this.totalReceivedBytes = totalReceivedBytes;
524 }
525
526 }