Update NB S4R, add README doc and testing scripts

adapter-s4r/src/main/java/io/nosqlbench/adapter/s4r/util/S4RAdapterUtil.java

@@ -16,13 +16,10 @@
 
 package io.nosqlbench.adapter.s4r.util;
 
-import com.fasterxml.jackson.core.type.TypeReference;
-import com.fasterxml.jackson.databind.ObjectMapper;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 
-import java.util.Map;
 import java.util.Set;
 import java.util.stream.Collectors;
 import java.util.stream.Stream;

adapter-s4r/src/main/resources/s4r_msg_sender.yaml

@@ -1,6 +1,5 @@
 bindings:
   mytext_val: AlphaNumericString(100)
-  myexname: CSVFrequencySampler('csv/exchange_names.csv', 'name')
   myroutingkey: CSVFrequencySampler('csv/routing_keys.csv', 'name')
 
 
@@ -8,18 +7,18 @@ bindings:
 params:
   # whether to do publisher confirm (for reliable publishing)
   # - default: false
-  publisher_confirm: "false"
-  #publisher_confirm: "true"
+  publisher_confirm: true
+  #publisher_confirm: true
   # If 'publisher_confirm' is true, use one of the following 3 confirm modes:
   # - individual (wait_for_confirm individually)
   # - batch (wait_for_confirm in batch)
   # - async [default]
-  confirm_mode: "aysnc"
-  #confirm_mode: "individual"
-  #confirm_mode: "batch"
+  #confirm_mode: async
+  #confirm_mode: individual
+  confirm_mode: batch
 
   # Only relevant when 'publisher_confirm' is true and 'confirm_mode' is "batch"
-  confirm_batch_num: 100
+  confirm_batch_num: 10
   # default timeout value (in milliseconds)
   # - only relevant when publisher_confirm' is true and 'confirm_mode' is NOT "async"
   dft_confirm_timeout_ms: 1000
@@ -28,12 +27,7 @@ params:
 blocks:
   msg-send-block:
     ops:
-      AmqpMsgSender:
-        #exchange_names: "{myexname}"
-        exchange_names: "alpha"
-
+      op1:
+        AmqpMsgSender: ""
         routing_key: "{myroutingkey}"
-
-        ## (Optional) Kafka message value.
-        #  - message key and value can't be both empty at the same time
         message: "{mytext_val}"

adapter-s4r/src/main/resources/sanity-validation/e2e-sanity-receiver.yaml

@@ -0,0 +1,6 @@
+blocks:
+  msg-recv-block:
+    ops:
+      op1:
+        AmqpMsgReceiver: ""
+        binding_key: "binding-test"