From 6137b1fc8547ae43488b3d8ee4edde389d9fc8d2 Mon Sep 17 00:00:00 2001 From: Suhothayan Date: Thu, 29 Aug 2019 21:25:49 +0530 Subject: [PATCH] Fix build issue --- .../siddhi/core/transport/InMemoryTransportTestCase.java | 4 ++-- .../core/transport/TestSourceOptionSourceMapper.java | 9 +++++---- 2 files changed, 7 insertions(+), 6 deletions(-) diff --git a/modules/siddhi-core/src/test/java/io/siddhi/core/transport/InMemoryTransportTestCase.java b/modules/siddhi-core/src/test/java/io/siddhi/core/transport/InMemoryTransportTestCase.java index 00223d6c3c..5c59e70f31 100644 --- a/modules/siddhi-core/src/test/java/io/siddhi/core/transport/InMemoryTransportTestCase.java +++ b/modules/siddhi-core/src/test/java/io/siddhi/core/transport/InMemoryTransportTestCase.java @@ -1222,10 +1222,10 @@ public void receive(Event[] events) { for (Event event : events) { switch (wso2Count.incrementAndGet()) { case 1: - Assert.assertEquals( event.getData(),new Object[]{"WSO2", "inMemory", 100l}); + Assert.assertEquals(event.getData(), new Object[]{"WSO2", "inMemory", 100L}); break; case 2: - Assert.assertEquals( event.getData(),new Object[]{"WSO2", "inMemory", 101l}); + Assert.assertEquals(event.getData(), new Object[]{"WSO2", "inMemory", 101L}); break; default: org.testng.AssertJUnit.fail(); diff --git a/modules/siddhi-core/src/test/java/io/siddhi/core/transport/TestSourceOptionSourceMapper.java b/modules/siddhi-core/src/test/java/io/siddhi/core/transport/TestSourceOptionSourceMapper.java index ce0195fb69..c89d4dd77a 100644 --- a/modules/siddhi-core/src/test/java/io/siddhi/core/transport/TestSourceOptionSourceMapper.java +++ b/modules/siddhi-core/src/test/java/io/siddhi/core/transport/TestSourceOptionSourceMapper.java @@ -64,14 +64,15 @@ public Class[] getSupportedInputEventClasses() { protected void mapAndProcess(Object eventObject, InputEventHandler inputEventHandler) throws InterruptedException { if (eventObject != null) { if (eventObject instanceof Event) { - Event event=((Event) eventObject); - event.getData()[0]=sourceOptionHolder.validateAndGetOption("topic").getValue(event); - event.getData()[1]=sourceType; + Event event = ((Event) eventObject); + event.getData()[0] = sourceOptionHolder.validateAndGetOption("topic").getValue(event); + event.getData()[1] = sourceType; inputEventHandler.sendEvent((Event) eventObject); - } else + } else { throw new SiddhiAppRuntimeException("Event object must be Event " + "but found " + eventObject.getClass().getCanonicalName()); } + } }