Repository: incubator-rocketmq Updated Branches: refs/heads/develop a146646b2 -> d7decc84a
[ROCKETMQ-139] Degrade the client related modules' JDK version to 1.6 Project: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/commit/d7decc84 Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/d7decc84 Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/d7decc84 Branch: refs/heads/develop Commit: d7decc84abc32dab63ee423d4d904f28d18cb1d7 Parents: a146646 Author: yukon <[email protected]> Authored: Fri Mar 10 16:41:58 2017 +0800 Committer: yukon <[email protected]> Committed: Fri Mar 10 16:45:40 2017 +0800 ---------------------------------------------------------------------- client/pom.xml | 6 +++++- .../rocketmq/client/consumer/DefaultMQPushConsumer.java | 2 +- .../rocketmq/client/impl/factory/MQClientInstance.java | 6 +++++- .../rocketmq/client/consumer/DefaultMQPullConsumerTest.java | 4 ++-- .../rocketmq/client/consumer/DefaultMQPushConsumerTest.java | 2 +- .../client/consumer/store/LocalFileOffsetStoreTest.java | 2 +- .../client/consumer/store/RemoteBrokerOffsetStoreTest.java | 2 +- .../rocketmq/client/impl/factory/MQClientInstanceTest.java | 6 +++--- .../rocketmq/client/producer/DefaultMQProducerTest.java | 6 +++--- .../producer/selector/SelectMessageQueueByHashTest.java | 2 +- common/pom.xml | 4 ++++ common/src/main/java/org/apache/rocketmq/common/MixAll.java | 4 ++-- .../src/test/java/org/apache/rocketmq/common/MixAllTest.java | 6 +++--- .../org/apache/rocketmq/common/filter/FilterAPITest.java | 2 +- remoting/pom.xml | 4 ++++ .../apache/rocketmq/remoting/netty/NettyRemotingClient.java | 8 ++++---- 16 files changed, 41 insertions(+), 25 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/d7decc84/client/pom.xml ---------------------------------------------------------------------- diff --git a/client/pom.xml b/client/pom.xml index 7c952ac..24d0a54 100644 --- a/client/pom.xml +++ b/client/pom.xml @@ -22,12 +22,16 @@ <version>4.1.0-incubating-SNAPSHOT</version> </parent> - <modelVersion>4.0.0</modelVersion> <packaging>jar</packaging> <artifactId>rocketmq-client</artifactId> <name>rocketmq-client ${project.version}</name> + <properties> + <maven.compiler.source>1.6</maven.compiler.source> + <maven.compiler.target>1.6</maven.compiler.target> + </properties> + <dependencies> <dependency> <groupId>${project.groupId}</groupId> http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/d7decc84/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java b/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java index 2cce03d..3903fe2 100644 --- a/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java +++ b/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java @@ -133,7 +133,7 @@ public class DefaultMQPushConsumer extends ClientConfig implements MQPushConsume /** * Subscription relationship */ - private Map<String /* topic */, String /* sub expression */> subscription = new HashMap<>(); + private Map<String /* topic */, String /* sub expression */> subscription = new HashMap<String, String>(); /** * Message listener http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/d7decc84/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java b/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java index 1343e76..ebcfb62 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java +++ b/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java @@ -842,7 +842,11 @@ public class MQClientInstance { try { this.mQClientAPIImpl.unregisterClient(addr, this.clientId, producerGroup, consumerGroup, 3000); log.info("unregister client[Producer: {} Consumer: {}] from broker[{} {} {}] success", producerGroup, consumerGroup, brokerName, entry1.getKey(), addr); - } catch (RemotingException | InterruptedException | MQBrokerException e) { + } catch (RemotingException e) { + log.error("unregister client exception from broker: " + addr, e); + } catch (InterruptedException e) { + log.error("unregister client exception from broker: " + addr, e); + } catch (MQBrokerException e) { log.error("unregister client exception from broker: " + addr, e); } } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/d7decc84/client/src/test/java/org/apache/rocketmq/client/consumer/DefaultMQPullConsumerTest.java ---------------------------------------------------------------------- diff --git a/client/src/test/java/org/apache/rocketmq/client/consumer/DefaultMQPullConsumerTest.java b/client/src/test/java/org/apache/rocketmq/client/consumer/DefaultMQPullConsumerTest.java index 6672b1e..3314261 100644 --- a/client/src/test/java/org/apache/rocketmq/client/consumer/DefaultMQPullConsumerTest.java +++ b/client/src/test/java/org/apache/rocketmq/client/consumer/DefaultMQPullConsumerTest.java @@ -99,7 +99,7 @@ public class DefaultMQPullConsumerTest { assertThat(pullResult.getNextBeginOffset()).isEqualTo(1024 + 1); assertThat(pullResult.getMinOffset()).isEqualTo(123); assertThat(pullResult.getMaxOffset()).isEqualTo(2048); - assertThat(pullResult.getMsgFoundList()).isEqualTo(new ArrayList<>()); + assertThat(pullResult.getMsgFoundList()).isEqualTo(new ArrayList<Object>()); } @Test @@ -137,7 +137,7 @@ public class DefaultMQPullConsumerTest { assertThat(pullResult.getNextBeginOffset()).isEqualTo(1024 + 1); assertThat(pullResult.getMinOffset()).isEqualTo(123); assertThat(pullResult.getMaxOffset()).isEqualTo(2048); - assertThat(pullResult.getMsgFoundList()).isEqualTo(new ArrayList<>()); + assertThat(pullResult.getMsgFoundList()).isEqualTo(new ArrayList<Object>()); } @Override public void onException(Throwable e) { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/d7decc84/client/src/test/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumerTest.java ---------------------------------------------------------------------- diff --git a/client/src/test/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumerTest.java b/client/src/test/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumerTest.java index 2e0af5a..cdf1d78 100644 --- a/client/src/test/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumerTest.java +++ b/client/src/test/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumerTest.java @@ -143,7 +143,7 @@ public class DefaultMQPushConsumerTest { doReturn(new FindBrokerResult("127.0.0.1:10911", false)).when(mQClientFactory).findBrokerAddressInSubscribe(anyString(), anyLong(), anyBoolean()); doReturn(Collections.singletonList(mQClientFactory.getClientId())).when(mQClientFactory).findConsumerIdList(anyString(), anyString()); - Set<MessageQueue> messageQueueSet = new HashSet<>(); + Set<MessageQueue> messageQueueSet = new HashSet<MessageQueue>(); messageQueueSet.add(createPullRequest().getMessageQueue()); pushConsumer.getDefaultMQPushConsumerImpl().updateTopicSubscribeInfo(topic, messageQueueSet); doReturn(123L).when(rebalancePushImpl).computePullFromWhere(any(MessageQueue.class)); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/d7decc84/client/src/test/java/org/apache/rocketmq/client/consumer/store/LocalFileOffsetStoreTest.java ---------------------------------------------------------------------- diff --git a/client/src/test/java/org/apache/rocketmq/client/consumer/store/LocalFileOffsetStoreTest.java b/client/src/test/java/org/apache/rocketmq/client/consumer/store/LocalFileOffsetStoreTest.java index bf0adcb..22e212b 100644 --- a/client/src/test/java/org/apache/rocketmq/client/consumer/store/LocalFileOffsetStoreTest.java +++ b/client/src/test/java/org/apache/rocketmq/client/consumer/store/LocalFileOffsetStoreTest.java @@ -69,7 +69,7 @@ public class LocalFileOffsetStoreTest { offsetStore.updateOffset(messageQueue, 1024, false); assertThat(offsetStore.readOffset(messageQueue, ReadOffsetType.READ_FROM_STORE)).isEqualTo(-1); - offsetStore.persistAll(new HashSet<>(Collections.singletonList(messageQueue))); + offsetStore.persistAll(new HashSet<MessageQueue>(Collections.singletonList(messageQueue))); assertThat(offsetStore.readOffset(messageQueue, ReadOffsetType.READ_FROM_STORE)).isEqualTo(1024); } } \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/d7decc84/client/src/test/java/org/apache/rocketmq/client/consumer/store/RemoteBrokerOffsetStoreTest.java ---------------------------------------------------------------------- diff --git a/client/src/test/java/org/apache/rocketmq/client/consumer/store/RemoteBrokerOffsetStoreTest.java b/client/src/test/java/org/apache/rocketmq/client/consumer/store/RemoteBrokerOffsetStoreTest.java index a13930f..81c394c 100644 --- a/client/src/test/java/org/apache/rocketmq/client/consumer/store/RemoteBrokerOffsetStoreTest.java +++ b/client/src/test/java/org/apache/rocketmq/client/consumer/store/RemoteBrokerOffsetStoreTest.java @@ -119,7 +119,7 @@ public class RemoteBrokerOffsetStoreTest { assertThat(offsetStore.readOffset(messageQueue, ReadOffsetType.READ_FROM_STORE)).isEqualTo(1023); offsetStore.updateOffset(messageQueue, 1025, false); - offsetStore.persistAll(new HashSet<>(Collections.singletonList(messageQueue))); + offsetStore.persistAll(new HashSet<MessageQueue>(Collections.singletonList(messageQueue))); assertThat(offsetStore.readOffset(messageQueue, ReadOffsetType.READ_FROM_STORE)).isEqualTo(1025); } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/d7decc84/client/src/test/java/org/apache/rocketmq/client/impl/factory/MQClientInstanceTest.java ---------------------------------------------------------------------- diff --git a/client/src/test/java/org/apache/rocketmq/client/impl/factory/MQClientInstanceTest.java b/client/src/test/java/org/apache/rocketmq/client/impl/factory/MQClientInstanceTest.java index eedf0b1..7e0b4f9 100644 --- a/client/src/test/java/org/apache/rocketmq/client/impl/factory/MQClientInstanceTest.java +++ b/client/src/test/java/org/apache/rocketmq/client/impl/factory/MQClientInstanceTest.java @@ -48,17 +48,17 @@ public class MQClientInstanceTest { TopicRouteData topicRouteData = new TopicRouteData(); topicRouteData.setFilterServerTable(new HashMap<String, List<String>>()); - List<BrokerData> brokerDataList = new ArrayList<>(); + List<BrokerData> brokerDataList = new ArrayList<BrokerData>(); BrokerData brokerData = new BrokerData(); brokerData.setBrokerName("BrokerA"); brokerData.setCluster("DefaultCluster"); - HashMap<Long, String> brokerAddrs = new HashMap<>(); + HashMap<Long, String> brokerAddrs = new HashMap<Long, String>(); brokerAddrs.put(0L, "127.0.0.1:10911"); brokerData.setBrokerAddrs(brokerAddrs); brokerDataList.add(brokerData); topicRouteData.setBrokerDatas(brokerDataList); - List<QueueData> queueDataList = new ArrayList<>(); + List<QueueData> queueDataList = new ArrayList<QueueData>(); QueueData queueData = new QueueData(); queueData.setBrokerName("BrokerA"); queueData.setPerm(6); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/d7decc84/client/src/test/java/org/apache/rocketmq/client/producer/DefaultMQProducerTest.java ---------------------------------------------------------------------- diff --git a/client/src/test/java/org/apache/rocketmq/client/producer/DefaultMQProducerTest.java b/client/src/test/java/org/apache/rocketmq/client/producer/DefaultMQProducerTest.java index eddd380..2f035e0 100644 --- a/client/src/test/java/org/apache/rocketmq/client/producer/DefaultMQProducerTest.java +++ b/client/src/test/java/org/apache/rocketmq/client/producer/DefaultMQProducerTest.java @@ -194,17 +194,17 @@ public class DefaultMQProducerTest { TopicRouteData topicRouteData = new TopicRouteData(); topicRouteData.setFilterServerTable(new HashMap<String, List<String>>()); - List<BrokerData> brokerDataList = new ArrayList<>(); + List<BrokerData> brokerDataList = new ArrayList<BrokerData>(); BrokerData brokerData = new BrokerData(); brokerData.setBrokerName("BrokerA"); brokerData.setCluster("DefaultCluster"); - HashMap<Long, String> brokerAddrs = new HashMap<>(); + HashMap<Long, String> brokerAddrs = new HashMap<Long, String>(); brokerAddrs.put(0L, "127.0.0.1:10911"); brokerData.setBrokerAddrs(brokerAddrs); brokerDataList.add(brokerData); topicRouteData.setBrokerDatas(brokerDataList); - List<QueueData> queueDataList = new ArrayList<>(); + List<QueueData> queueDataList = new ArrayList<QueueData>(); QueueData queueData = new QueueData(); queueData.setBrokerName("BrokerA"); queueData.setPerm(6); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/d7decc84/client/src/test/java/org/apache/rocketmq/client/producer/selector/SelectMessageQueueByHashTest.java ---------------------------------------------------------------------- diff --git a/client/src/test/java/org/apache/rocketmq/client/producer/selector/SelectMessageQueueByHashTest.java b/client/src/test/java/org/apache/rocketmq/client/producer/selector/SelectMessageQueueByHashTest.java index 64ef21d..056e910 100644 --- a/client/src/test/java/org/apache/rocketmq/client/producer/selector/SelectMessageQueueByHashTest.java +++ b/client/src/test/java/org/apache/rocketmq/client/producer/selector/SelectMessageQueueByHashTest.java @@ -34,7 +34,7 @@ public class SelectMessageQueueByHashTest { Message message = new Message(topic, new byte[] {}); - List<MessageQueue> messageQueues = new ArrayList<>(); + List<MessageQueue> messageQueues = new ArrayList<MessageQueue>(); for (int i = 0; i < 10; i++) { MessageQueue messageQueue = new MessageQueue(topic, "DefaultBroker", i); messageQueues.add(messageQueue); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/d7decc84/common/pom.xml ---------------------------------------------------------------------- diff --git a/common/pom.xml b/common/pom.xml index c2ab187..835ffa6 100644 --- a/common/pom.xml +++ b/common/pom.xml @@ -27,6 +27,10 @@ <artifactId>rocketmq-common</artifactId> <name>rocketmq-common ${project.version}</name> + <properties> + <maven.compiler.source>1.6</maven.compiler.source> + <maven.compiler.target>1.6</maven.compiler.target> + </properties> <dependencies> <dependency> http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/d7decc84/common/src/main/java/org/apache/rocketmq/common/MixAll.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/MixAll.java b/common/src/main/java/org/apache/rocketmq/common/MixAll.java index cbb395a..4a54a60 100644 --- a/common/src/main/java/org/apache/rocketmq/common/MixAll.java +++ b/common/src/main/java/org/apache/rocketmq/common/MixAll.java @@ -256,7 +256,7 @@ public class MixAll { if (null == value) { value = ""; } - } catch (IllegalArgumentException | IllegalAccessException e) { + } catch (IllegalAccessException e) { e.printStackTrace(); } @@ -313,7 +313,7 @@ public class MixAll { try { field.setAccessible(true); value = field.get(object); - } catch (IllegalArgumentException | IllegalAccessException e) { + } catch (IllegalAccessException e) { e.printStackTrace(); } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/d7decc84/common/src/test/java/org/apache/rocketmq/common/MixAllTest.java ---------------------------------------------------------------------- diff --git a/common/src/test/java/org/apache/rocketmq/common/MixAllTest.java b/common/src/test/java/org/apache/rocketmq/common/MixAllTest.java index 06024c3..8220981 100644 --- a/common/src/test/java/org/apache/rocketmq/common/MixAllTest.java +++ b/common/src/test/java/org/apache/rocketmq/common/MixAllTest.java @@ -59,9 +59,9 @@ public class MixAllTest { file.delete(); } file.createNewFile(); - try (PrintWriter out = new PrintWriter(fileName)) { - out.write("TestForMixAll"); - } + PrintWriter out = new PrintWriter(fileName); + out.write("TestForMixAll"); + out.close(); String string = MixAll.file2String(fileName); assertThat(string).isEqualTo("TestForMixAll"); file.delete(); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/d7decc84/common/src/test/java/org/apache/rocketmq/common/filter/FilterAPITest.java ---------------------------------------------------------------------- diff --git a/common/src/test/java/org/apache/rocketmq/common/filter/FilterAPITest.java b/common/src/test/java/org/apache/rocketmq/common/filter/FilterAPITest.java index 097a01c..5137f32 100644 --- a/common/src/test/java/org/apache/rocketmq/common/filter/FilterAPITest.java +++ b/common/src/test/java/org/apache/rocketmq/common/filter/FilterAPITest.java @@ -36,7 +36,7 @@ public class FilterAPITest { assertThat(subscriptionData.getTopic()).isEqualTo(topic); assertThat(subscriptionData.getSubString()).isEqualTo(subString); String [] tags = subString.split("\\|\\|"); - Set<String> tagSet = new HashSet<>(); + Set<String> tagSet = new HashSet<String>(); for (String tag : tags) { tagSet.add(tag.trim()); } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/d7decc84/remoting/pom.xml ---------------------------------------------------------------------- diff --git a/remoting/pom.xml b/remoting/pom.xml index b25e062..1552341 100644 --- a/remoting/pom.xml +++ b/remoting/pom.xml @@ -27,6 +27,10 @@ <artifactId>rocketmq-remoting</artifactId> <name>rocketmq-remoting ${project.version}</name> + <properties> + <maven.compiler.source>1.6</maven.compiler.source> + <maven.compiler.target>1.6</maven.compiler.target> + </properties> <dependencies> <dependency> http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/d7decc84/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java ---------------------------------------------------------------------- diff --git a/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java b/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java index d84f2a8..85f9244 100644 --- a/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java +++ b/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java @@ -73,12 +73,12 @@ public class NettyRemotingClient extends NettyRemotingAbstract implements Remoti private final Bootstrap bootstrap = new Bootstrap(); private final EventLoopGroup eventLoopGroupWorker; private final Lock lockChannelTables = new ReentrantLock(); - private final ConcurrentHashMap<String /* addr */, ChannelWrapper> channelTables = new ConcurrentHashMap<>(); + private final ConcurrentHashMap<String /* addr */, ChannelWrapper> channelTables = new ConcurrentHashMap<String, ChannelWrapper>(); private final Timer timer = new Timer("ClientHouseKeepingService", true); - private final AtomicReference<List<String>> namesrvAddrList = new AtomicReference<>(); - private final AtomicReference<String> namesrvAddrChoosed = new AtomicReference<>(); + private final AtomicReference<List<String>> namesrvAddrList = new AtomicReference<List<String>>(); + private final AtomicReference<String> namesrvAddrChoosed = new AtomicReference<String>(); private final AtomicInteger namesrvIndex = new AtomicInteger(initValueIndex()); private final Lock lockNamesrvChannel = new ReentrantLock(); @@ -522,7 +522,7 @@ public class NettyRemotingClient extends NettyRemotingAbstract implements Remoti executorThis = this.publicExecutor; } - Pair<NettyRequestProcessor, ExecutorService> pair = new Pair<>(processor, executorThis); + Pair<NettyRequestProcessor, ExecutorService> pair = new Pair<NettyRequestProcessor, ExecutorService>(processor, executorThis); this.processorTable.put(requestCode, pair); }
