[camel] branch master updated: ByteArrayBodyGenerator for String body (#4678)

[davsclaus]

This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/master by this push:
     new 7a3d072  ByteArrayBodyGenerator for String body (#4678)
7a3d072 is described below

commit 7a3d0727ded171f1342b32b8afa6dcea3179eadc
Author: sms0070 <suyash....@gmail.com>
AuthorDate: Wed Nov 25 10:36:49 2020 +0530

    ByteArrayBodyGenerator for String body (#4678)
    
    https://issues.apache.org/jira/browse/CAMEL-15891
---
 .../java/org/apache/camel/component/ahc/DefaultAhcBinding.java     | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git 
a/components/camel-ahc/src/main/java/org/apache/camel/component/ahc/DefaultAhcBinding.java
 
b/components/camel-ahc/src/main/java/org/apache/camel/component/ahc/DefaultAhcBinding.java
index eaef106..b52682c 100644
--- 
a/components/camel-ahc/src/main/java/org/apache/camel/component/ahc/DefaultAhcBinding.java
+++ 
b/components/camel-ahc/src/main/java/org/apache/camel/component/ahc/DefaultAhcBinding.java
@@ -49,6 +49,7 @@ import org.asynchttpclient.Request;
 import org.asynchttpclient.RequestBuilder;
 import org.asynchttpclient.request.body.generator.BodyGenerator;
 import org.asynchttpclient.request.body.generator.FileBodyGenerator;
+import org.asynchttpclient.request.body.generator.ByteArrayBodyGenerator;
 import org.asynchttpclient.request.body.generator.InputStreamBodyGenerator;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -173,7 +174,7 @@ public class DefaultAhcBinding implements AhcBinding {
                         ByteArrayOutputStream bos = new 
ByteArrayOutputStream(endpoint.getBufferSize());
                         AhcHelper.writeObjectToStream(bos, obj);
                         byte[] bytes = bos.toByteArray();
-                        body = new InputStreamBodyGenerator(new 
ByteArrayInputStream(bytes));
+                        body = new ByteArrayBodyGenerator(bytes);
                         IOHelper.close(bos);
                     } else if (data instanceof File || data instanceof 
GenericFile) {
                         // file based (could potentially also be a FTP file 
etc)
@@ -187,9 +188,9 @@ public class DefaultAhcBinding implements AhcBinding {
                         // do not fallback to use the default charset as it 
can influence the request
                         // (for example application/x-www-form-urlencoded 
forms being sent)
                         if (charset != null) {
-                            body = new InputStreamBodyGenerator(new 
ByteArrayInputStream(((String) data).getBytes(charset)));
+                            body = new ByteArrayBodyGenerator(((String) 
data).getBytes(charset));
                         } else {
-                            body = new InputStreamBodyGenerator(new 
ByteArrayInputStream(((String) data).getBytes()));
+                            body = new ByteArrayBodyGenerator(((String) 
data).getBytes());
                         }
                     }
                     // fallback as input stream