You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by du...@apache.org on 2019/01/02 16:45:38 UTC
[rocketmq] 14/14: Modify license header
This is an automated email from the ASF dual-hosted git repository.
duhengforever pushed a commit to branch snode
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
commit cd4403ce5a6d2747cae924e643371198478b16d3
Author: duhenglucky <du...@gmail.com>
AuthorDate: Thu Jan 3 00:44:09 2019 +0800
Modify license header
---
.../apache/rocketmq/broker/processor/PullMessageProcessorTest.java | 3 +++
snode/src/main/java/org/apache/rocketmq/snode/SnodeController.java | 4 ++--
snode/src/main/java/org/apache/rocketmq/snode/SnodeStartup.java | 4 ++--
snode/src/main/java/org/apache/rocketmq/snode/client/PushSession.java | 4 ++--
snode/src/main/java/org/apache/rocketmq/snode/config/SnodeConfig.java | 4 ++--
.../main/java/org/apache/rocketmq/snode/constant/SnodeConstant.java | 4 ++--
.../main/java/org/apache/rocketmq/snode/exception/SnodeException.java | 4 ++--
.../java/org/apache/rocketmq/snode/interceptor/ExceptionContext.java | 4 ++--
.../java/org/apache/rocketmq/snode/interceptor/InterceptorGroup.java | 4 ++--
.../java/org/apache/rocketmq/snode/interceptor/RequestContext.java | 4 ++--
.../java/org/apache/rocketmq/snode/interceptor/ResponseContext.java | 4 ++--
.../org/apache/rocketmq/snode/processor/PullMessageProcessor.java | 4 ++--
.../org/apache/rocketmq/snode/processor/SendMessageProcessor.java | 4 ++--
.../src/main/java/org/apache/rocketmq/snode/service/EnodeService.java | 4 ++--
.../src/main/java/org/apache/rocketmq/snode/service/NnodeService.java | 4 ++--
.../src/main/java/org/apache/rocketmq/snode/service/PushService.java | 4 ++--
.../main/java/org/apache/rocketmq/snode/service/ScheduledService.java | 4 ++--
.../java/org/apache/rocketmq/snode/service/impl/EnodeServiceImpl.java | 4 ++--
.../java/org/apache/rocketmq/snode/service/impl/NnodeServiceImpl.java | 4 ++--
.../org/apache/rocketmq/snode/service/impl/ScheduledServiceImpl.java | 4 ++--
20 files changed, 41 insertions(+), 38 deletions(-)
diff --git a/broker/src/test/java/org/apache/rocketmq/broker/processor/PullMessageProcessorTest.java b/broker/src/test/java/org/apache/rocketmq/broker/processor/PullMessageProcessorTest.java
index 48d09bc..a5a32c4 100644
--- a/broker/src/test/java/org/apache/rocketmq/broker/processor/PullMessageProcessorTest.java
+++ b/broker/src/test/java/org/apache/rocketmq/broker/processor/PullMessageProcessorTest.java
@@ -16,6 +16,7 @@
*/
package org.apache.rocketmq.broker.processor;
+import io.netty.channel.Channel;
import io.netty.channel.ChannelHandlerContext;
import java.net.InetSocketAddress;
import java.util.ArrayList;
@@ -70,6 +71,8 @@ public class PullMessageProcessorTest {
@Mock
private ChannelHandlerContext handlerContext;
@Mock
+ private Channel channel;
+ @Mock
private MessageStore messageStore;
private ClientChannelInfo clientChannelInfo;
private String group = "FooBarGroup";
diff --git a/snode/src/main/java/org/apache/rocketmq/snode/SnodeController.java b/snode/src/main/java/org/apache/rocketmq/snode/SnodeController.java
index 66d792d..0bc06e0 100644
--- a/snode/src/main/java/org/apache/rocketmq/snode/SnodeController.java
+++ b/snode/src/main/java/org/apache/rocketmq/snode/SnodeController.java
@@ -1,4 +1,4 @@
-package org.apache.rocketmq.snode;/*
+/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
@@ -14,7 +14,7 @@ package org.apache.rocketmq.snode;/*
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
+package org.apache.rocketmq.snode;
import java.util.List;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ExecutorService;
diff --git a/snode/src/main/java/org/apache/rocketmq/snode/SnodeStartup.java b/snode/src/main/java/org/apache/rocketmq/snode/SnodeStartup.java
index f745ede..8e51f50 100644
--- a/snode/src/main/java/org/apache/rocketmq/snode/SnodeStartup.java
+++ b/snode/src/main/java/org/apache/rocketmq/snode/SnodeStartup.java
@@ -1,4 +1,4 @@
-package org.apache.rocketmq.snode;/*
+/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
@@ -14,7 +14,7 @@ package org.apache.rocketmq.snode;/*
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
+package org.apache.rocketmq.snode;
import ch.qos.logback.classic.LoggerContext;
import ch.qos.logback.classic.joran.JoranConfigurator;
import ch.qos.logback.core.joran.spi.JoranException;
diff --git a/snode/src/main/java/org/apache/rocketmq/snode/client/PushSession.java b/snode/src/main/java/org/apache/rocketmq/snode/client/PushSession.java
index c08bab5..7511025 100644
--- a/snode/src/main/java/org/apache/rocketmq/snode/client/PushSession.java
+++ b/snode/src/main/java/org/apache/rocketmq/snode/client/PushSession.java
@@ -1,4 +1,4 @@
-package org.apache.rocketmq.snode.client;/*
+/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
@@ -14,7 +14,7 @@ package org.apache.rocketmq.snode.client;/*
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
+package org.apache.rocketmq.snode.client;
import io.netty.channel.Channel;
import org.apache.rocketmq.common.protocol.heartbeat.SubscriptionData;
diff --git a/snode/src/main/java/org/apache/rocketmq/snode/config/SnodeConfig.java b/snode/src/main/java/org/apache/rocketmq/snode/config/SnodeConfig.java
index 6ef55b1..c171d9b 100644
--- a/snode/src/main/java/org/apache/rocketmq/snode/config/SnodeConfig.java
+++ b/snode/src/main/java/org/apache/rocketmq/snode/config/SnodeConfig.java
@@ -1,4 +1,4 @@
-package org.apache.rocketmq.snode.config;/*
+/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
@@ -14,7 +14,7 @@ package org.apache.rocketmq.snode.config;/*
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
+package org.apache.rocketmq.snode.config;
import org.apache.rocketmq.common.MixAll;
import org.apache.rocketmq.common.annotation.ImportantField;
import org.apache.rocketmq.common.constant.LoggerName;
diff --git a/snode/src/main/java/org/apache/rocketmq/snode/constant/SnodeConstant.java b/snode/src/main/java/org/apache/rocketmq/snode/constant/SnodeConstant.java
index 1f5c7dd..65838f3 100644
--- a/snode/src/main/java/org/apache/rocketmq/snode/constant/SnodeConstant.java
+++ b/snode/src/main/java/org/apache/rocketmq/snode/constant/SnodeConstant.java
@@ -1,4 +1,4 @@
-package org.apache.rocketmq.snode.constant;/*
+/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
@@ -14,7 +14,7 @@ package org.apache.rocketmq.snode.constant;/*
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
+package org.apache.rocketmq.snode.constant;
public class SnodeConstant {
public static final long heartbeatTimeout = 3000;
diff --git a/snode/src/main/java/org/apache/rocketmq/snode/exception/SnodeException.java b/snode/src/main/java/org/apache/rocketmq/snode/exception/SnodeException.java
index e9bd114..84cba64 100644
--- a/snode/src/main/java/org/apache/rocketmq/snode/exception/SnodeException.java
+++ b/snode/src/main/java/org/apache/rocketmq/snode/exception/SnodeException.java
@@ -1,4 +1,4 @@
-package org.apache.rocketmq.snode.exception;/*
+/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
@@ -14,7 +14,7 @@ package org.apache.rocketmq.snode.exception;/*
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
+package org.apache.rocketmq.snode.exception;
import org.apache.rocketmq.common.UtilAll;
import org.apache.rocketmq.common.help.FAQUrl;
diff --git a/snode/src/main/java/org/apache/rocketmq/snode/interceptor/ExceptionContext.java b/snode/src/main/java/org/apache/rocketmq/snode/interceptor/ExceptionContext.java
index 569633d..192f249 100644
--- a/snode/src/main/java/org/apache/rocketmq/snode/interceptor/ExceptionContext.java
+++ b/snode/src/main/java/org/apache/rocketmq/snode/interceptor/ExceptionContext.java
@@ -1,4 +1,4 @@
-package org.apache.rocketmq.snode.interceptor;/*
+/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
@@ -14,7 +14,7 @@ package org.apache.rocketmq.snode.interceptor;/*
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
+package org.apache.rocketmq.snode.interceptor;
import org.apache.rocketmq.remoting.RemotingChannel;
import org.apache.rocketmq.remoting.protocol.RemotingCommand;
diff --git a/snode/src/main/java/org/apache/rocketmq/snode/interceptor/InterceptorGroup.java b/snode/src/main/java/org/apache/rocketmq/snode/interceptor/InterceptorGroup.java
index 4582894..fcee7a5 100644
--- a/snode/src/main/java/org/apache/rocketmq/snode/interceptor/InterceptorGroup.java
+++ b/snode/src/main/java/org/apache/rocketmq/snode/interceptor/InterceptorGroup.java
@@ -1,4 +1,4 @@
-package org.apache.rocketmq.snode.interceptor;/*
+/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
@@ -14,7 +14,7 @@ package org.apache.rocketmq.snode.interceptor;/*
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
+package org.apache.rocketmq.snode.interceptor;
import java.util.ArrayList;
import java.util.List;
diff --git a/snode/src/main/java/org/apache/rocketmq/snode/interceptor/RequestContext.java b/snode/src/main/java/org/apache/rocketmq/snode/interceptor/RequestContext.java
index 796358b..5f32e6b 100644
--- a/snode/src/main/java/org/apache/rocketmq/snode/interceptor/RequestContext.java
+++ b/snode/src/main/java/org/apache/rocketmq/snode/interceptor/RequestContext.java
@@ -1,4 +1,4 @@
-package org.apache.rocketmq.snode.interceptor;/*
+/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
@@ -14,7 +14,7 @@ package org.apache.rocketmq.snode.interceptor;/*
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
+package org.apache.rocketmq.snode.interceptor;
import org.apache.rocketmq.remoting.RemotingChannel;
import org.apache.rocketmq.remoting.protocol.RemotingCommand;
diff --git a/snode/src/main/java/org/apache/rocketmq/snode/interceptor/ResponseContext.java b/snode/src/main/java/org/apache/rocketmq/snode/interceptor/ResponseContext.java
index 2634426..9901981 100644
--- a/snode/src/main/java/org/apache/rocketmq/snode/interceptor/ResponseContext.java
+++ b/snode/src/main/java/org/apache/rocketmq/snode/interceptor/ResponseContext.java
@@ -1,4 +1,4 @@
-package org.apache.rocketmq.snode.interceptor;/*
+/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
@@ -14,7 +14,7 @@ package org.apache.rocketmq.snode.interceptor;/*
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
+package org.apache.rocketmq.snode.interceptor;
import org.apache.rocketmq.remoting.RemotingChannel;
import org.apache.rocketmq.remoting.protocol.RemotingCommand;
diff --git a/snode/src/main/java/org/apache/rocketmq/snode/processor/PullMessageProcessor.java b/snode/src/main/java/org/apache/rocketmq/snode/processor/PullMessageProcessor.java
index f5d080f..2abc196 100644
--- a/snode/src/main/java/org/apache/rocketmq/snode/processor/PullMessageProcessor.java
+++ b/snode/src/main/java/org/apache/rocketmq/snode/processor/PullMessageProcessor.java
@@ -1,4 +1,4 @@
-package org.apache.rocketmq.snode.processor;/*
+/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
@@ -14,7 +14,7 @@ package org.apache.rocketmq.snode.processor;/*
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
+package org.apache.rocketmq.snode.processor;
import java.util.concurrent.CompletableFuture;
import org.apache.rocketmq.common.constant.LoggerName;
import org.apache.rocketmq.common.help.FAQUrl;
diff --git a/snode/src/main/java/org/apache/rocketmq/snode/processor/SendMessageProcessor.java b/snode/src/main/java/org/apache/rocketmq/snode/processor/SendMessageProcessor.java
index 2c45bb7..9477895 100644
--- a/snode/src/main/java/org/apache/rocketmq/snode/processor/SendMessageProcessor.java
+++ b/snode/src/main/java/org/apache/rocketmq/snode/processor/SendMessageProcessor.java
@@ -1,4 +1,4 @@
-package org.apache.rocketmq.snode.processor;/*
+/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
@@ -14,7 +14,7 @@ package org.apache.rocketmq.snode.processor;/*
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
+package org.apache.rocketmq.snode.processor;
import java.util.concurrent.CompletableFuture;
import org.apache.rocketmq.common.constant.LoggerName;
import org.apache.rocketmq.logging.InternalLogger;
diff --git a/snode/src/main/java/org/apache/rocketmq/snode/service/EnodeService.java b/snode/src/main/java/org/apache/rocketmq/snode/service/EnodeService.java
index 4c3f894..0105027 100644
--- a/snode/src/main/java/org/apache/rocketmq/snode/service/EnodeService.java
+++ b/snode/src/main/java/org/apache/rocketmq/snode/service/EnodeService.java
@@ -1,4 +1,4 @@
-package org.apache.rocketmq.snode.service;/*
+/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
@@ -14,7 +14,7 @@ package org.apache.rocketmq.snode.service;/*
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
+package org.apache.rocketmq.snode.service;
import java.util.concurrent.CompletableFuture;
import org.apache.rocketmq.client.exception.MQBrokerException;
import org.apache.rocketmq.common.TopicConfig;
diff --git a/snode/src/main/java/org/apache/rocketmq/snode/service/NnodeService.java b/snode/src/main/java/org/apache/rocketmq/snode/service/NnodeService.java
index 21bc6ed..b4da238 100644
--- a/snode/src/main/java/org/apache/rocketmq/snode/service/NnodeService.java
+++ b/snode/src/main/java/org/apache/rocketmq/snode/service/NnodeService.java
@@ -1,4 +1,4 @@
-package org.apache.rocketmq.snode.service;/*
+/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
@@ -14,7 +14,7 @@ package org.apache.rocketmq.snode.service;/*
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
+package org.apache.rocketmq.snode.service;
import java.util.Set;
import org.apache.rocketmq.client.exception.MQClientException;
import org.apache.rocketmq.common.protocol.body.ClusterInfo;
diff --git a/snode/src/main/java/org/apache/rocketmq/snode/service/PushService.java b/snode/src/main/java/org/apache/rocketmq/snode/service/PushService.java
index e9bfe2b..5c0870a 100644
--- a/snode/src/main/java/org/apache/rocketmq/snode/service/PushService.java
+++ b/snode/src/main/java/org/apache/rocketmq/snode/service/PushService.java
@@ -1,4 +1,4 @@
-package org.apache.rocketmq.snode.service;/*
+/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
@@ -14,7 +14,7 @@ package org.apache.rocketmq.snode.service;/*
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
+package org.apache.rocketmq.snode.service;
import org.apache.rocketmq.common.message.Message;
public interface PushService {
diff --git a/snode/src/main/java/org/apache/rocketmq/snode/service/ScheduledService.java b/snode/src/main/java/org/apache/rocketmq/snode/service/ScheduledService.java
index dc86688..f332f81 100644
--- a/snode/src/main/java/org/apache/rocketmq/snode/service/ScheduledService.java
+++ b/snode/src/main/java/org/apache/rocketmq/snode/service/ScheduledService.java
@@ -1,4 +1,4 @@
-package org.apache.rocketmq.snode.service;/*
+/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
@@ -14,7 +14,7 @@ package org.apache.rocketmq.snode.service;/*
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
+package org.apache.rocketmq.snode.service;
public interface ScheduledService {
void startScheduleTask();
void shutdown();
diff --git a/snode/src/main/java/org/apache/rocketmq/snode/service/impl/EnodeServiceImpl.java b/snode/src/main/java/org/apache/rocketmq/snode/service/impl/EnodeServiceImpl.java
index 5e28ebe..f6d157a 100644
--- a/snode/src/main/java/org/apache/rocketmq/snode/service/impl/EnodeServiceImpl.java
+++ b/snode/src/main/java/org/apache/rocketmq/snode/service/impl/EnodeServiceImpl.java
@@ -1,4 +1,4 @@
-package org.apache.rocketmq.snode.service.impl;/*
+/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
@@ -14,7 +14,7 @@ package org.apache.rocketmq.snode.service.impl;/*
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
+package org.apache.rocketmq.snode.service.impl;
import java.util.HashMap;
import java.util.Map;
import java.util.Set;
diff --git a/snode/src/main/java/org/apache/rocketmq/snode/service/impl/NnodeServiceImpl.java b/snode/src/main/java/org/apache/rocketmq/snode/service/impl/NnodeServiceImpl.java
index 78fd624..286abc8 100644
--- a/snode/src/main/java/org/apache/rocketmq/snode/service/impl/NnodeServiceImpl.java
+++ b/snode/src/main/java/org/apache/rocketmq/snode/service/impl/NnodeServiceImpl.java
@@ -1,4 +1,4 @@
-package org.apache.rocketmq.snode.service.impl;/*
+/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
@@ -14,7 +14,7 @@ package org.apache.rocketmq.snode.service.impl;/*
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
+package org.apache.rocketmq.snode.service.impl;
import java.util.ArrayList;
import java.util.List;
import java.util.Set;
diff --git a/snode/src/main/java/org/apache/rocketmq/snode/service/impl/ScheduledServiceImpl.java b/snode/src/main/java/org/apache/rocketmq/snode/service/impl/ScheduledServiceImpl.java
index 384a0c2..4de080b 100644
--- a/snode/src/main/java/org/apache/rocketmq/snode/service/impl/ScheduledServiceImpl.java
+++ b/snode/src/main/java/org/apache/rocketmq/snode/service/impl/ScheduledServiceImpl.java
@@ -1,4 +1,4 @@
-package org.apache.rocketmq.snode.service.impl;/*
+/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
@@ -14,7 +14,7 @@ package org.apache.rocketmq.snode.service.impl;/*
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
+package org.apache.rocketmq.snode.service.impl;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ThreadFactory;