Repository: atlas Updated Branches: refs/heads/0.8-incubating 374cc342d -> 8967f0cf6
ATLAS-2048: Fix for Unit test failure on 0.8-incubating branch Signed-off-by: Sarath Subramanian <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/atlas/repo Commit: http://git-wip-us.apache.org/repos/asf/atlas/commit/8967f0cf Tree: http://git-wip-us.apache.org/repos/asf/atlas/tree/8967f0cf Diff: http://git-wip-us.apache.org/repos/asf/atlas/diff/8967f0cf Branch: refs/heads/0.8-incubating Commit: 8967f0cf62cae4c6d6215a7fb4fc0b1d7bac9789 Parents: 374cc34 Author: nixonrodrigues <[email protected]> Authored: Wed Aug 16 11:58:10 2017 -0700 Committer: Sarath Subramanian <[email protected]> Committed: Wed Aug 16 11:58:10 2017 -0700 ---------------------------------------------------------------------- .../NotificationHookConsumerKafkaTest.java | 26 ++------------------ 1 file changed, 2 insertions(+), 24 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/atlas/blob/8967f0cf/webapp/src/test/java/org/apache/atlas/notification/NotificationHookConsumerKafkaTest.java ---------------------------------------------------------------------- diff --git a/webapp/src/test/java/org/apache/atlas/notification/NotificationHookConsumerKafkaTest.java b/webapp/src/test/java/org/apache/atlas/notification/NotificationHookConsumerKafkaTest.java index 1a3c413..eb37fa8 100644 --- a/webapp/src/test/java/org/apache/atlas/notification/NotificationHookConsumerKafkaTest.java +++ b/webapp/src/test/java/org/apache/atlas/notification/NotificationHookConsumerKafkaTest.java @@ -100,30 +100,8 @@ public class NotificationHookConsumerKafkaTest { produceMessage(new HookNotification.EntityCreateRequest("test_user1", createEntity())); NotificationConsumer<HookNotificationMessage> consumer = createNewConsumer(kafkaNotification, false); - NotificationHookConsumer notificationHookConsumer = new NotificationHookConsumer(notificationInterface, atlasEntityStore, serviceState, instanceConverter, typeRegistry); - NotificationHookConsumer.HookConsumer hookConsumer = notificationHookConsumer.new HookConsumer(consumer); - - consumeOneMessage(consumer, hookConsumer); - verify(atlasEntityStore).createOrUpdate(any(EntityStream.class), anyBoolean()); - - // produce another message, and make sure it moves ahead. If commit succeeded, this would work. - produceMessage(new HookNotification.EntityCreateRequest("test_user2", createEntity())); - consumeOneMessage(consumer, hookConsumer); - verify(atlasEntityStore,times(2)).createOrUpdate(any(EntityStream.class), anyBoolean()); - reset(atlasEntityStore); - } - finally { - kafkaNotification.close(); - } - } - - @Test - public void testConsumerConsumesNewMessageWithAutoCommitDisabled1() throws AtlasException, InterruptedException, AtlasBaseException { - try { - produceMessage(new HookNotification.EntityCreateRequest("test_user1", createEntity())); - - NotificationConsumer<HookNotificationMessage> consumer = createNewConsumer(kafkaNotification, false); - NotificationHookConsumer notificationHookConsumer = new NotificationHookConsumer(notificationInterface, atlasEntityStore, serviceState, instanceConverter, typeRegistry); + NotificationHookConsumer notificationHookConsumer = + new NotificationHookConsumer(notificationInterface, atlasEntityStore, serviceState, instanceConverter, typeRegistry); NotificationHookConsumer.HookConsumer hookConsumer = notificationHookConsumer.new HookConsumer(consumer); consumeOneMessage(consumer, hookConsumer);
