diff --git a/src/main/java/org/springframework/integration/splunk/support/SplunkDataReader.java b/src/main/java/org/springframework/integration/splunk/support/SplunkDataReader.java index 3de0548..0eb626f 100644 --- a/src/main/java/org/springframework/integration/splunk/support/SplunkDataReader.java +++ b/src/main/java/org/springframework/integration/splunk/support/SplunkDataReader.java @@ -193,7 +193,9 @@ public class SplunkDataReader implements DataReader, InitializingBean { return exportSearch(); } case REALTIME: { - return realtimeSearch(); + throw new UnsupportedOperationException("The 'real-time' search isn't supported " + + "because of the infinite Splunk Job nature."); +// return realtimeSearch(); } } return null; diff --git a/src/main/resources/org/springframework/integration/splunk/config/xml/spring-integration-splunk-1.1.xsd b/src/main/resources/org/springframework/integration/splunk/config/xml/spring-integration-splunk-1.1.xsd index 4fe55b8..4950b83 100644 --- a/src/main/resources/org/springframework/integration/splunk/config/xml/spring-integration-splunk-1.1.xsd +++ b/src/main/resources/org/springframework/integration/splunk/config/xml/spring-integration-splunk-1.1.xsd @@ -181,7 +181,7 @@ Indicates the connection timeout in ms. - Search mode: normal, blocking, realtime, export, saved + Search mode: normal, blocking, export, saved @@ -250,7 +250,7 @@ Indicates the connection timeout in ms. - + @@ -260,7 +260,7 @@ Indicates the connection timeout in ms. - + @@ -346,7 +346,7 @@ Indicates the connection timeout in ms. - + @@ -354,7 +354,7 @@ Indicates the connection timeout in ms. - + diff --git a/src/test/java/org/springframework/integration/splunk/support/SplunkDataReaderTests.java b/src/test/java/org/springframework/integration/splunk/support/SplunkDataReaderTests.java index 3249b1a..666f9e3 100644 --- a/src/test/java/org/springframework/integration/splunk/support/SplunkDataReaderTests.java +++ b/src/test/java/org/springframework/integration/splunk/support/SplunkDataReaderTests.java @@ -28,6 +28,7 @@ import com.splunk.JobCollection; import com.splunk.Service; import org.junit.Assert; import org.junit.Before; +import org.junit.Ignore; import org.junit.Test; import org.springframework.core.io.ClassPathResource; @@ -72,6 +73,7 @@ public class SplunkDataReaderTests { } + @Ignore @Test public void testRealtimeSearch() throws Exception { reader.setMode(SearchMode.REALTIME);