Remove dead code
This commit is contained in:
parent
fbb92482b8
commit
782d3419b8
|
@ -179,8 +179,6 @@ public final class UDPBroadcastEndpointFactory implements BroadcastEndpointFacto
|
||||||
}
|
}
|
||||||
else {
|
else {
|
||||||
if (localAddress != null) {
|
if (localAddress != null) {
|
||||||
java.util.Random random = new java.util.Random(System.currentTimeMillis());
|
|
||||||
|
|
||||||
for (int i = 0; i < 100; i++) {
|
for (int i = 0; i < 100; i++) {
|
||||||
int nextPort = RandomUtil.randomInterval(3000, 4000);
|
int nextPort = RandomUtil.randomInterval(3000, 4000);
|
||||||
try {
|
try {
|
||||||
|
|
|
@ -180,7 +180,6 @@ public class AddressControlImpl extends AbstractControl implements AddressContro
|
||||||
long totalMsgs = 0;
|
long totalMsgs = 0;
|
||||||
try {
|
try {
|
||||||
Bindings bindings = postOffice.getBindingsForAddress(address);
|
Bindings bindings = postOffice.getBindingsForAddress(address);
|
||||||
List<String> queueNames = new ArrayList<>();
|
|
||||||
for (Binding binding : bindings.getBindings()) {
|
for (Binding binding : bindings.getBindings()) {
|
||||||
if (binding instanceof QueueBinding) {
|
if (binding instanceof QueueBinding) {
|
||||||
totalMsgs += ((QueueBinding) binding).getQueue().getMessageCount();
|
totalMsgs += ((QueueBinding) binding).getQueue().getMessageCount();
|
||||||
|
|
Loading…
Reference in New Issue