Repository: camel Updated Branches: refs/heads/master 04f25a609 -> 9bb92338a
Add type converter for StreamCache to ByteBuffer which camel-undertow may use Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/9bb92338 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/9bb92338 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/9bb92338 Branch: refs/heads/master Commit: 9bb92338a6619dc67356f44fc0069edded3dd06d Parents: 04f25a6 Author: Claus Ibsen <davscl...@apache.org> Authored: Thu Apr 6 18:38:39 2017 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Thu Apr 6 18:38:39 2017 +0200 ---------------------------------------------------------------------- .../apache/camel/converter/stream/StreamCacheConverter.java | 7 +++++++ 1 file changed, 7 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/9bb92338/camel-core/src/main/java/org/apache/camel/converter/stream/StreamCacheConverter.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/converter/stream/StreamCacheConverter.java b/camel-core/src/main/java/org/apache/camel/converter/stream/StreamCacheConverter.java index 0695cde..7d5267a 100644 --- a/camel-core/src/main/java/org/apache/camel/converter/stream/StreamCacheConverter.java +++ b/camel-core/src/main/java/org/apache/camel/converter/stream/StreamCacheConverter.java @@ -22,6 +22,7 @@ import java.io.IOException; import java.io.InputStream; import java.io.Reader; import java.io.Serializable; +import java.nio.ByteBuffer; import javax.xml.transform.TransformerException; import javax.xml.transform.sax.SAXSource; import javax.xml.transform.stream.StreamSource; @@ -108,4 +109,10 @@ public final class StreamCacheConverter { return os.toByteArray(); } + @Converter + public static ByteBuffer convertToByteBuffer(StreamCache cache, Exchange exchange) throws IOException { + byte[] array = convertToByteArray(cache, exchange); + return ByteBuffer.wrap(array); + } + }
