Repository: activemq Updated Branches: refs/heads/master 6e17c2a5a -> f09493727
[AMQ-6586] Compilation of activemq-unit-test fails (cherry picked from commit 659d1f6ba545dd283e80489425b616c75fee973d) Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/f0949372 Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/f0949372 Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/f0949372 Branch: refs/heads/master Commit: f09493727f95afce417414f2b27b58c429ed4d1e Parents: 6e17c2a Author: Krzysztof Sobkowiak <[email protected]> Authored: Tue Jan 31 20:36:13 2017 +0100 Committer: Christopher L. Shannon (cshannon) <[email protected]> Committed: Tue Jan 31 15:32:34 2017 -0500 ---------------------------------------------------------------------- .../java/org/apache/activemq/broker/region/QueuePurgeTest.java | 4 ++-- .../activemq/transport/tcp/TcpTransportCloseSocketTest.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/f0949372/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/QueuePurgeTest.java ---------------------------------------------------------------------- diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/QueuePurgeTest.java b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/QueuePurgeTest.java index 30b2cb2..3e8b647 100644 --- a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/QueuePurgeTest.java +++ b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/QueuePurgeTest.java @@ -191,9 +191,9 @@ public class QueuePurgeTest extends CombinationTestSupport { private void testConcurrentPurgeAndSend(boolean prioritizedMessages) throws Exception { applyBrokerSpoolingPolicy(false); createProducerAndSendMessages(NUM_TO_SEND / 2); - QueueViewMBean proxy = getProxyToQueueViewMBean(); + final QueueViewMBean proxy = getProxyToQueueViewMBean(); createConsumer(); - long start = System.currentTimeMillis(); + final long start = System.currentTimeMillis(); ExecutorService service = Executors.newFixedThreadPool(1); try { LOG.info("purging.."); http://git-wip-us.apache.org/repos/asf/activemq/blob/f0949372/activemq-unit-tests/src/test/java/org/apache/activemq/transport/tcp/TcpTransportCloseSocketTest.java ---------------------------------------------------------------------- diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/transport/tcp/TcpTransportCloseSocketTest.java b/activemq-unit-tests/src/test/java/org/apache/activemq/transport/tcp/TcpTransportCloseSocketTest.java index ad2080b..252dd22 100644 --- a/activemq-unit-tests/src/test/java/org/apache/activemq/transport/tcp/TcpTransportCloseSocketTest.java +++ b/activemq-unit-tests/src/test/java/org/apache/activemq/transport/tcp/TcpTransportCloseSocketTest.java @@ -105,7 +105,7 @@ public class TcpTransportCloseSocketTest { factory.setBrokerURL(uri); factory.setClientID("id"); - TcpTransportServer server = (TcpTransportServer) brokerService.getTransportConnectorByName("tcp").getServer(); + final TcpTransportServer server = (TcpTransportServer) brokerService.getTransportConnectorByName("tcp").getServer(); //Try and create 2 connections, the second should fail because of a duplicate clientId int failed = 0;
