diff --git a/javadsl/.idea/.name b/javadsl/.idea/.name
new file mode 100644
index 0000000..1bd61ef
--- /dev/null
+++ b/javadsl/.idea/.name
@@ -0,0 +1 @@
+scdfdsl
\ No newline at end of file
diff --git a/javadsl/.idea/compiler.xml b/javadsl/.idea/compiler.xml
new file mode 100644
index 0000000..da2d27a
--- /dev/null
+++ b/javadsl/.idea/compiler.xml
@@ -0,0 +1,16 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/encodings.xml b/javadsl/.idea/encodings.xml
new file mode 100644
index 0000000..b26911b
--- /dev/null
+++ b/javadsl/.idea/encodings.xml
@@ -0,0 +1,6 @@
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__ch_qos_logback_logback_classic_1_1_11.xml b/javadsl/.idea/libraries/Maven__ch_qos_logback_logback_classic_1_1_11.xml
new file mode 100644
index 0000000..c6ea67e
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__ch_qos_logback_logback_classic_1_1_11.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__ch_qos_logback_logback_core_1_1_11.xml b/javadsl/.idea/libraries/Maven__ch_qos_logback_logback_core_1_1_11.xml
new file mode 100644
index 0000000..f538e36
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__ch_qos_logback_logback_core_1_1_11.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__com_fasterxml_classmate_1_3_4.xml b/javadsl/.idea/libraries/Maven__com_fasterxml_classmate_1_3_4.xml
new file mode 100644
index 0000000..33c30b4
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__com_fasterxml_classmate_1_3_4.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__com_fasterxml_jackson_core_jackson_annotations_2_8_0.xml b/javadsl/.idea/libraries/Maven__com_fasterxml_jackson_core_jackson_annotations_2_8_0.xml
new file mode 100644
index 0000000..49b4ec7
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__com_fasterxml_jackson_core_jackson_annotations_2_8_0.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__com_fasterxml_jackson_core_jackson_core_2_8_10.xml b/javadsl/.idea/libraries/Maven__com_fasterxml_jackson_core_jackson_core_2_8_10.xml
new file mode 100644
index 0000000..5d9d662
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__com_fasterxml_jackson_core_jackson_core_2_8_10.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__com_fasterxml_jackson_core_jackson_databind_2_8_10.xml b/javadsl/.idea/libraries/Maven__com_fasterxml_jackson_core_jackson_databind_2_8_10.xml
new file mode 100644
index 0000000..df5cb22
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__com_fasterxml_jackson_core_jackson_databind_2_8_10.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__com_fasterxml_jackson_dataformat_jackson_dataformat_yaml_2_8_10.xml b/javadsl/.idea/libraries/Maven__com_fasterxml_jackson_dataformat_jackson_dataformat_yaml_2_8_10.xml
new file mode 100644
index 0000000..88c8172
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__com_fasterxml_jackson_dataformat_jackson_dataformat_yaml_2_8_10.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__com_ibm_jbatch_com_ibm_jbatch_tck_spi_1_0.xml b/javadsl/.idea/libraries/Maven__com_ibm_jbatch_com_ibm_jbatch_tck_spi_1_0.xml
new file mode 100644
index 0000000..2d6c591
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__com_ibm_jbatch_com_ibm_jbatch_tck_spi_1_0.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__com_jayway_jsonpath_json_path_2_2_0.xml b/javadsl/.idea/libraries/Maven__com_jayway_jsonpath_json_path_2_2_0.xml
new file mode 100644
index 0000000..578b079
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__com_jayway_jsonpath_json_path_2_2_0.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__com_thoughtworks_xstream_xstream_1_4_7.xml b/javadsl/.idea/libraries/Maven__com_thoughtworks_xstream_xstream_1_4_7.xml
new file mode 100644
index 0000000..08952d7
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__com_thoughtworks_xstream_xstream_1_4_7.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__com_vaadin_external_google_android_json_0_0_20131108_vaadin1.xml b/javadsl/.idea/libraries/Maven__com_vaadin_external_google_android_json_0_0_20131108_vaadin1.xml
new file mode 100644
index 0000000..b8581a6
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__com_vaadin_external_google_android_json_0_0_20131108_vaadin1.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__commons_codec_commons_codec_1_10.xml b/javadsl/.idea/libraries/Maven__commons_codec_commons_codec_1_10.xml
new file mode 100644
index 0000000..27424a1
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__commons_codec_commons_codec_1_10.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__javax_batch_javax_batch_api_1_0.xml b/javadsl/.idea/libraries/Maven__javax_batch_javax_batch_api_1_0.xml
new file mode 100644
index 0000000..6be63d2
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__javax_batch_javax_batch_api_1_0.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__javax_validation_validation_api_1_1_0_Final.xml b/javadsl/.idea/libraries/Maven__javax_validation_validation_api_1_1_0_Final.xml
new file mode 100644
index 0000000..940ce73
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__javax_validation_validation_api_1_1_0_Final.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__joda_time_joda_time_2_9_9.xml b/javadsl/.idea/libraries/Maven__joda_time_joda_time_2_9_9.xml
new file mode 100644
index 0000000..a468f58
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__joda_time_joda_time_2_9_9.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__junit_junit_4_12.xml b/javadsl/.idea/libraries/Maven__junit_junit_4_12.xml
new file mode 100644
index 0000000..d411041
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__junit_junit_4_12.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__net_minidev_accessors_smart_1_1.xml b/javadsl/.idea/libraries/Maven__net_minidev_accessors_smart_1_1.xml
new file mode 100644
index 0000000..88d626e
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__net_minidev_accessors_smart_1_1.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__net_minidev_json_smart_2_2_1.xml b/javadsl/.idea/libraries/Maven__net_minidev_json_smart_2_2_1.xml
new file mode 100644
index 0000000..6c692c8
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__net_minidev_json_smart_2_2_1.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_apache_commons_commons_lang3_3_4.xml b/javadsl/.idea/libraries/Maven__org_apache_commons_commons_lang3_3_4.xml
new file mode 100644
index 0000000..78cfcd3
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_apache_commons_commons_lang3_3_4.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_apache_httpcomponents_httpclient_4_5_3.xml b/javadsl/.idea/libraries/Maven__org_apache_httpcomponents_httpclient_4_5_3.xml
new file mode 100644
index 0000000..c82bb7c
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_apache_httpcomponents_httpclient_4_5_3.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_apache_httpcomponents_httpcore_4_4_8.xml b/javadsl/.idea/libraries/Maven__org_apache_httpcomponents_httpcore_4_4_8.xml
new file mode 100644
index 0000000..6372678
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_apache_httpcomponents_httpcore_4_4_8.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_apache_tomcat_embed_tomcat_embed_el_8_5_23.xml b/javadsl/.idea/libraries/Maven__org_apache_tomcat_embed_tomcat_embed_el_8_5_23.xml
new file mode 100644
index 0000000..9837b75
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_apache_tomcat_embed_tomcat_embed_el_8_5_23.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_assertj_assertj_core_2_6_0.xml b/javadsl/.idea/libraries/Maven__org_assertj_assertj_core_2_6_0.xml
new file mode 100644
index 0000000..58bdc9a
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_assertj_assertj_core_2_6_0.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_codehaus_jettison_jettison_1_2.xml b/javadsl/.idea/libraries/Maven__org_codehaus_jettison_jettison_1_2.xml
new file mode 100644
index 0000000..ddac9ec
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_codehaus_jettison_jettison_1_2.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_hamcrest_hamcrest_core_1_3.xml b/javadsl/.idea/libraries/Maven__org_hamcrest_hamcrest_core_1_3.xml
new file mode 100644
index 0000000..f58bbc1
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_hamcrest_hamcrest_core_1_3.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_hamcrest_hamcrest_library_1_3.xml b/javadsl/.idea/libraries/Maven__org_hamcrest_hamcrest_library_1_3.xml
new file mode 100644
index 0000000..78dbe45
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_hamcrest_hamcrest_library_1_3.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_hibernate_hibernate_validator_5_3_5_Final.xml b/javadsl/.idea/libraries/Maven__org_hibernate_hibernate_validator_5_3_5_Final.xml
new file mode 100644
index 0000000..4bd0591
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_hibernate_hibernate_validator_5_3_5_Final.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_hibernate_javax_persistence_hibernate_jpa_2_1_api_1_0_0_Final.xml b/javadsl/.idea/libraries/Maven__org_hibernate_javax_persistence_hibernate_jpa_2_1_api_1_0_0_Final.xml
new file mode 100644
index 0000000..6492b2b
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_hibernate_javax_persistence_hibernate_jpa_2_1_api_1_0_0_Final.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_jboss_logging_jboss_logging_3_3_1_Final.xml b/javadsl/.idea/libraries/Maven__org_jboss_logging_jboss_logging_3_3_1_Final.xml
new file mode 100644
index 0000000..6dc7a37
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_jboss_logging_jboss_logging_3_3_1_Final.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_mockito_mockito_core_1_10_19.xml b/javadsl/.idea/libraries/Maven__org_mockito_mockito_core_1_10_19.xml
new file mode 100644
index 0000000..a523703
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_mockito_mockito_core_1_10_19.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_objenesis_objenesis_2_1.xml b/javadsl/.idea/libraries/Maven__org_objenesis_objenesis_2_1.xml
new file mode 100644
index 0000000..7ab319b
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_objenesis_objenesis_2_1.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_ow2_asm_asm_5_0_3.xml b/javadsl/.idea/libraries/Maven__org_ow2_asm_asm_5_0_3.xml
new file mode 100644
index 0000000..da69f6c
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_ow2_asm_asm_5_0_3.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_skyscreamer_jsonassert_1_4_0.xml b/javadsl/.idea/libraries/Maven__org_skyscreamer_jsonassert_1_4_0.xml
new file mode 100644
index 0000000..f86d2c8
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_skyscreamer_jsonassert_1_4_0.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_slf4j_jcl_over_slf4j_1_7_25.xml b/javadsl/.idea/libraries/Maven__org_slf4j_jcl_over_slf4j_1_7_25.xml
new file mode 100644
index 0000000..bae9949
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_slf4j_jcl_over_slf4j_1_7_25.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_slf4j_jul_to_slf4j_1_7_25.xml b/javadsl/.idea/libraries/Maven__org_slf4j_jul_to_slf4j_1_7_25.xml
new file mode 100644
index 0000000..6073e53
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_slf4j_jul_to_slf4j_1_7_25.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_slf4j_log4j_over_slf4j_1_7_25.xml b/javadsl/.idea/libraries/Maven__org_slf4j_log4j_over_slf4j_1_7_25.xml
new file mode 100644
index 0000000..a14ac63
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_slf4j_log4j_over_slf4j_1_7_25.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_slf4j_slf4j_api_1_7_25.xml b/javadsl/.idea/libraries/Maven__org_slf4j_slf4j_api_1_7_25.xml
new file mode 100644
index 0000000..20e8163
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_slf4j_slf4j_api_1_7_25.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_springframework_analytics_spring_analytics_1_1_3_RELEASE.xml b/javadsl/.idea/libraries/Maven__org_springframework_analytics_spring_analytics_1_1_3_RELEASE.xml
new file mode 100644
index 0000000..2ae0f28
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_springframework_analytics_spring_analytics_1_1_3_RELEASE.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_springframework_batch_spring_batch_core_3_0_8_RELEASE.xml b/javadsl/.idea/libraries/Maven__org_springframework_batch_spring_batch_core_3_0_8_RELEASE.xml
new file mode 100644
index 0000000..34d1a84
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_springframework_batch_spring_batch_core_3_0_8_RELEASE.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_springframework_batch_spring_batch_infrastructure_3_0_8_RELEASE.xml b/javadsl/.idea/libraries/Maven__org_springframework_batch_spring_batch_infrastructure_3_0_8_RELEASE.xml
new file mode 100644
index 0000000..0718365
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_springframework_batch_spring_batch_infrastructure_3_0_8_RELEASE.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_springframework_boot_spring_boot_1_5_8_RELEASE.xml b/javadsl/.idea/libraries/Maven__org_springframework_boot_spring_boot_1_5_8_RELEASE.xml
new file mode 100644
index 0000000..5226c5b
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_springframework_boot_spring_boot_1_5_8_RELEASE.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_springframework_boot_spring_boot_actuator_1_5_8_RELEASE.xml b/javadsl/.idea/libraries/Maven__org_springframework_boot_spring_boot_actuator_1_5_8_RELEASE.xml
new file mode 100644
index 0000000..ffd6fef
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_springframework_boot_spring_boot_actuator_1_5_8_RELEASE.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_springframework_boot_spring_boot_autoconfigure_1_5_8_RELEASE.xml b/javadsl/.idea/libraries/Maven__org_springframework_boot_spring_boot_autoconfigure_1_5_8_RELEASE.xml
new file mode 100644
index 0000000..9297c27
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_springframework_boot_spring_boot_autoconfigure_1_5_8_RELEASE.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_springframework_boot_spring_boot_configuration_metadata_1_5_8_RELEASE.xml b/javadsl/.idea/libraries/Maven__org_springframework_boot_spring_boot_configuration_metadata_1_5_8_RELEASE.xml
new file mode 100644
index 0000000..569bf4d
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_springframework_boot_spring_boot_configuration_metadata_1_5_8_RELEASE.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_springframework_boot_spring_boot_starter_1_5_8_RELEASE.xml b/javadsl/.idea/libraries/Maven__org_springframework_boot_spring_boot_starter_1_5_8_RELEASE.xml
new file mode 100644
index 0000000..760647e
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_springframework_boot_spring_boot_starter_1_5_8_RELEASE.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_springframework_boot_spring_boot_starter_actuator_1_5_8_RELEASE.xml b/javadsl/.idea/libraries/Maven__org_springframework_boot_spring_boot_starter_actuator_1_5_8_RELEASE.xml
new file mode 100644
index 0000000..61461eb
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_springframework_boot_spring_boot_starter_actuator_1_5_8_RELEASE.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_springframework_boot_spring_boot_starter_logging_1_5_8_RELEASE.xml b/javadsl/.idea/libraries/Maven__org_springframework_boot_spring_boot_starter_logging_1_5_8_RELEASE.xml
new file mode 100644
index 0000000..1eb8fb2
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_springframework_boot_spring_boot_starter_logging_1_5_8_RELEASE.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_springframework_boot_spring_boot_starter_test_1_5_8_RELEASE.xml b/javadsl/.idea/libraries/Maven__org_springframework_boot_spring_boot_starter_test_1_5_8_RELEASE.xml
new file mode 100644
index 0000000..14ebf86
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_springframework_boot_spring_boot_starter_test_1_5_8_RELEASE.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_springframework_boot_spring_boot_starter_validation_1_5_8_RELEASE.xml b/javadsl/.idea/libraries/Maven__org_springframework_boot_spring_boot_starter_validation_1_5_8_RELEASE.xml
new file mode 100644
index 0000000..dbf83c5
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_springframework_boot_spring_boot_starter_validation_1_5_8_RELEASE.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_springframework_boot_spring_boot_test_1_5_8_RELEASE.xml b/javadsl/.idea/libraries/Maven__org_springframework_boot_spring_boot_test_1_5_8_RELEASE.xml
new file mode 100644
index 0000000..5d582d2
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_springframework_boot_spring_boot_test_1_5_8_RELEASE.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_springframework_boot_spring_boot_test_autoconfigure_1_5_8_RELEASE.xml b/javadsl/.idea/libraries/Maven__org_springframework_boot_spring_boot_test_autoconfigure_1_5_8_RELEASE.xml
new file mode 100644
index 0000000..5283f87
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_springframework_boot_spring_boot_test_autoconfigure_1_5_8_RELEASE.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_springframework_cloud_spring_cloud_dataflow_core_1_3_0_BUILD_SNAPSHOT.xml b/javadsl/.idea/libraries/Maven__org_springframework_cloud_spring_cloud_dataflow_core_1_3_0_BUILD_SNAPSHOT.xml
new file mode 100644
index 0000000..794ea93
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_springframework_cloud_spring_cloud_dataflow_core_1_3_0_BUILD_SNAPSHOT.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_springframework_cloud_spring_cloud_dataflow_rest_client_1_3_0_BUILD_SNAPSHOT.xml b/javadsl/.idea/libraries/Maven__org_springframework_cloud_spring_cloud_dataflow_rest_client_1_3_0_BUILD_SNAPSHOT.xml
new file mode 100644
index 0000000..d3d071e
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_springframework_cloud_spring_cloud_dataflow_rest_client_1_3_0_BUILD_SNAPSHOT.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_springframework_cloud_spring_cloud_dataflow_rest_resource_1_3_0_BUILD_SNAPSHOT.xml b/javadsl/.idea/libraries/Maven__org_springframework_cloud_spring_cloud_dataflow_rest_resource_1_3_0_BUILD_SNAPSHOT.xml
new file mode 100644
index 0000000..69cd439
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_springframework_cloud_spring_cloud_dataflow_rest_resource_1_3_0_BUILD_SNAPSHOT.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_springframework_cloud_spring_cloud_deployer_resource_support_1_2_1_RELEASE.xml b/javadsl/.idea/libraries/Maven__org_springframework_cloud_spring_cloud_deployer_resource_support_1_2_1_RELEASE.xml
new file mode 100644
index 0000000..8df3d38
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_springframework_cloud_spring_cloud_deployer_resource_support_1_2_1_RELEASE.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_springframework_cloud_spring_cloud_deployer_spi_1_3_0_M2.xml b/javadsl/.idea/libraries/Maven__org_springframework_cloud_spring_cloud_deployer_spi_1_3_0_M2.xml
new file mode 100644
index 0000000..7be60f0
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_springframework_cloud_spring_cloud_deployer_spi_1_3_0_M2.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_springframework_cloud_spring_cloud_skipper_1_0_0_BUILD_SNAPSHOT.xml b/javadsl/.idea/libraries/Maven__org_springframework_cloud_spring_cloud_skipper_1_0_0_BUILD_SNAPSHOT.xml
new file mode 100644
index 0000000..78ad035
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_springframework_cloud_spring_cloud_skipper_1_0_0_BUILD_SNAPSHOT.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_springframework_cloud_spring_cloud_task_core_1_2_1_RELEASE.xml b/javadsl/.idea/libraries/Maven__org_springframework_cloud_spring_cloud_task_core_1_2_1_RELEASE.xml
new file mode 100644
index 0000000..8c69a80
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_springframework_cloud_spring_cloud_task_core_1_2_1_RELEASE.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_springframework_data_spring_data_commons_1_13_8_RELEASE.xml b/javadsl/.idea/libraries/Maven__org_springframework_data_spring_data_commons_1_13_8_RELEASE.xml
new file mode 100644
index 0000000..844b177
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_springframework_data_spring_data_commons_1_13_8_RELEASE.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_springframework_data_spring_data_keyvalue_1_2_8_RELEASE.xml b/javadsl/.idea/libraries/Maven__org_springframework_data_spring_data_keyvalue_1_2_8_RELEASE.xml
new file mode 100644
index 0000000..3813e79
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_springframework_data_spring_data_keyvalue_1_2_8_RELEASE.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_springframework_hateoas_spring_hateoas_0_23_0_RELEASE.xml b/javadsl/.idea/libraries/Maven__org_springframework_hateoas_spring_hateoas_0_23_0_RELEASE.xml
new file mode 100644
index 0000000..92e7f9f
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_springframework_hateoas_spring_hateoas_0_23_0_RELEASE.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_springframework_plugin_spring_plugin_core_1_2_0_RELEASE.xml b/javadsl/.idea/libraries/Maven__org_springframework_plugin_spring_plugin_core_1_2_0_RELEASE.xml
new file mode 100644
index 0000000..fbc0452
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_springframework_plugin_spring_plugin_core_1_2_0_RELEASE.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_springframework_retry_spring_retry_1_2_1_RELEASE.xml b/javadsl/.idea/libraries/Maven__org_springframework_retry_spring_retry_1_2_1_RELEASE.xml
new file mode 100644
index 0000000..bd2629e
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_springframework_retry_spring_retry_1_2_1_RELEASE.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_springframework_spring_aop_4_3_12_RELEASE.xml b/javadsl/.idea/libraries/Maven__org_springframework_spring_aop_4_3_12_RELEASE.xml
new file mode 100644
index 0000000..0804f96
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_springframework_spring_aop_4_3_12_RELEASE.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_springframework_spring_beans_4_3_12_RELEASE.xml b/javadsl/.idea/libraries/Maven__org_springframework_spring_beans_4_3_12_RELEASE.xml
new file mode 100644
index 0000000..4630fab
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_springframework_spring_beans_4_3_12_RELEASE.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_springframework_spring_context_4_3_12_RELEASE.xml b/javadsl/.idea/libraries/Maven__org_springframework_spring_context_4_3_12_RELEASE.xml
new file mode 100644
index 0000000..93ceada
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_springframework_spring_context_4_3_12_RELEASE.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_springframework_spring_core_4_3_12_RELEASE.xml b/javadsl/.idea/libraries/Maven__org_springframework_spring_core_4_3_12_RELEASE.xml
new file mode 100644
index 0000000..134018a
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_springframework_spring_core_4_3_12_RELEASE.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_springframework_spring_expression_4_3_12_RELEASE.xml b/javadsl/.idea/libraries/Maven__org_springframework_spring_expression_4_3_12_RELEASE.xml
new file mode 100644
index 0000000..b9bbe52
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_springframework_spring_expression_4_3_12_RELEASE.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_springframework_spring_jdbc_4_3_12_RELEASE.xml b/javadsl/.idea/libraries/Maven__org_springframework_spring_jdbc_4_3_12_RELEASE.xml
new file mode 100644
index 0000000..aab4414
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_springframework_spring_jdbc_4_3_12_RELEASE.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_springframework_spring_test_4_3_12_RELEASE.xml b/javadsl/.idea/libraries/Maven__org_springframework_spring_test_4_3_12_RELEASE.xml
new file mode 100644
index 0000000..e6e7e5e
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_springframework_spring_test_4_3_12_RELEASE.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_springframework_spring_tx_4_3_12_RELEASE.xml b/javadsl/.idea/libraries/Maven__org_springframework_spring_tx_4_3_12_RELEASE.xml
new file mode 100644
index 0000000..5abb24b
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_springframework_spring_tx_4_3_12_RELEASE.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_springframework_spring_web_4_3_12_RELEASE.xml b/javadsl/.idea/libraries/Maven__org_springframework_spring_web_4_3_12_RELEASE.xml
new file mode 100644
index 0000000..27cfa73
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_springframework_spring_web_4_3_12_RELEASE.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_springframework_spring_webmvc_4_3_12_RELEASE.xml b/javadsl/.idea/libraries/Maven__org_springframework_spring_webmvc_4_3_12_RELEASE.xml
new file mode 100644
index 0000000..2a48cd9
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_springframework_spring_webmvc_4_3_12_RELEASE.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_yaml_snakeyaml_1_17.xml b/javadsl/.idea/libraries/Maven__org_yaml_snakeyaml_1_17.xml
new file mode 100644
index 0000000..20e2920
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_yaml_snakeyaml_1_17.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__org_zeroturnaround_zt_zip_1_11.xml b/javadsl/.idea/libraries/Maven__org_zeroturnaround_zt_zip_1_11.xml
new file mode 100644
index 0000000..22fcf62
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__org_zeroturnaround_zt_zip_1_11.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__xmlpull_xmlpull_1_1_3_1.xml b/javadsl/.idea/libraries/Maven__xmlpull_xmlpull_1_1_3_1.xml
new file mode 100644
index 0000000..0f2d9ef
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__xmlpull_xmlpull_1_1_3_1.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/libraries/Maven__xpp3_xpp3_min_1_1_4c.xml b/javadsl/.idea/libraries/Maven__xpp3_xpp3_min_1_1_4c.xml
new file mode 100644
index 0000000..6726a2d
--- /dev/null
+++ b/javadsl/.idea/libraries/Maven__xpp3_xpp3_min_1_1_4c.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/misc.xml b/javadsl/.idea/misc.xml
new file mode 100644
index 0000000..d30d09e
--- /dev/null
+++ b/javadsl/.idea/misc.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/modules.xml b/javadsl/.idea/modules.xml
new file mode 100644
index 0000000..af35c29
--- /dev/null
+++ b/javadsl/.idea/modules.xml
@@ -0,0 +1,8 @@
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/.idea/workspace.xml b/javadsl/.idea/workspace.xml
new file mode 100644
index 0000000..bb46bfc
--- /dev/null
+++ b/javadsl/.idea/workspace.xml
@@ -0,0 +1,551 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ true
+ DEFINITION_ORDER
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ AngularJS
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 1511449738195
+
+
+ 1511449738195
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 1.8
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/javadsl/src/main/java/com/example/scdfdsl/ScdfdslApplication.java b/javadsl/src/main/java/com/example/scdfdsl/ScdfdslApplication.java
index 1f4c028..47b375c 100644
--- a/javadsl/src/main/java/com/example/scdfdsl/ScdfdslApplication.java
+++ b/javadsl/src/main/java/com/example/scdfdsl/ScdfdslApplication.java
@@ -3,13 +3,13 @@ package com.example.scdfdsl;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
-import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.dataflow.rest.client.DataFlowOperations;
import org.springframework.cloud.dataflow.rest.client.DataFlowTemplate;
import org.springframework.cloud.dataflow.rest.client.dsl.Stream;
import org.springframework.cloud.dataflow.rest.client.dsl.StreamApplication;
+import org.springframework.cloud.dataflow.rest.client.dsl.StreamBuilder;
import org.springframework.context.annotation.Bean;
import java.net.URI;
@@ -61,7 +61,7 @@ public class ScdfdslApplication implements ApplicationRunner {
definitionStyle(dataFlowOperations);
} else if (style.equalsIgnoreCase("fluent")) {
// FLUENT STYLE
- fluentApplicationSytle(dataFlowOperations);
+ fluentStyle(dataFlowOperations);
} else {
System.out.println("Style [" + style + "] not supported");
}
@@ -88,8 +88,7 @@ public class ScdfdslApplication implements ApplicationRunner {
- private void fluentApplicationSytle(DataFlowOperations dataFlowOperations) throws InterruptedException {
- Map deploymentProperties = createDeploymentProperties();
+ private void fluentStyle(DataFlowOperations dataFlowOperations) throws InterruptedException {
System.out.println("Deploying stream.");
@@ -98,7 +97,7 @@ public class ScdfdslApplication implements ApplicationRunner {
.processor(processor)
.sink(sink)
.create()
- .deploy(deploymentProperties);
+ .deploy();
waitAndDestroy(woodchuck);
}
@@ -125,8 +124,8 @@ public class ScdfdslApplication implements ApplicationRunner {
return dataFlowOperations;
}
- private void waitAndDestroy(Stream woodchuck) throws InterruptedException {
- while(!woodchuck.getStatus().equals("deployed")){
+ private void waitAndDestroy(Stream stream) throws InterruptedException {
+ while(!stream.getStatus().equals("deployed")){
System.out.println("Wating for deployment of stream.");
Thread.sleep(5000);
}
@@ -136,7 +135,7 @@ public class ScdfdslApplication implements ApplicationRunner {
Thread.sleep(120000);
System.out.println("Destroying stream");
- woodchuck.destroy();
+ stream.destroy();
}
}
diff --git a/javadsl/src/test/java/com/example/scdfdsl/SimpleUsageTests.java b/javadsl/src/test/java/com/example/scdfdsl/SimpleUsageTests.java
index e963a4e..e42e281 100644
--- a/javadsl/src/test/java/com/example/scdfdsl/SimpleUsageTests.java
+++ b/javadsl/src/test/java/com/example/scdfdsl/SimpleUsageTests.java
@@ -20,6 +20,7 @@ import org.springframework.cloud.dataflow.rest.client.DataFlowOperations;
import org.springframework.cloud.dataflow.rest.client.DataFlowTemplate;
import org.springframework.cloud.dataflow.rest.client.dsl.Stream;
import org.springframework.cloud.dataflow.rest.client.dsl.StreamBuilder;
+import org.springframework.cloud.dataflow.rest.client.dsl.StreamDefinition;
import java.net.URI;
@@ -36,8 +37,8 @@ public class SimpleUsageTests {
public void doStuff() {
URI dataFlowUri = URI.create("http://localhost:9393");
DataFlowOperations dataFlowOperations = new DataFlowTemplate(dataFlowUri);
- StreamBuilder streamBuilder = Stream.builder(dataFlowOperations).name("ticktock").definition("time | log").create();
- Stream stream = streamBuilder.deploy();
+ StreamDefinition streamDefinition = Stream.builder(dataFlowOperations).name("ticktock").definition("time | log").create();
+ Stream stream = streamDefinition.deploy();
}