Remove unnecessary semicolons
This commit is contained in:
parent
7bf3923cee
commit
d0223af640
|
@ -209,7 +209,6 @@ public class ActiveMQConnectionFactory extends JNDIBaseStorable implements Conne
|
||||||
params.clear();
|
params.clear();
|
||||||
|
|
||||||
this.vmBrokerUri = URISupport.createRemainingURI(uri, params);
|
this.vmBrokerUri = URISupport.createRemainingURI(uri, params);
|
||||||
;
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (URISyntaxException e) {
|
catch (URISyntaxException e) {
|
||||||
|
|
|
@ -168,7 +168,6 @@ public class JMSConsumerTest extends JmsTestSupport {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
;
|
|
||||||
|
|
||||||
final ExecutorService executor = Executors.newCachedThreadPool();
|
final ExecutorService executor = Executors.newCachedThreadPool();
|
||||||
consumer.setMessageListener(new MessageListener() {
|
consumer.setMessageListener(new MessageListener() {
|
||||||
|
|
|
@ -121,7 +121,6 @@ public class JmsQueueBrowserTest extends JmsTestSupport {
|
||||||
for (int i = 0; i < 10; i++) {
|
for (int i = 0; i < 10; i++) {
|
||||||
outbound[i] = session.createTextMessage(i + " Message");
|
outbound[i] = session.createTextMessage(i + " Message");
|
||||||
}
|
}
|
||||||
;
|
|
||||||
|
|
||||||
// lets consume any outstanding messages from previous test runs
|
// lets consume any outstanding messages from previous test runs
|
||||||
while (consumer.receive(1000) != null) {
|
while (consumer.receive(1000) != null) {
|
||||||
|
@ -178,7 +177,6 @@ public class JmsQueueBrowserTest extends JmsTestSupport {
|
||||||
for (int i = 0; i < 10; i++) {
|
for (int i = 0; i < 10; i++) {
|
||||||
outbound[i] = session.createTextMessage(i + " Message");
|
outbound[i] = session.createTextMessage(i + " Message");
|
||||||
}
|
}
|
||||||
;
|
|
||||||
|
|
||||||
// lets consume any outstanding messages from previous test runs
|
// lets consume any outstanding messages from previous test runs
|
||||||
while (consumer.receive(1000) != null) {
|
while (consumer.receive(1000) != null) {
|
||||||
|
|
|
@ -154,7 +154,6 @@ public class JmsSendReceiveWithMessageExpirationTest extends TestSupport {
|
||||||
}
|
}
|
||||||
received.acknowledge();
|
received.acknowledge();
|
||||||
}
|
}
|
||||||
;
|
|
||||||
|
|
||||||
assertEquals("got all (normal plus one with ttl) messages", messageCount + 1, messages.size());
|
assertEquals("got all (normal plus one with ttl) messages", messageCount + 1, messages.size());
|
||||||
|
|
||||||
|
@ -162,7 +161,6 @@ public class JmsSendReceiveWithMessageExpirationTest extends TestSupport {
|
||||||
while ((received = dlqConsumer.receive(1000)) != null) {
|
while ((received = dlqConsumer.receive(1000)) != null) {
|
||||||
dlqMessages.add(received);
|
dlqMessages.add(received);
|
||||||
}
|
}
|
||||||
;
|
|
||||||
|
|
||||||
assertEquals("got dlq messages", data.length - 1, dlqMessages.size());
|
assertEquals("got dlq messages", data.length - 1, dlqMessages.size());
|
||||||
|
|
||||||
|
|
|
@ -39,8 +39,6 @@ public abstract class SpringTestSupport extends TestCase {
|
||||||
|
|
||||||
protected abstract AbstractApplicationContext createApplicationContext();
|
protected abstract AbstractApplicationContext createApplicationContext();
|
||||||
|
|
||||||
;
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
protected void tearDown() throws Exception {
|
protected void tearDown() throws Exception {
|
||||||
if (context != null) {
|
if (context != null) {
|
||||||
|
|
|
@ -172,8 +172,6 @@ public abstract class TestSupport extends CombinationTestSupport {
|
||||||
|
|
||||||
public static enum PersistenceAdapterChoice {LevelDB, KahaDB, AMQ, JDBC, MEM}
|
public static enum PersistenceAdapterChoice {LevelDB, KahaDB, AMQ, JDBC, MEM}
|
||||||
|
|
||||||
;
|
|
||||||
|
|
||||||
public PersistenceAdapter setDefaultPersistenceAdapter(BrokerService broker) throws IOException {
|
public PersistenceAdapter setDefaultPersistenceAdapter(BrokerService broker) throws IOException {
|
||||||
return setPersistenceAdapter(broker, defaultPersistenceAdapter);
|
return setPersistenceAdapter(broker, defaultPersistenceAdapter);
|
||||||
}
|
}
|
||||||
|
|
|
@ -175,8 +175,6 @@ public class BrokerBenchmark extends BrokerTestSupport {
|
||||||
producersFinished.release();
|
producersFinished.release();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
;
|
|
||||||
}.start();
|
}.start();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -351,8 +351,6 @@ public class BrokerTestSupport extends CombinationTestSupport {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
;
|
|
||||||
|
|
||||||
protected void assertNoMessagesLeft(StubConnection connection) throws InterruptedException {
|
protected void assertNoMessagesLeft(StubConnection connection) throws InterruptedException {
|
||||||
long wait = FAST_NO_MESSAGE_LEFT_ASSERT ? 0 : maxWait;
|
long wait = FAST_NO_MESSAGE_LEFT_ASSERT ? 0 : maxWait;
|
||||||
while (true) {
|
while (true) {
|
||||||
|
|
|
@ -62,8 +62,6 @@ public class MarshallingBrokerTest extends BrokerTest {
|
||||||
protected void dispatch(Command command) throws InterruptedException, IOException {
|
protected void dispatch(Command command) throws InterruptedException, IOException {
|
||||||
super.dispatch(wireFormat.unmarshal(wireFormat.marshal(command)));
|
super.dispatch(wireFormat.unmarshal(wireFormat.marshal(command)));
|
||||||
}
|
}
|
||||||
|
|
||||||
;
|
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -96,8 +96,6 @@ public class MessageListenerDeadLetterTest extends DeadLetterTestSupport {
|
||||||
super.tearDown();
|
super.tearDown();
|
||||||
}
|
}
|
||||||
|
|
||||||
;
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
protected ActiveMQConnectionFactory createConnectionFactory() throws Exception {
|
protected ActiveMQConnectionFactory createConnectionFactory() throws Exception {
|
||||||
ActiveMQConnectionFactory answer = super.createConnectionFactory();
|
ActiveMQConnectionFactory answer = super.createConnectionFactory();
|
||||||
|
|
|
@ -164,8 +164,6 @@ public class QueueDuplicatesFromStoreTest extends TestCase {
|
||||||
public void destroy() {
|
public void destroy() {
|
||||||
}
|
}
|
||||||
|
|
||||||
;
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void gc() {
|
public void gc() {
|
||||||
}
|
}
|
||||||
|
|
|
@ -75,7 +75,6 @@ public class AMQ1936Test extends TestCase {
|
||||||
broker.setDeleteAllMessagesOnStartup(true);
|
broker.setDeleteAllMessagesOnStartup(true);
|
||||||
broker.start();
|
broker.start();
|
||||||
connectionFactory = new ActiveMQConnectionFactory("vm://test");
|
connectionFactory = new ActiveMQConnectionFactory("vm://test");
|
||||||
;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|
|
@ -195,7 +195,6 @@ public class AMQ3014Test {
|
||||||
}
|
}
|
||||||
|
|
||||||
Assert.assertFalse("Timed out waiting for bridge to form.", remoteBrokerInfos.isEmpty());
|
Assert.assertFalse("Timed out waiting for bridge to form.", remoteBrokerInfos.isEmpty());
|
||||||
;
|
|
||||||
Assert.assertNotNull("Local broker ID is null.", remoteBrokerInfos.get(0).getBrokerId());
|
Assert.assertNotNull("Local broker ID is null.", remoteBrokerInfos.get(0).getBrokerId());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -192,8 +192,6 @@ public class AMQ3405Test extends TestSupport {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
;
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
protected ActiveMQConnectionFactory createConnectionFactory() throws Exception {
|
protected ActiveMQConnectionFactory createConnectionFactory() throws Exception {
|
||||||
ActiveMQConnectionFactory answer = super.createConnectionFactory();
|
ActiveMQConnectionFactory answer = super.createConnectionFactory();
|
||||||
|
|
|
@ -493,7 +493,6 @@ public class AMQ4083Test {
|
||||||
}
|
}
|
||||||
received.acknowledge();
|
received.acknowledge();
|
||||||
}
|
}
|
||||||
;
|
|
||||||
|
|
||||||
assertEquals("got messages", messageCount + 1, messages.size());
|
assertEquals("got messages", messageCount + 1, messages.size());
|
||||||
|
|
||||||
|
@ -501,7 +500,6 @@ public class AMQ4083Test {
|
||||||
while ((received = dlqConsumer.receive(1000)) != null) {
|
while ((received = dlqConsumer.receive(1000)) != null) {
|
||||||
dlqMessages.add(received);
|
dlqMessages.add(received);
|
||||||
}
|
}
|
||||||
;
|
|
||||||
|
|
||||||
assertEquals("got dlq messages", data.length - 1, dlqMessages.size());
|
assertEquals("got dlq messages", data.length - 1, dlqMessages.size());
|
||||||
|
|
||||||
|
|
|
@ -246,7 +246,6 @@ public class AMQ4485LowLimitTest extends JmsMultipleBrokersTestSupport {
|
||||||
if (tally.expected.size() == 1) {
|
if (tally.expected.size() == 1) {
|
||||||
startConsumer(tally.brokerName, tally.destination);
|
startConsumer(tally.brokerName, tally.destination);
|
||||||
}
|
}
|
||||||
;
|
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
LOG.info("got tally on " + tally.brokerName);
|
LOG.info("got tally on " + tally.brokerName);
|
||||||
|
|
|
@ -45,7 +45,6 @@ public class ActiveMQAdmin implements Admin {
|
||||||
final Hashtable<String, String> env = new Hashtable<>();
|
final Hashtable<String, String> env = new Hashtable<>();
|
||||||
env.put("java.naming.factory.initial", "org.eclipse.jetty.jndi.InitialContextFactory");
|
env.put("java.naming.factory.initial", "org.eclipse.jetty.jndi.InitialContextFactory");
|
||||||
env.put("java.naming.factory.url.pkgs", "org.eclipse.jetty.jndi");
|
env.put("java.naming.factory.url.pkgs", "org.eclipse.jetty.jndi");
|
||||||
;
|
|
||||||
context = new InitialContext(env);
|
context = new InitialContext(env);
|
||||||
}
|
}
|
||||||
catch (NamingException e) {
|
catch (NamingException e) {
|
||||||
|
|
|
@ -92,7 +92,6 @@ public class NetworkFailoverTest extends TestCase {
|
||||||
catch (JMSException e) {
|
catch (JMSException e) {
|
||||||
e.printStackTrace();
|
e.printStackTrace();
|
||||||
}
|
}
|
||||||
;
|
|
||||||
}
|
}
|
||||||
catch (Exception e) {
|
catch (Exception e) {
|
||||||
LOG.warn("*** Responder listener caught exception: ", e);
|
LOG.warn("*** Responder listener caught exception: ", e);
|
||||||
|
|
|
@ -253,7 +253,6 @@ class Producer implements Runnable {
|
||||||
class Consumer implements Runnable {
|
class Consumer implements Runnable {
|
||||||
|
|
||||||
private static final Logger LOG = LoggerFactory.getLogger(Consumer.class);
|
private static final Logger LOG = LoggerFactory.getLogger(Consumer.class);
|
||||||
;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* connect to broker and receive messages
|
* connect to broker and receive messages
|
||||||
|
|
|
@ -46,7 +46,6 @@ public class KahaDBStoreRecoveryBrokerTest extends RecoveryBrokerTest {
|
||||||
|
|
||||||
enum CorruptionType {None, FailToLoad, LoadInvalid, LoadCorrupt, LoadOrderIndex0}
|
enum CorruptionType {None, FailToLoad, LoadInvalid, LoadCorrupt, LoadOrderIndex0}
|
||||||
|
|
||||||
;
|
|
||||||
public CorruptionType failTest = CorruptionType.None;
|
public CorruptionType failTest = CorruptionType.None;
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|
|
@ -232,7 +232,6 @@ public class PListTest {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
;
|
|
||||||
|
|
||||||
class B implements Runnable {
|
class B implements Runnable {
|
||||||
|
|
||||||
|
@ -259,7 +258,6 @@ public class PListTest {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
;
|
|
||||||
|
|
||||||
executor.execute(new A());
|
executor.execute(new A());
|
||||||
executor.execute(new A());
|
executor.execute(new A());
|
||||||
|
|
|
@ -52,8 +52,6 @@ public class ServerSocketTstFactory extends ServerSocketFactory {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
;
|
|
||||||
|
|
||||||
private final Random rnd;
|
private final Random rnd;
|
||||||
|
|
||||||
public ServerSocketTstFactory() {
|
public ServerSocketTstFactory() {
|
||||||
|
|
|
@ -139,8 +139,6 @@ public class SocketTstFactory extends SocketFactory {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
;
|
|
||||||
|
|
||||||
private final Random rnd;
|
private final Random rnd;
|
||||||
|
|
||||||
public SocketTstFactory() {
|
public SocketTstFactory() {
|
||||||
|
|
|
@ -264,7 +264,6 @@ public class ConcurrentProducerDurableConsumerTest extends TestSupport {
|
||||||
LOG.info("Signalled add consumer");
|
LOG.info("Signalled add consumer");
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
;
|
|
||||||
if (count % 5000 == 0) {
|
if (count % 5000 == 0) {
|
||||||
LOG.info("Sent " + count + ", singleSendMax:" + max);
|
LOG.info("Sent " + count + ", singleSendMax:" + max);
|
||||||
}
|
}
|
||||||
|
|
|
@ -249,7 +249,6 @@ public class ConcurrentProducerQueueConsumerTest extends TestSupport {
|
||||||
LOG.info("Signalled add consumer");
|
LOG.info("Signalled add consumer");
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
;
|
|
||||||
if (count % 5000 == 0) {
|
if (count % 5000 == 0) {
|
||||||
LOG.info("Sent " + count + ", singleSendMax:" + max);
|
LOG.info("Sent " + count + ", singleSendMax:" + max);
|
||||||
}
|
}
|
||||||
|
|
|
@ -214,8 +214,6 @@ public class ExpiredMessagesTest extends CombinationTestSupport {
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
;
|
|
||||||
|
|
||||||
private MessageConsumer createDlqConsumer(Connection connection) throws Exception {
|
private MessageConsumer createDlqConsumer(Connection connection) throws Exception {
|
||||||
return connection.createSession(false, Session.AUTO_ACKNOWLEDGE).createConsumer(dlqDestination);
|
return connection.createSession(false, Session.AUTO_ACKNOWLEDGE).createConsumer(dlqDestination);
|
||||||
}
|
}
|
||||||
|
|
|
@ -198,7 +198,6 @@ public class JdbcDurableSubDupTest {
|
||||||
}
|
}
|
||||||
catch (InterruptedException e) {
|
catch (InterruptedException e) {
|
||||||
}
|
}
|
||||||
;
|
|
||||||
|
|
||||||
try {
|
try {
|
||||||
TextMessage m = (TextMessage) message;
|
TextMessage m = (TextMessage) message;
|
||||||
|
|
|
@ -163,7 +163,6 @@ public class TestBrokerConnectionDuplexExcludedDestinations extends TestCase {
|
||||||
// we should be able to receive excluded queue message on Hub
|
// we should be able to receive excluded queue message on Hub
|
||||||
MessageConsumer excludedConsumerHub = hubSession.createConsumer(excludedQueueHub);
|
MessageConsumer excludedConsumerHub = hubSession.createConsumer(excludedQueueHub);
|
||||||
msg = excludedConsumerHub.receive(200);
|
msg = excludedConsumerHub.receive(200);
|
||||||
;
|
|
||||||
assertEquals(excludedMsgHub, msg);
|
assertEquals(excludedMsgHub, msg);
|
||||||
|
|
||||||
hubProducer.close();
|
hubProducer.close();
|
||||||
|
|
|
@ -31,8 +31,6 @@ public class LinkedNodeTest extends TestCase {
|
||||||
this.v = v;
|
this.v = v;
|
||||||
}
|
}
|
||||||
|
|
||||||
;
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public String toString() {
|
public String toString() {
|
||||||
return "" + v;
|
return "" + v;
|
||||||
|
|
Loading…
Reference in New Issue