This is an automated email from the ASF dual-hosted git repository. madhan pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/atlas.git
from c482cc3c0 ATLAS-4968: checkstyle compliance updates - tools module (#281) add 391ddba7a ATLAS-4963: checkstyle compliance updates - atlas-notification module (#280) No new revisions were added by this update. Summary of changes: dev-support/checkstyle-suppressions.xml | 1 + notification/pom.xml | 5 + .../main/java/org/apache/atlas/hook/AtlasHook.java | 411 +++++++++++---------- .../org/apache/atlas/hook/AtlasHookException.java | 7 +- .../org/apache/atlas/hook/AtlasTopicCreator.java | 42 ++- .../apache/atlas/hook/FailedMessagesLogger.java | 10 +- .../org/apache/atlas/kafka/AtlasKafkaConsumer.java | 77 ++-- .../org/apache/atlas/kafka/AtlasKafkaMessage.java | 14 +- .../apache/atlas/kafka/EmbeddedKafkaServer.java | 32 +- .../org/apache/atlas/kafka/KafkaNotification.java | 297 +++++++-------- .../apache/atlas/kafka/NotificationProvider.java | 22 +- .../notification/AbstractMessageDeserializer.java | 13 +- .../atlas/notification/AbstractNotification.java | 145 ++++---- .../notification/AbstractNotificationConsumer.java | 7 +- .../AtlasNotificationMessageDeserializer.java | 124 +++---- .../notification/IncompatibleVersionException.java | 8 +- .../atlas/notification/MessageDeserializer.java | 8 +- .../atlas/notification/NotificationConsumer.java | 16 +- .../atlas/notification/NotificationException.java | 14 +- .../atlas/notification/NotificationInterface.java | 55 ++- .../atlas/notification/SplitMessageAggregator.java | 7 +- .../entity/EntityMessageDeserializer.java | 13 +- .../notification/hook/HookMessageDeserializer.java | 15 +- .../atlas/notification/rest/RestNotification.java | 127 ++++--- .../apache/atlas/notification/spool/Archiver.java | 10 +- .../atlas/notification/spool/AtlasFileSpool.java | 44 +-- .../atlas/notification/spool/FileOperations.java | 6 +- .../atlas/notification/spool/IndexManagement.java | 157 ++++---- .../apache/atlas/notification/spool/Publisher.java | 79 ++-- .../notification/spool/SpoolConfiguration.java | 24 +- .../atlas/notification/spool/SpoolUtils.java | 75 ++-- .../apache/atlas/notification/spool/Spooler.java | 22 +- .../notification/spool/models/IndexRecord.java | 55 ++- .../notification/spool/models/IndexRecords.java | 12 +- .../spool/utils/local/FileLockedReadWrite.java | 6 +- .../spool/utils/local/FileOpAppend.java | 7 +- .../spool/utils/local/FileOpDelete.java | 6 +- .../notification/spool/utils/local/FileOpRead.java | 6 +- .../spool/utils/local/FileOpUpdate.java | 8 +- .../spool/utils/local/FileOperation.java | 41 +- .../apache/atlas/util/CommandHandlerUtility.java | 24 +- .../java/org/apache/atlas/hook/AtlasHookTest.java | 83 ++--- .../apache/atlas/hook/AtlasTopicCreatorTest.java | 53 +-- .../org/apache/atlas/kafka/KafkaConsumerTest.java | 148 ++++---- .../atlas/kafka/KafkaNotificationMockTest.java | 137 ++++--- .../apache/atlas/kafka/KafkaNotificationTest.java | 33 +- .../AbstractNotificationConsumerTest.java | 139 +++---- .../notification/AbstractNotificationTest.java | 32 +- .../notification/AtlasNotificationMessageTest.java | 51 +-- .../atlas/notification/MessageVersionTest.java | 66 ++-- .../atlas/notification/RestNotificationTest.java | 70 ++-- .../notification/SplitMessageAggregatorTest.java | 20 +- .../entity/EntityNotificationDeserializerTest.java | 16 +- .../entity/EntityNotificationTest.java | 67 ++-- .../hook/HookNotificationDeserializerTest.java | 29 +- .../notification/hook/HookNotificationTest.java | 46 ++- .../notification/spool/AtlasFileSpoolTest.java | 169 ++++----- .../apache/atlas/notification/spool/BaseTest.java | 22 +- .../notification/spool/IndexManagementTest.java | 98 ++--- 59 files changed, 1649 insertions(+), 1682 deletions(-)