fix(issue#809) spliting query param by &

core/citrus-base/src/main/java/org/citrusframework/endpoint/resolver/DynamicEndpointUriResolver.java

@@ -101,7 +101,7 @@ private String appendQueryParams(String uri, Map<String, Object> headers) {
         StringBuilder queryParamBuilder = new StringBuilder();
         String queryParams = headers.get(QUERY_PARAM_HEADER_NAME).toString();
 
-        StringTokenizer tok = new StringTokenizer(queryParams, ",");
+        StringTokenizer tok = new StringTokenizer(queryParams, "&");
         if (tok.hasMoreTokens()) {
             while (requestUri.endsWith("/")) {
                 requestUri = requestUri.substring(0, requestUri.length() - 1);

endpoints/citrus-http/src/main/java/org/citrusframework/http/controller/HttpMessageController.java

@@ -161,7 +161,7 @@ private ResponseEntity<?> handleRequestInternal(HttpMethod method, HttpEntity<?>
                 .uri(pathHelper.getRequestUri(servletRequest))
                 .contextPath(pathHelper.getContextPath(servletRequest))
                 .queryParams(Optional.ofNullable(pathHelper.getOriginatingQueryString(servletRequest))
-                                    .map(queryString -> queryString.replaceAll("&", ","))
+                                    .map(queryString -> queryString.replaceAll(",", "&"))
                                     .orElse(""))
                 .version(servletRequest.getProtocol())
                 .method(method);

endpoints/citrus-http/src/main/java/org/citrusframework/http/message/HttpMessage.java

@@ -224,7 +224,7 @@ public HttpMessage queryParams(final String queryParamString) {
         header(HttpMessageHeaders.HTTP_QUERY_PARAMS, queryParamString);
         header(EndpointUriResolver.QUERY_PARAM_HEADER_NAME, queryParamString);
 
-        Stream.of(queryParamString.split(","))
+        Stream.of(queryParamString.split("&"))
                 .map(keyValue -> keyValue.split("="))
                 .filter(keyValue -> StringUtils.hasText(keyValue[0]))
                 .map(keyValue -> {
@@ -265,7 +265,7 @@ public HttpMessage queryParam(final String name, final String value) {
         final String queryParamString = queryParams.entrySet()
                 .stream()
                 .map(this::outputQueryParam)
-                .collect(Collectors.joining(","));
+                .collect(Collectors.joining("&"));
 
         header(HttpMessageHeaders.HTTP_QUERY_PARAMS, queryParamString);
         header(EndpointUriResolver.QUERY_PARAM_HEADER_NAME, queryParamString);
@@ -583,7 +583,7 @@ private void addQueryParam(final String name, final String value) {
     private String outputQueryParam(final Map.Entry<String, Collection<String>> entry) {
         return entry.getValue().stream()
                 .map(entryValue -> entry.getKey() + (entryValue != null ? "=" + entryValue : ""))
-                .collect(Collectors.joining(","));
+                .collect(Collectors.joining("&"));
     }
 
     private static HttpMessage parseHttpMessage(final BufferedReader reader, final HttpMessage message) throws IOException {

endpoints/citrus-http/src/main/java/org/citrusframework/http/message/HttpQueryParamHeaderValidator.java

@@ -73,7 +73,7 @@ private Map<String, Object> convertToMap(Object expression) {
         return Stream.of(Optional.ofNullable(expression)
                 .map(Object::toString)
                 .orElse("")
-                .split(","))
+                .split("&"))
             .map(keyValue -> keyValue.split("="))
             .filter(keyValue -> hasText(keyValue[0]))
             .collect(toMap(

tools/test-generator/src/main/java/org/citrusframework/generate/provider/http/HttpCodeProvider.java

@@ -74,7 +74,7 @@ private void provideQueryParameter(final CodeBlock.Builder code, final HttpMessa
                     );
         } else if (StringUtils.hasText(message.getQueryParamString())) {
             Stream.of(message.getQueryParamString()
-                    .split(","))
+                    .split("&"))
                     .map(nameValuePair -> nameValuePair.split("="))
                     .forEach(param ->
                             code.add(".queryParam($S, $S)\n", param[0], param[1])

tools/test-generator/src/main/java/org/citrusframework/generate/provider/http/ReceiveHttpRequestActionProvider.java

@@ -73,7 +73,7 @@ public ReceiveRequestModel getAction(String endpoint, HttpMessage message) {
                     );
         } else if (StringUtils.hasText(message.getQueryParamString())) {
             Stream.of(message.getQueryParamString()
-                    .split(","))
+                    .split("&"))
                     .map(nameValuePair -> nameValuePair.split("="))
                     .forEach(param -> {
                         ParamType paramType = new ParamType();

tools/test-generator/src/main/java/org/citrusframework/generate/provider/http/SendHttpRequestActionProvider.java

@@ -74,7 +74,7 @@ public SendRequestModel getAction(String endpoint, HttpMessage message) {
                     );
         } else if (StringUtils.hasText(message.getQueryParamString())) {
             Stream.of(message.getQueryParamString()
-                    .split(","))
+                    .split("&"))
                     .map(nameValuePair -> nameValuePair.split("="))
                     .forEach(param -> {
                         ParamType paramType = new ParamType();