[camel] branch camel-2.25.x updated: ByteArrayBodyGenerator for String body

[acosentino]

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

acosentino pushed a commit to branch camel-2.25.x
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/camel-2.25.x by this push:
     new e4334bc  ByteArrayBodyGenerator for String body
e4334bc is described below

commit e4334bc65b3cd9d7b9448b558bb70f3d6a3f38dc
Author: sms0070 <suyash....@gmail.com>
AuthorDate: Wed Nov 25 10:57:26 2020 +0530

    ByteArrayBodyGenerator for String body
---
 .../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 ffea5f7..0681607 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
@@ -48,6 +48,7 @@ import org.asynchttpclient.HttpResponseStatus;
 import org.asynchttpclient.Request;
 import org.asynchttpclient.RequestBuilder;
 import org.asynchttpclient.request.body.generator.BodyGenerator;
+import org.asynchttpclient.request.body.generator.ByteArrayBodyGenerator;
 import org.asynchttpclient.request.body.generator.FileBodyGenerator;
 import org.asynchttpclient.request.body.generator.InputStreamBodyGenerator;
 import org.slf4j.Logger;
@@ -169,7 +170,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)
@@ -183,9 +184,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