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