You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cs...@apache.org on 2017/01/31 20:35:52 UTC
activemq git commit: [AMQ-6586] Compilation of activemq-unit-test
fails
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 <kr...@gmail.com>
Authored: Tue Jan 31 20:36:13 2017 +0100
Committer: Christopher L. Shannon (cshannon) <ch...@gmail.com>
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;