KAA-286: add license headers

client/client-multi/client-java-core/src/main/java/org/kaaproject/kaa/client/channel/GenericTransportInfo.java

@@ -1,7 +1,27 @@
+/*
+ * Copyright 2014 CyberVision, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
 package org.kaaproject.kaa.client.channel;
 
 import org.kaaproject.kaa.common.endpoint.gen.ProtocolMetaData;
 
+/**
+ * Generic implementation of {@link ServerInfo} that is based on {@link ProtocolMetaData}
+ * @author Andrew Shvayka
+ *
+ */
 public class GenericTransportInfo implements ServerInfo {
 
     protected final ServerType serverType;

client/client-multi/client-java-core/src/main/java/org/kaaproject/kaa/client/channel/TransportId.java

@@ -1,5 +1,27 @@
+/*
+ * Copyright 2014 CyberVision, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
 package org.kaaproject.kaa.client.channel;
 
+/**
+ * Immutable class to represent transport ID. Holds references to transport
+ * protocol id and transport protocol version
+ * 
+ * @author Andrew Shvayka
+ *
+ */
 public final class TransportId {
 
     private final int protocolId;

client/client-multi/client-java-core/src/main/java/org/kaaproject/kaa/client/channel/impl/channels/TransportIdConstants.java → client/client-multi/client-java-core/src/main/java/org/kaaproject/kaa/client/channel/TransportIdConstants.java

@@ -1,6 +1,20 @@
-package org.kaaproject.kaa.client.channel.impl.channels;
+/*
+ * Copyright 2014 CyberVision, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.kaaproject.kaa.client.channel;
 
-import org.kaaproject.kaa.client.channel.TransportId;
 
 /**
  * Class to hold transport id constants. Please note that this constants should

client/client-multi/client-java-core/src/main/java/org/kaaproject/kaa/client/channel/impl/channels/AbstractHttpChannel.java

@@ -29,6 +29,7 @@
 import org.kaaproject.kaa.client.channel.KaaDataMultiplexer;
 import org.kaaproject.kaa.client.channel.ServerInfo;
 import org.kaaproject.kaa.client.channel.TransportId;
+import org.kaaproject.kaa.client.channel.TransportIdConstants;
 import org.kaaproject.kaa.client.channel.connectivity.ConnectivityChecker;
 import org.kaaproject.kaa.client.persistence.KaaClientState;
 import org.kaaproject.kaa.client.transport.AbstractHttpClient;

client/client-multi/client-java-core/src/main/java/org/kaaproject/kaa/client/channel/impl/channels/DefaultOperationTcpChannel.java

@@ -39,6 +39,7 @@
 import org.kaaproject.kaa.client.channel.ServerInfo;
 import org.kaaproject.kaa.client.channel.ServerType;
 import org.kaaproject.kaa.client.channel.TransportId;
+import org.kaaproject.kaa.client.channel.TransportIdConstants;
 import org.kaaproject.kaa.client.channel.connectivity.ConnectivityChecker;
 import org.kaaproject.kaa.client.persistence.KaaClientState;
 import org.kaaproject.kaa.common.Constants;

client/client-multi/client-java-core/src/main/java/org/kaaproject/kaa/client/channel/impl/channels/DefaultOperationsChannel.java

@@ -34,6 +34,7 @@
 import org.kaaproject.kaa.client.channel.ServerInfo;
 import org.kaaproject.kaa.client.channel.ServerType;
 import org.kaaproject.kaa.client.channel.TransportId;
+import org.kaaproject.kaa.client.channel.TransportIdConstants;
 import org.kaaproject.kaa.client.channel.connectivity.ConnectivityChecker;
 import org.kaaproject.kaa.client.channel.impl.channels.polling.CancelableCommandRunnable;
 import org.kaaproject.kaa.client.channel.impl.channels.polling.CancelableRunnable;

client/client-multi/client-java-core/src/test/java/org/kaaproject/kaa/client/KaaClientPropertiesTest.java

@@ -28,7 +28,7 @@
 import org.kaaproject.kaa.client.channel.ServerInfo;
 import org.kaaproject.kaa.client.channel.ServerType;
 import org.kaaproject.kaa.client.channel.TransportId;
-import org.kaaproject.kaa.client.channel.impl.channels.TransportIdConstants;
+import org.kaaproject.kaa.client.channel.TransportIdConstants;
 import org.kaaproject.kaa.common.endpoint.gen.EndpointVersionInfo;
 import org.kaaproject.kaa.common.endpoint.gen.EventClassFamilyVersionInfo;
 

client/client-multi/client-java-core/src/test/java/org/kaaproject/kaa/client/bootstrap/DefaultBootstrapManagerTest.java

@@ -38,8 +38,8 @@
 import org.kaaproject.kaa.client.channel.KaaDataChannel;
 import org.kaaproject.kaa.client.channel.KaaInvalidChannelException;
 import org.kaaproject.kaa.client.channel.ServerInfo;
+import org.kaaproject.kaa.client.channel.TransportIdConstants;
 import org.kaaproject.kaa.client.channel.connectivity.ConnectivityChecker;
-import org.kaaproject.kaa.client.channel.impl.channels.TransportIdConstants;
 import org.kaaproject.kaa.client.transport.TransportException;
 import org.kaaproject.kaa.common.TransportType;
 import org.kaaproject.kaa.common.endpoint.gen.ProtocolMetaData;

client/client-multi/client-java-core/src/test/java/org/kaaproject/kaa/client/channel/DefaultBootstrapChannelTest.java

@@ -25,7 +25,6 @@
 import org.junit.Test;
 import org.kaaproject.kaa.client.AbstractKaaClient;
 import org.kaaproject.kaa.client.channel.impl.channels.DefaultBootstrapChannel;
-import org.kaaproject.kaa.client.channel.impl.channels.TransportIdConstants;
 import org.kaaproject.kaa.client.persistence.KaaClientState;
 import org.kaaproject.kaa.client.transport.AbstractHttpClient;
 import org.kaaproject.kaa.common.TransportType;

client/client-multi/client-java-core/src/test/java/org/kaaproject/kaa/client/channel/DefaultChannelManagerTest.java

@@ -33,7 +33,6 @@
 import org.kaaproject.kaa.client.channel.connectivity.ConnectivityChecker;
 import org.kaaproject.kaa.client.channel.impl.ChannelRuntimeException;
 import org.kaaproject.kaa.client.channel.impl.DefaultChannelManager;
-import org.kaaproject.kaa.client.channel.impl.channels.TransportIdConstants;
 import org.kaaproject.kaa.common.TransportType;
 import org.kaaproject.kaa.common.endpoint.security.KeyUtil;
 import org.mockito.Mockito;

client/client-multi/client-java-core/src/test/java/org/kaaproject/kaa/client/channel/DefaultOperationHttpChannelTest.java

@@ -27,7 +27,6 @@
 import org.junit.Test;
 import org.kaaproject.kaa.client.AbstractKaaClient;
 import org.kaaproject.kaa.client.channel.impl.channels.DefaultOperationHttpChannel;
-import org.kaaproject.kaa.client.channel.impl.channels.TransportIdConstants;
 import org.kaaproject.kaa.client.persistence.KaaClientState;
 import org.kaaproject.kaa.client.transport.AbstractHttpClient;
 import org.kaaproject.kaa.common.TransportType;

client/client-multi/client-java-core/src/test/java/org/kaaproject/kaa/client/channel/DefaultOperationTcpChannelTest.java

@@ -31,7 +31,6 @@
 import org.junit.Test;
 import org.kaaproject.kaa.client.channel.connectivity.ConnectivityChecker;
 import org.kaaproject.kaa.client.channel.impl.channels.DefaultOperationTcpChannel;
-import org.kaaproject.kaa.client.channel.impl.channels.TransportIdConstants;
 import org.kaaproject.kaa.client.persistence.KaaClientState;
 import org.kaaproject.kaa.common.TransportType;
 import org.kaaproject.kaa.common.avro.AvroByteArrayConverter;

client/client-multi/client-java-core/src/test/java/org/kaaproject/kaa/client/channel/DefaultOperationsChannelTest.java

@@ -28,7 +28,6 @@
 import org.junit.Test;
 import org.kaaproject.kaa.client.AbstractKaaClient;
 import org.kaaproject.kaa.client.channel.impl.channels.DefaultOperationsChannel;
-import org.kaaproject.kaa.client.channel.impl.channels.TransportIdConstants;
 import org.kaaproject.kaa.client.persistence.KaaClientState;
 import org.kaaproject.kaa.client.transport.AbstractHttpClient;
 import org.kaaproject.kaa.common.TransportType;

client/client-multi/client-java-core/src/test/java/org/kaaproject/kaa/client/channel/IPTransportInfoTest.java

@@ -1,3 +1,18 @@
+/*
+ * Copyright 2014 CyberVision, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
 package org.kaaproject.kaa.client.channel;
 
 import java.nio.ByteBuffer;
@@ -7,10 +22,14 @@
 
 import org.junit.Assert;
 import org.junit.Test;
-import org.kaaproject.kaa.client.channel.impl.channels.TransportIdConstants;
 import org.kaaproject.kaa.common.endpoint.gen.ProtocolMetaData;
 import org.kaaproject.kaa.common.endpoint.security.KeyUtil;
 
+/**
+ * 
+ * @author Andrew Shvayka
+ *
+ */
 public class IPTransportInfoTest {
     private static final Charset UTF8 = Charset.forName("UTF-8");
     protected static final int SIZE_OF_INT = 4;

pom.xml

@@ -450,6 +450,7 @@ Copyright 2014 CyberVision, Inc.
                         <exclude>**/bin/**</exclude>
                         <exclude>**/thirdparty/**</exclude>
                         <exclude>**/security.policy</exclude>
+                        <exclude>**/*-transport.config</exclude>
                     </excludes>
                 </configuration>
             </plugin>

server/bootstrap/src/test/java/org/kaaproject/kaa/server/bootstrap/BootstrapServerLauncherIT.java

@@ -1,3 +1,18 @@
+/*
+ * Copyright 2014 CyberVision, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
 package org.kaaproject.kaa.server.bootstrap;
 
 import java.util.concurrent.TimeoutException;
@@ -13,6 +28,11 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+/**
+ * 
+ * @author Andrew Shvayka
+ *
+ */
 public class BootstrapServerLauncherIT {
     private static final int STARTUP_TIMEOUT = 30000;
 

server/bootstrap/src/test/java/org/kaaproject/kaa/server/bootstrap/service/DefaultOperationsServerListServiceTest.java

@@ -1,3 +1,18 @@
+/*
+ * Copyright 2014 CyberVision, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
 package org.kaaproject.kaa.server.bootstrap.service;
 
 import java.nio.ByteBuffer;
@@ -19,6 +34,11 @@
 import org.kaaproject.kaa.server.sync.bootstrap.ProtocolVersionKey;
 import org.mockito.Mockito;
 
+/**
+ * 
+ * @author Andrew Shvayka
+ *
+ */
 public class DefaultOperationsServerListServiceTest {
 
     OperationsServerListService service;

server/common/netty-server/src/main/java/org/kaaproject/kaa/server/common/server/NettyChannelContext.java

@@ -1,9 +1,30 @@
+/*
+ * Copyright 2014 CyberVision, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
 package org.kaaproject.kaa.server.common.server;
 
 import io.netty.channel.ChannelHandlerContext;
 
 import org.kaaproject.kaa.server.transport.channel.ChannelContext;
 
+/**
+ * Implementation of {@link ChannelContext} that is based on Netty channels.
+ * 
+ * @author Andrew Shvayka
+ *
+ */
 public class NettyChannelContext implements ChannelContext{
     private final ChannelHandlerContext ctx;
 

server/common/server-shared/src/main/java/org/kaaproject/kaa/server/sync/platform/PlatformLookup.java

@@ -1,3 +1,18 @@
+/*
+ * Copyright 2014 CyberVision, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
 package org.kaaproject.kaa.server.sync.platform;
 
 import java.util.HashMap;
@@ -11,6 +26,12 @@
 import org.springframework.context.annotation.ClassPathScanningCandidateComponentProvider;
 import org.springframework.core.type.filter.AnnotationTypeFilter;
 
+/**
+ * Provides ability to lookup and init {@link PlatformEncDec} instances
+ * 
+ * @author Andrew Shvayka
+ *
+ */
 public class PlatformLookup {
     /** The Constant LOG. */
     private static final Logger LOG = LoggerFactory.getLogger(PlatformLookup.class);

server/common/transport-shared/src/main/java/org/kaaproject/kaa/server/transport/AbstractTransportService.java

@@ -1,3 +1,18 @@
+/*
+ * Copyright 2014 CyberVision, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
 package org.kaaproject.kaa.server.transport;
 
 import java.io.IOException;
@@ -27,6 +42,13 @@
 import org.springframework.context.annotation.ClassPathScanningCandidateComponentProvider;
 import org.springframework.core.type.filter.AnnotationTypeFilter;
 
+/**
+ * Responsible for classpath scan and initialization of {@link Transport} implementations.
+ * Provides ability to add/remove listeners to transports statup.
+ * 
+ * @author Andrew Shvayka
+ *
+ */
 public abstract class AbstractTransportService implements TransportService {
     protected static final String TRANSPORT_CONFIGURATION_SCAN_PACKAGE = "org.kaaproject.kaa.server.transport";
 

server/common/transport-shared/src/main/java/org/kaaproject/kaa/server/transport/TransportUpdateListener.java

@@ -1,10 +1,31 @@
+/*
+ * Copyright 2014 CyberVision, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
 package org.kaaproject.kaa.server.transport;
 
 import java.util.List;
-import java.util.Map;
+import org.kaaproject.kaa.server.common.zk.gen.TransportMetaData;
 
+/**
+ * Listener to transport state updates.
+ * 
+ * @author Andrew Shvayka
+ *
+ */
 public interface TransportUpdateListener {
 
-    void onTransportsStarted(List<org.kaaproject.kaa.server.common.zk.gen.TransportMetaData> mdList);
+    void onTransportsStarted(List<TransportMetaData> mdList);
 
 }