Repository: activemq Updated Branches: refs/heads/activemq-5.14.x 776418bae -> cd82533f3
[AMQ-6586] Compilation of activemq-unit-test fails Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/659d1f6b Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/659d1f6b Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/659d1f6b Branch: refs/heads/activemq-5.14.x Commit: 659d1f6ba545dd283e80489425b616c75fee973d Parents: 776418b Author: Krzysztof Sobkowiak <[email protected]> Authored: Tue Jan 31 20:36:13 2017 +0100 Committer: Krzysztof Sobkowiak <[email protected]> Committed: Tue Jan 31 20:36:13 2017 +0100 ---------------------------------------------------------------------- .../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/659d1f6b/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/659d1f6b/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;
