|
1 package org.jgroups.jmx.protocols;
2
3 import org.jgroups.Address;
4 import org.jgroups.stack.Protocol;
5
6 import java.net.UnknownHostException  ;
7 import java.util.List ;
8
9
13 public class TP extends org.jgroups.jmx.Protocol implements TPMBean {
14 org.jgroups.protocols.TP tp;
15
16 public TP() {
17 }
18
19 public TP(Protocol p) {
20 super(p);
21 tp=(org.jgroups.protocols.TP)p;
22 }
23
24 public void attachProtocol(Protocol p) {
25 super.attachProtocol(p);
26 tp=(org.jgroups.protocols.TP)p;
27 }
28
29 public long getMessagesSent() {
30 return tp.getNumMessagesSent();
31 }
32
33 public long getMessagesReceived() {
34 return tp.getNumMessagesReceived();
35 }
36
37 public long getBytesSent() {
38 return tp.getNumBytesSent();
39 }
40
41 public long getBytesReceived() {
42 return tp.getNumBytesReceived();
43 }
44
45 public Address getLocalAddress() {
46 return tp.getLocalAddress();
47 }
48
49 public String getBindAddress() {
50 return tp.getBindAddress();
51 }
52
53 public String getChannelName() {
54 return tp.getChannelName();
55 }
56
57 public void setBindAddress(String bind_address) throws UnknownHostException {
58 tp.setBindAddress(bind_address);
59 }
60
61 public boolean isReceiveOnAllInterfaces() {
62 return tp.isReceiveOnAllInterfaces();
63 }
64
65 public List getReceiveInterfaces() {
66 return tp.getReceiveInterfaces();
67 }
68
69 public boolean isSendOnAllInterfaces() {
70 return tp.isSendOnAllInterfaces();
71 }
72
73 public List getSendInterfaces() {
74 return tp.getSendInterfaces();
75 }
76
77 public boolean isDiscardIncompatiblePackets() {
78 return tp.isDiscardIncompatiblePackets();
79 }
80
81 public void setDiscardIncompatiblePackets(boolean flag) {
82 tp.setDiscardIncompatiblePackets(flag);
83 }
84
85 public boolean isEnableBundling() {
86 return tp.isEnableBundling();
87 }
88
89 public void setEnableBundling(boolean flag) {
90 tp.setEnableBundling(flag);
91 }
92
93 public int getMaxBundleSize() {
94 return tp.getMaxBundleSize();
95 }
96
97 public void setMaxBundleSize(int size) {
98 tp.setMaxBundleSize(size);
99 }
100
101 public long getMaxBundleTimeout() {
102 return tp.getMaxBundleTimeout();
103 }
104
105 public void setMaxBundleTimeout(long timeout) {
106 tp.setMaxBundleTimeout(timeout);
107 }
108
109 public boolean isLoopback() {
110 return tp.isLoopback();
111 }
112
113 public void setLoopback(boolean b) {
114 tp.setLoopback(b);
115 }
116
117 public boolean isUseIncomingPacketHandler() {
118 return tp.isUseIncomingPacketHandler();
119 }
120
121
122
123
124 public int getOOBMinPoolSize() {
125 return tp.getOOBMinPoolSize();
126 }
127
128 public void setOOBMinPoolSize(int size) {
129 tp.setOOBMinPoolSize(size);
130 }
131
132 public int getOOBMaxPoolSize() {
133 return tp.getOOBMaxPoolSize();
134 }
135
136 public void setOOBMaxPoolSize(int size) {
137 tp.setOOBMaxPoolSize(size);
138 }
139
140 public int getOOBPoolSize() {
141 return tp.getOOBPoolSize();
142 }
143
144 public long getOOBKeepAliveTime() {
145 return tp.getOOBKeepAliveTime();
146 }
147
148 public void setOOBKeepAliveTime(long time) {
149 tp.setOOBKeepAliveTime(time);
150 }
151
152 public long getOOBMessages() {
153 return tp.getOOBMessages();
154 }
155
156 public int getOOBQueueSize() {
157 return tp.getOOBQueueSize();
158 }
159
160 public int getOOBMaxQueueSize() {
161 return tp.getOOBMaxQueueSize();
162 }
163
164
165
166 public int getIncomingMinPoolSize() {
167 return tp.getIncomingMinPoolSize();
168 }
169
170 public void setIncomingMinPoolSize(int size) {
171 tp.setIncomingMinPoolSize(size);
172 }
173
174 public int getIncomingMaxPoolSize() {
175 return tp.getIncomingMaxPoolSize();
176 }
177
178 public void setIncomingMaxPoolSize(int size) {
179 tp.setIncomingMaxPoolSize(size);
180 }
181
182 public int getIncomingPoolSize() {
183 return tp.getIncomingPoolSize();
184 }
185
186 public long getIncomingKeepAliveTime() {
187 return tp.getIncomingKeepAliveTime();
188 }
189
190 public void setIncomingKeepAliveTime(long time) {
191 tp.setIncomingKeepAliveTime(time);
192 }
193
194 public long getIncomingMessages() {
195 return tp.getIncomingMessages();
196 }
197
198 public int getIncomingQueueSize() {
199 return tp.getIncomingQueueSize();
200 }
201
202 public int getIncomingMaxQueueSize() {
203 return tp.getIncomingMaxQueueSize();
204 }
205
206
207 }
208 |
Popular Tags |
Java API By Example, From Geeks To Geeks.