From 2c0731437bf3a8bcd031cd936f9220819211ebb0 Mon Sep 17 00:00:00 2001 From: Juan Pablo Diaz-Vaz Date: Fri, 24 Jul 2015 10:01:22 -0300 Subject: [PATCH 1/4] SUMOK-31 Removed Amazon copyright header --- .../com/mcplusa/kinesis/BatchedStreamSource.java | 14 -------------- .../mcplusa/kinesis/KinesisConnectorExecutor.java | 14 -------------- .../kinesis/KinesisConnectorExecutorBase.java | 14 -------------- .../kinesis/KinesisConnectorMetricsExecutor.java | 14 -------------- .../java/com/mcplusa/kinesis/StreamSource.java | 14 -------------- .../com/mcplusa/kinesis/utils/KinesisUtils.java | 14 -------------- 6 files changed, 84 deletions(-) diff --git a/src/main/java/com/mcplusa/kinesis/BatchedStreamSource.java b/src/main/java/com/mcplusa/kinesis/BatchedStreamSource.java index d463002..10bca6a 100644 --- a/src/main/java/com/mcplusa/kinesis/BatchedStreamSource.java +++ b/src/main/java/com/mcplusa/kinesis/BatchedStreamSource.java @@ -1,17 +1,3 @@ -/* - * Copyright 2014 Amazon.com, Inc. or its affiliates. All Rights Reserved. - * - * Licensed under the Amazon Software License (the "License"). - * You may not use this file except in compliance with the License. - * A copy of the License is located at - * - * http://aws.amazon.com/asl/ - * - * or in the "license" file accompanying this file. This file 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 com.mcplusa.kinesis; import java.io.BufferedReader; diff --git a/src/main/java/com/mcplusa/kinesis/KinesisConnectorExecutor.java b/src/main/java/com/mcplusa/kinesis/KinesisConnectorExecutor.java index c7440c6..f65d805 100644 --- a/src/main/java/com/mcplusa/kinesis/KinesisConnectorExecutor.java +++ b/src/main/java/com/mcplusa/kinesis/KinesisConnectorExecutor.java @@ -1,17 +1,3 @@ -/* - * Copyright 2013-2014 Amazon.com, Inc. or its affiliates. All Rights Reserved. - * - * Licensed under the Amazon Software License (the "License"). - * You may not use this file except in compliance with the License. - * A copy of the License is located at - * - * http://aws.amazon.com/asl/ - * - * or in the "license" file accompanying this file. This file 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 com.mcplusa.kinesis; import java.io.IOException; diff --git a/src/main/java/com/mcplusa/kinesis/KinesisConnectorExecutorBase.java b/src/main/java/com/mcplusa/kinesis/KinesisConnectorExecutorBase.java index eacf9a2..0351912 100644 --- a/src/main/java/com/mcplusa/kinesis/KinesisConnectorExecutorBase.java +++ b/src/main/java/com/mcplusa/kinesis/KinesisConnectorExecutorBase.java @@ -1,17 +1,3 @@ -/* - * Copyright 2013-2014 Amazon.com, Inc. or its affiliates. All Rights Reserved. - * - * Licensed under the Amazon Software License (the "License"). - * You may not use this file except in compliance with the License. - * A copy of the License is located at - * - * http://aws.amazon.com/asl/ - * - * or in the "license" file accompanying this file. This file 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 com.mcplusa.kinesis; import org.apache.commons.logging.Log; diff --git a/src/main/java/com/mcplusa/kinesis/KinesisConnectorMetricsExecutor.java b/src/main/java/com/mcplusa/kinesis/KinesisConnectorMetricsExecutor.java index 38bec4e..43c0e04 100644 --- a/src/main/java/com/mcplusa/kinesis/KinesisConnectorMetricsExecutor.java +++ b/src/main/java/com/mcplusa/kinesis/KinesisConnectorMetricsExecutor.java @@ -1,17 +1,3 @@ -/* - * Copyright 2013-2014 Amazon.com, Inc. or its affiliates. All Rights Reserved. - * - * Licensed under the Amazon Software License (the "License"). - * You may not use this file except in compliance with the License. - * A copy of the License is located at - * - * http://aws.amazon.com/asl/ - * - * or in the "license" file accompanying this file. This file 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 com.mcplusa.kinesis; import com.amazonaws.services.kinesis.metrics.impl.CWMetricsFactory; diff --git a/src/main/java/com/mcplusa/kinesis/StreamSource.java b/src/main/java/com/mcplusa/kinesis/StreamSource.java index b9b4b2b..198d932 100644 --- a/src/main/java/com/mcplusa/kinesis/StreamSource.java +++ b/src/main/java/com/mcplusa/kinesis/StreamSource.java @@ -1,17 +1,3 @@ -/* - * Copyright 2013-2014 Amazon.com, Inc. or its affiliates. All Rights Reserved. - * - * Licensed under the Amazon Software License (the "License"). - * You may not use this file except in compliance with the License. - * A copy of the License is located at - * - * http://aws.amazon.com/asl/ - * - * or in the "license" file accompanying this file. This file 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 com.mcplusa.kinesis; import java.io.BufferedReader; diff --git a/src/main/java/com/mcplusa/kinesis/utils/KinesisUtils.java b/src/main/java/com/mcplusa/kinesis/utils/KinesisUtils.java index 9c477d2..26cbeed 100644 --- a/src/main/java/com/mcplusa/kinesis/utils/KinesisUtils.java +++ b/src/main/java/com/mcplusa/kinesis/utils/KinesisUtils.java @@ -1,17 +1,3 @@ -/* - * Copyright 2013-2014 Amazon.com, Inc. or its affiliates. All Rights Reserved. - * - * Licensed under the Amazon Software License (the "License"). - * You may not use this file except in compliance with the License. - * A copy of the License is located at - * - * http://aws.amazon.com/asl/ - * - * or in the "license" file accompanying this file. This file 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 com.mcplusa.kinesis.utils; import java.util.List; From 12b151c1e920867aae385d7ff958c41275f3bb7c Mon Sep 17 00:00:00 2001 From: Juan Pablo Diaz-Vaz Date: Fri, 24 Jul 2015 10:08:50 -0300 Subject: [PATCH 2/4] SUMOK-31 Removed references to mcplusa in package names --- .../CloudWatchMessageModelSumologicTransformer.java | 0 .../DefaultKinesisMessageModelSumologicTransformer.java | 0 .../KinesisConnectorForSumologicConfiguration.java | 0 .../client}/SimpleKinesisMessageModel.java | 0 .../sumologic => sumologic/client}/SumologicExecutor.java | 0 .../client}/SumologicMessageModelPipeline.java | 0 .../sumologic => sumologic/client}/SumologicSender.java | 0 .../client}/implementations/SumologicEmitter.java | 0 .../client}/implementations/SumologicTransformer.java | 0 .../kinesis/BatchedStreamSource.java | 4 ++-- .../kinesis/KinesisConnectorExecutor.java | 6 +++--- .../kinesis/KinesisConnectorExecutorBase.java | 2 +- .../kinesis/KinesisConnectorMetricsExecutor.java | 2 +- .../com/{mcplusa => sumologic}/kinesis/StreamSource.java | 6 +++--- .../kinesis/utils/KinesisUtils.java | 2 +- .../CloudWatchMessageModelSumologicTransformerTest.java | 6 +++--- .../client}/SumologicSenderTest.java | 8 ++++---- .../client}/implementations/SumologicEmitterTest.java | 4 ++-- 18 files changed, 20 insertions(+), 20 deletions(-) rename src/main/java/com/{mcplusa/sumologic => sumologic/client}/CloudWatchMessageModelSumologicTransformer.java (100%) rename src/main/java/com/{mcplusa/sumologic => sumologic/client}/DefaultKinesisMessageModelSumologicTransformer.java (100%) rename src/main/java/com/{mcplusa/sumologic => sumologic/client}/KinesisConnectorForSumologicConfiguration.java (100%) rename src/main/java/com/{mcplusa/sumologic => sumologic/client}/SimpleKinesisMessageModel.java (100%) rename src/main/java/com/{mcplusa/sumologic => sumologic/client}/SumologicExecutor.java (100%) rename src/main/java/com/{mcplusa/sumologic => sumologic/client}/SumologicMessageModelPipeline.java (100%) rename src/main/java/com/{mcplusa/sumologic => sumologic/client}/SumologicSender.java (100%) rename src/main/java/com/{mcplusa/sumologic => sumologic/client}/implementations/SumologicEmitter.java (100%) rename src/main/java/com/{mcplusa/sumologic => sumologic/client}/implementations/SumologicTransformer.java (100%) rename src/main/java/com/{mcplusa => sumologic}/kinesis/BatchedStreamSource.java (97%) rename src/main/java/com/{mcplusa => sumologic}/kinesis/KinesisConnectorExecutor.java (96%) rename src/main/java/com/{mcplusa => sumologic}/kinesis/KinesisConnectorExecutorBase.java (99%) rename src/main/java/com/{mcplusa => sumologic}/kinesis/KinesisConnectorMetricsExecutor.java (97%) rename src/main/java/com/{mcplusa => sumologic}/kinesis/StreamSource.java (97%) rename src/main/java/com/{mcplusa => sumologic}/kinesis/utils/KinesisUtils.java (99%) rename src/test/java/com/{mcplusa/sumologic => sumologic/client}/CloudWatchMessageModelSumologicTransformerTest.java (89%) rename src/test/java/com/{mcplusa/sumologic => sumologic/client}/SumologicSenderTest.java (92%) rename src/test/java/com/{mcplusa/sumologic => sumologic/client}/implementations/SumologicEmitterTest.java (94%) diff --git a/src/main/java/com/mcplusa/sumologic/CloudWatchMessageModelSumologicTransformer.java b/src/main/java/com/sumologic/client/CloudWatchMessageModelSumologicTransformer.java similarity index 100% rename from src/main/java/com/mcplusa/sumologic/CloudWatchMessageModelSumologicTransformer.java rename to src/main/java/com/sumologic/client/CloudWatchMessageModelSumologicTransformer.java diff --git a/src/main/java/com/mcplusa/sumologic/DefaultKinesisMessageModelSumologicTransformer.java b/src/main/java/com/sumologic/client/DefaultKinesisMessageModelSumologicTransformer.java similarity index 100% rename from src/main/java/com/mcplusa/sumologic/DefaultKinesisMessageModelSumologicTransformer.java rename to src/main/java/com/sumologic/client/DefaultKinesisMessageModelSumologicTransformer.java diff --git a/src/main/java/com/mcplusa/sumologic/KinesisConnectorForSumologicConfiguration.java b/src/main/java/com/sumologic/client/KinesisConnectorForSumologicConfiguration.java similarity index 100% rename from src/main/java/com/mcplusa/sumologic/KinesisConnectorForSumologicConfiguration.java rename to src/main/java/com/sumologic/client/KinesisConnectorForSumologicConfiguration.java diff --git a/src/main/java/com/mcplusa/sumologic/SimpleKinesisMessageModel.java b/src/main/java/com/sumologic/client/SimpleKinesisMessageModel.java similarity index 100% rename from src/main/java/com/mcplusa/sumologic/SimpleKinesisMessageModel.java rename to src/main/java/com/sumologic/client/SimpleKinesisMessageModel.java diff --git a/src/main/java/com/mcplusa/sumologic/SumologicExecutor.java b/src/main/java/com/sumologic/client/SumologicExecutor.java similarity index 100% rename from src/main/java/com/mcplusa/sumologic/SumologicExecutor.java rename to src/main/java/com/sumologic/client/SumologicExecutor.java diff --git a/src/main/java/com/mcplusa/sumologic/SumologicMessageModelPipeline.java b/src/main/java/com/sumologic/client/SumologicMessageModelPipeline.java similarity index 100% rename from src/main/java/com/mcplusa/sumologic/SumologicMessageModelPipeline.java rename to src/main/java/com/sumologic/client/SumologicMessageModelPipeline.java diff --git a/src/main/java/com/mcplusa/sumologic/SumologicSender.java b/src/main/java/com/sumologic/client/SumologicSender.java similarity index 100% rename from src/main/java/com/mcplusa/sumologic/SumologicSender.java rename to src/main/java/com/sumologic/client/SumologicSender.java diff --git a/src/main/java/com/mcplusa/sumologic/implementations/SumologicEmitter.java b/src/main/java/com/sumologic/client/implementations/SumologicEmitter.java similarity index 100% rename from src/main/java/com/mcplusa/sumologic/implementations/SumologicEmitter.java rename to src/main/java/com/sumologic/client/implementations/SumologicEmitter.java diff --git a/src/main/java/com/mcplusa/sumologic/implementations/SumologicTransformer.java b/src/main/java/com/sumologic/client/implementations/SumologicTransformer.java similarity index 100% rename from src/main/java/com/mcplusa/sumologic/implementations/SumologicTransformer.java rename to src/main/java/com/sumologic/client/implementations/SumologicTransformer.java diff --git a/src/main/java/com/mcplusa/kinesis/BatchedStreamSource.java b/src/main/java/com/sumologic/kinesis/BatchedStreamSource.java similarity index 97% rename from src/main/java/com/mcplusa/kinesis/BatchedStreamSource.java rename to src/main/java/com/sumologic/kinesis/BatchedStreamSource.java index 10bca6a..192db34 100644 --- a/src/main/java/com/mcplusa/kinesis/BatchedStreamSource.java +++ b/src/main/java/com/sumologic/kinesis/BatchedStreamSource.java @@ -1,4 +1,4 @@ -package com.mcplusa.kinesis; +package com.sumologic.kinesis; import java.io.BufferedReader; import java.io.ByteArrayOutputStream; @@ -14,7 +14,7 @@ import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; -import com.mcplusa.sumologic.SimpleKinesisMessageModel; +import com.sumologic.client.SimpleKinesisMessageModel; import com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration; import com.amazonaws.services.kinesis.model.PutRecordRequest; diff --git a/src/main/java/com/mcplusa/kinesis/KinesisConnectorExecutor.java b/src/main/java/com/sumologic/kinesis/KinesisConnectorExecutor.java similarity index 96% rename from src/main/java/com/mcplusa/kinesis/KinesisConnectorExecutor.java rename to src/main/java/com/sumologic/kinesis/KinesisConnectorExecutor.java index f65d805..77a6e56 100644 --- a/src/main/java/com/mcplusa/kinesis/KinesisConnectorExecutor.java +++ b/src/main/java/com/sumologic/kinesis/KinesisConnectorExecutor.java @@ -1,4 +1,4 @@ -package com.mcplusa.kinesis; +package com.sumologic.kinesis; import java.io.IOException; import java.io.InputStream; @@ -7,8 +7,8 @@ import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; -import com.mcplusa.sumologic.KinesisConnectorForSumologicConfiguration; -import com.mcplusa.kinesis.KinesisConnectorExecutorBase; +import com.sumologic.client.KinesisConnectorForSumologicConfiguration; +import com.sumologic.kinesis.KinesisConnectorExecutorBase; import com.amazonaws.auth.AWSCredentialsProvider; import com.amazonaws.auth.ClasspathPropertiesFileCredentialsProvider; import com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration; diff --git a/src/main/java/com/mcplusa/kinesis/KinesisConnectorExecutorBase.java b/src/main/java/com/sumologic/kinesis/KinesisConnectorExecutorBase.java similarity index 99% rename from src/main/java/com/mcplusa/kinesis/KinesisConnectorExecutorBase.java rename to src/main/java/com/sumologic/kinesis/KinesisConnectorExecutorBase.java index 0351912..e7c8cae 100644 --- a/src/main/java/com/mcplusa/kinesis/KinesisConnectorExecutorBase.java +++ b/src/main/java/com/sumologic/kinesis/KinesisConnectorExecutorBase.java @@ -1,4 +1,4 @@ -package com.mcplusa.kinesis; +package com.sumologic.kinesis; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; diff --git a/src/main/java/com/mcplusa/kinesis/KinesisConnectorMetricsExecutor.java b/src/main/java/com/sumologic/kinesis/KinesisConnectorMetricsExecutor.java similarity index 97% rename from src/main/java/com/mcplusa/kinesis/KinesisConnectorMetricsExecutor.java rename to src/main/java/com/sumologic/kinesis/KinesisConnectorMetricsExecutor.java index 43c0e04..9a4bdb0 100644 --- a/src/main/java/com/mcplusa/kinesis/KinesisConnectorMetricsExecutor.java +++ b/src/main/java/com/sumologic/kinesis/KinesisConnectorMetricsExecutor.java @@ -1,4 +1,4 @@ -package com.mcplusa.kinesis; +package com.sumologic.kinesis; import com.amazonaws.services.kinesis.metrics.impl.CWMetricsFactory; import com.amazonaws.services.kinesis.metrics.interfaces.IMetricsFactory; diff --git a/src/main/java/com/mcplusa/kinesis/StreamSource.java b/src/main/java/com/sumologic/kinesis/StreamSource.java similarity index 97% rename from src/main/java/com/mcplusa/kinesis/StreamSource.java rename to src/main/java/com/sumologic/kinesis/StreamSource.java index 198d932..0290b5d 100644 --- a/src/main/java/com/mcplusa/kinesis/StreamSource.java +++ b/src/main/java/com/sumologic/kinesis/StreamSource.java @@ -1,4 +1,4 @@ -package com.mcplusa.kinesis; +package com.sumologic.kinesis; import java.io.BufferedReader; import java.io.IOException; @@ -9,8 +9,8 @@ import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; -import com.mcplusa.sumologic.SimpleKinesisMessageModel; -import com.mcplusa.kinesis.utils.KinesisUtils; +import com.sumologic.client.SimpleKinesisMessageModel; +import com.sumologic.kinesis.utils.KinesisUtils; import com.amazonaws.auth.AWSCredentialsProvider; import com.amazonaws.regions.RegionUtils; diff --git a/src/main/java/com/mcplusa/kinesis/utils/KinesisUtils.java b/src/main/java/com/sumologic/kinesis/utils/KinesisUtils.java similarity index 99% rename from src/main/java/com/mcplusa/kinesis/utils/KinesisUtils.java rename to src/main/java/com/sumologic/kinesis/utils/KinesisUtils.java index 26cbeed..59154b8 100644 --- a/src/main/java/com/mcplusa/kinesis/utils/KinesisUtils.java +++ b/src/main/java/com/sumologic/kinesis/utils/KinesisUtils.java @@ -1,4 +1,4 @@ -package com.mcplusa.kinesis.utils; +package com.sumologic.kinesis.utils; import java.util.List; diff --git a/src/test/java/com/mcplusa/sumologic/CloudWatchMessageModelSumologicTransformerTest.java b/src/test/java/com/sumologic/client/CloudWatchMessageModelSumologicTransformerTest.java similarity index 89% rename from src/test/java/com/mcplusa/sumologic/CloudWatchMessageModelSumologicTransformerTest.java rename to src/test/java/com/sumologic/client/CloudWatchMessageModelSumologicTransformerTest.java index 7839b34..7f31a29 100644 --- a/src/test/java/com/mcplusa/sumologic/CloudWatchMessageModelSumologicTransformerTest.java +++ b/src/test/java/com/sumologic/client/CloudWatchMessageModelSumologicTransformerTest.java @@ -1,4 +1,4 @@ -package com.mcplusa.sumologic; +package com.sumologic.client; import org.junit.Assert; import org.junit.Before; @@ -7,8 +7,8 @@ import org.junit.Ignore; import com.amazonaws.services.kinesis.model.Record; -import com.mcplusa.sumologic.CloudWatchMessageModelSumologicTransformer; -import com.mcplusa.sumologic.SimpleKinesisMessageModel; +import com.sumologic.client.CloudWatchMessageModelSumologicTransformer; +import com.sumologic.client.SimpleKinesisMessageModel; import java.io.IOException; import java.nio.charset.Charset; diff --git a/src/test/java/com/mcplusa/sumologic/SumologicSenderTest.java b/src/test/java/com/sumologic/client/SumologicSenderTest.java similarity index 92% rename from src/test/java/com/mcplusa/sumologic/SumologicSenderTest.java rename to src/test/java/com/sumologic/client/SumologicSenderTest.java index c4ead55..8961ec4 100644 --- a/src/test/java/com/mcplusa/sumologic/SumologicSenderTest.java +++ b/src/test/java/com/sumologic/client/SumologicSenderTest.java @@ -1,4 +1,4 @@ -package com.mcplusa.sumologic; +package com.sumologic.client; import java.io.IOException; import java.nio.charset.Charset; @@ -16,9 +16,9 @@ import com.github.tomakehurst.wiremock.client.WireMock; import com.github.tomakehurst.wiremock.junit.WireMockRule; -import com.mcplusa.sumologic.CloudWatchMessageModelSumologicTransformer; -import com.mcplusa.sumologic.SumologicSender; -import com.mcplusa.sumologic.implementations.SumologicEmitter; +import com.sumologic.client.CloudWatchMessageModelSumologicTransformer; +import com.sumologic.client.SumologicSender; +import com.sumologic.client.implementations.SumologicEmitter; public class SumologicSenderTest { diff --git a/src/test/java/com/mcplusa/sumologic/implementations/SumologicEmitterTest.java b/src/test/java/com/sumologic/client/implementations/SumologicEmitterTest.java similarity index 94% rename from src/test/java/com/mcplusa/sumologic/implementations/SumologicEmitterTest.java rename to src/test/java/com/sumologic/client/implementations/SumologicEmitterTest.java index 0f788f3..d1968a6 100644 --- a/src/test/java/com/mcplusa/sumologic/implementations/SumologicEmitterTest.java +++ b/src/test/java/com/sumologic/client/implementations/SumologicEmitterTest.java @@ -1,4 +1,4 @@ -package com.mcplusa.sumologic.implementations; +package com.sumologic.client.implementations; import java.util.ArrayList; import java.util.List; @@ -13,7 +13,7 @@ import com.github.tomakehurst.wiremock.client.WireMock; import com.github.tomakehurst.wiremock.junit.WireMockRule; -import com.mcplusa.sumologic.implementations.SumologicEmitter; +import com.sumologic.client.implementations.SumologicEmitter; public class SumologicEmitterTest { From 2818b541a9e0b43b228cd04ef771f1810bb53cae Mon Sep 17 00:00:00 2001 From: Juan Pablo Diaz-Vaz Date: Fri, 24 Jul 2015 10:17:58 -0300 Subject: [PATCH 3/4] SUMOK-31 Removed more references to mcplusa in packages --- build.xml | 15 ++++++++------- ...loudWatchMessageModelSumologicTransformer.java | 6 +++--- ...ltKinesisMessageModelSumologicTransformer.java | 8 ++++---- ...KinesisConnectorForSumologicConfiguration.java | 2 +- .../client/SimpleKinesisMessageModel.java | 2 +- .../com/sumologic/client/SumologicExecutor.java | 8 ++++---- .../client/SumologicMessageModelPipeline.java | 8 ++++---- .../com/sumologic/client/SumologicSender.java | 2 +- .../client/implementations/SumologicEmitter.java | 6 +++--- .../implementations/SumologicTransformer.java | 2 +- 10 files changed, 30 insertions(+), 29 deletions(-) diff --git a/build.xml b/build.xml index cf6be68..66dac1c 100644 --- a/build.xml +++ b/build.xml @@ -77,13 +77,13 @@ + includes="com/sumologic/kinesis/*.java, com/sumologic/kinesis/utils/*.java, + com/sumologic/client/*.java, com/sumologic/client/implementations/*.java"/> + includes="com/sumologic/kinesis/*.java, com/sumologic/kinesis/utils/*.java, + com/sumologic/client/*.java, com/sumologic/client/implementations/*.java"/> - + includes="com/sumologic/kinesis/*.java, com/sumologic/kinesis/utils/*.java, + com/sumologic/client/*.java, com/sumologic/client/implementations/*.java"/> + diff --git a/src/main/java/com/sumologic/client/CloudWatchMessageModelSumologicTransformer.java b/src/main/java/com/sumologic/client/CloudWatchMessageModelSumologicTransformer.java index 8fcaf31..78d9529 100644 --- a/src/main/java/com/sumologic/client/CloudWatchMessageModelSumologicTransformer.java +++ b/src/main/java/com/sumologic/client/CloudWatchMessageModelSumologicTransformer.java @@ -1,10 +1,10 @@ -package com.mcplusa.sumologic; +package com.sumologic.client; import java.io.IOException; import com.amazonaws.services.kinesis.model.Record; -import com.mcplusa.sumologic.SimpleKinesisMessageModel; -import com.mcplusa.sumologic.implementations.SumologicTransformer; +import com.sumologic.client.SimpleKinesisMessageModel; +import com.sumologic.client.implementations.SumologicTransformer; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; diff --git a/src/main/java/com/sumologic/client/DefaultKinesisMessageModelSumologicTransformer.java b/src/main/java/com/sumologic/client/DefaultKinesisMessageModelSumologicTransformer.java index bf7572d..5266d00 100644 --- a/src/main/java/com/sumologic/client/DefaultKinesisMessageModelSumologicTransformer.java +++ b/src/main/java/com/sumologic/client/DefaultKinesisMessageModelSumologicTransformer.java @@ -1,12 +1,12 @@ -package com.mcplusa.sumologic; +package com.sumologic.client; import java.io.IOException; import com.amazonaws.services.kinesis.connectors.BasicJsonTransformer; import com.amazonaws.services.kinesis.model.Record; -import com.mcplusa.sumologic.SimpleKinesisMessageModel; -import com.mcplusa.sumologic.implementations.SumologicEmitter; -import com.mcplusa.sumologic.implementations.SumologicTransformer; +import com.sumologic.client.SimpleKinesisMessageModel; +import com.sumologic.client.implementations.SumologicEmitter; +import com.sumologic.client.implementations.SumologicTransformer; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; diff --git a/src/main/java/com/sumologic/client/KinesisConnectorForSumologicConfiguration.java b/src/main/java/com/sumologic/client/KinesisConnectorForSumologicConfiguration.java index 5c124e8..bb65f84 100644 --- a/src/main/java/com/sumologic/client/KinesisConnectorForSumologicConfiguration.java +++ b/src/main/java/com/sumologic/client/KinesisConnectorForSumologicConfiguration.java @@ -1,4 +1,4 @@ -package com.mcplusa.sumologic; +package com.sumologic.client; import java.util.Properties; diff --git a/src/main/java/com/sumologic/client/SimpleKinesisMessageModel.java b/src/main/java/com/sumologic/client/SimpleKinesisMessageModel.java index e1d671e..da5e43c 100644 --- a/src/main/java/com/sumologic/client/SimpleKinesisMessageModel.java +++ b/src/main/java/com/sumologic/client/SimpleKinesisMessageModel.java @@ -1,4 +1,4 @@ -package com.mcplusa.sumologic; +package com.sumologic.client; import java.io.Serializable; diff --git a/src/main/java/com/sumologic/client/SumologicExecutor.java b/src/main/java/com/sumologic/client/SumologicExecutor.java index 97a908e..f2e48c6 100644 --- a/src/main/java/com/sumologic/client/SumologicExecutor.java +++ b/src/main/java/com/sumologic/client/SumologicExecutor.java @@ -1,10 +1,10 @@ -package com.mcplusa.sumologic; +package com.sumologic.client; import com.amazonaws.services.kinesis.connectors.KinesisConnectorRecordProcessorFactory; -import com.mcplusa.kinesis.KinesisConnectorExecutor; -import com.mcplusa.sumologic.SimpleKinesisMessageModel; -import com.mcplusa.sumologic.SumologicMessageModelPipeline; +import com.sumologic.kinesis.KinesisConnectorExecutor; +import com.sumologic.client.SimpleKinesisMessageModel; +import com.sumologic.client.SumologicMessageModelPipeline; public class SumologicExecutor extends KinesisConnectorExecutor { diff --git a/src/main/java/com/sumologic/client/SumologicMessageModelPipeline.java b/src/main/java/com/sumologic/client/SumologicMessageModelPipeline.java index 1441c83..2a2f3dd 100644 --- a/src/main/java/com/sumologic/client/SumologicMessageModelPipeline.java +++ b/src/main/java/com/sumologic/client/SumologicMessageModelPipeline.java @@ -1,11 +1,11 @@ -package com.mcplusa.sumologic; +package com.sumologic.client; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; -import com.mcplusa.sumologic.SimpleKinesisMessageModel; -import com.mcplusa.sumologic.CloudWatchMessageModelSumologicTransformer; -import com.mcplusa.sumologic.implementations.SumologicEmitter; +import com.sumologic.client.SimpleKinesisMessageModel; +import com.sumologic.client.CloudWatchMessageModelSumologicTransformer; +import com.sumologic.client.implementations.SumologicEmitter; import com.amazonaws.services.kinesis.connectors.interfaces.IKinesisConnectorPipeline; import com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration; import com.amazonaws.services.kinesis.connectors.impl.BasicMemoryBuffer; diff --git a/src/main/java/com/sumologic/client/SumologicSender.java b/src/main/java/com/sumologic/client/SumologicSender.java index 1ee9056..295234e 100644 --- a/src/main/java/com/sumologic/client/SumologicSender.java +++ b/src/main/java/com/sumologic/client/SumologicSender.java @@ -1,4 +1,4 @@ -package com.mcplusa.sumologic; +package com.sumologic.client; import java.io.ByteArrayOutputStream; import java.io.IOException; diff --git a/src/main/java/com/sumologic/client/implementations/SumologicEmitter.java b/src/main/java/com/sumologic/client/implementations/SumologicEmitter.java index b57a4fe..dc4c1da 100644 --- a/src/main/java/com/sumologic/client/implementations/SumologicEmitter.java +++ b/src/main/java/com/sumologic/client/implementations/SumologicEmitter.java @@ -1,4 +1,4 @@ -package com.mcplusa.sumologic.implementations; +package com.sumologic.client.implementations; import java.io.IOException; import java.util.ArrayList; @@ -9,8 +9,8 @@ import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; -import com.mcplusa.sumologic.SumologicSender; -import com.mcplusa.sumologic.KinesisConnectorForSumologicConfiguration; +import com.sumologic.client.SumologicSender; +import com.sumologic.client.KinesisConnectorForSumologicConfiguration; import com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration; import com.amazonaws.services.kinesis.connectors.UnmodifiableBuffer; diff --git a/src/main/java/com/sumologic/client/implementations/SumologicTransformer.java b/src/main/java/com/sumologic/client/implementations/SumologicTransformer.java index ed5bfe0..34b234d 100644 --- a/src/main/java/com/sumologic/client/implementations/SumologicTransformer.java +++ b/src/main/java/com/sumologic/client/implementations/SumologicTransformer.java @@ -1,4 +1,4 @@ -package com.mcplusa.sumologic.implementations; +package com.sumologic.client.implementations; import com.amazonaws.services.kinesis.connectors.interfaces.ITransformer; From c9d98e6dff9c57923eeacd22f45f4f52d9a06e95 Mon Sep 17 00:00:00 2001 From: Juan Pablo Diaz-Vaz Date: Fri, 24 Jul 2015 10:20:44 -0300 Subject: [PATCH 4/4] SUMOK-31 Modified package reference hardcoded --- .../com/sumologic/client/SumologicMessageModelPipeline.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/com/sumologic/client/SumologicMessageModelPipeline.java b/src/main/java/com/sumologic/client/SumologicMessageModelPipeline.java index 2a2f3dd..edbf76b 100644 --- a/src/main/java/com/sumologic/client/SumologicMessageModelPipeline.java +++ b/src/main/java/com/sumologic/client/SumologicMessageModelPipeline.java @@ -47,7 +47,7 @@ public IBuffer getBuffer(KinesisConnectorConfiguratio // Load specified class String argClass = ((KinesisConnectorForSumologicConfiguration)configuration).TRANSFORMER_CLASS; - String className = "com.mcplusa.sumologic."+argClass; + String className = "com.sumologic.client."+argClass; ClassLoader classLoader = SumologicMessageModelPipeline.class.getClassLoader(); Class ModelClass = null; try {