Merge pull request #1476 from suhothayan/master

Fix build
siddhi-io · Aug 29, 2019 · 1b5f045 · 1b5f045
2 parents e5f7c52 + cef0c7b
commit 1b5f045
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 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
@@ -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
@@ -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());
             }
+        }
 
     }