[jira] [Created] (CAMEL-6810) Bean Component/BeanBinding: Body as InputStream parametr (specified as ${body} in route)

["Radek Kraus (JIRA)" <ji...@apache.org>]

Radek Kraus created CAMEL-6810:
----------------------------------

             Summary: Bean Component/BeanBinding: Body as InputStream parametr (specified as ${body} in route)
                 Key: CAMEL-6810
                 URL: https://issues.apache.org/jira/browse/CAMEL-6810
             Project: Camel
          Issue Type: Bug
          Components: camel-core
    Affects Versions: 2.12.1, 2.11.2
            Reporter: Radek Kraus
            Priority: Minor


I discovered following problem (which was already shortly discussed in [Camel user forum|http://camel.465427.n5.nabble.com/Bean-component-Bean-Binding-Body-as-InputStream-parametr-specified-as-body-in-route-td5740656.ht]).

I have a "streamBodyBindingBean" bean with this method:
{code}
public void bodyBinding(InputStream in) throws IOException {
  int byteCount = 0;
  int c;
  while((c = in.read()) != -1)
    byteCount++;
  System.out.println("ByteCount: " + byteCount);
}
{code}

And this route:
{code}
<route id="" trace="true">
  <from uri="direct://body-input-stream-binding-in"/>
  <to uri="bean://streamBodyBindingBean?method=bodyBinding(${body})"/>
  <!-- to uri="bean://isBodyBindingBean"/--> 
  <to uri="mock://body-input-stream-binding-out"/>
</route>
{code}

And here is a way how I send exchange from test stuff:
{code}
ByteArrayInputStream in = new ByteArrayInputStream(
  "Small body, which I want to bind as InputStream".getBytes("UTF-8")
);
Exchange exchange = createExchangeWithBody(in);
exchange.setPattern(ExchangePattern.InOnly);
template.send("direct://body-input-stream-binding-in", exchange); 
{code}

In this case I got a sysout message: {{ByteCount: 0}}, but when I used the commented variant in the route, I got expected result: {{ByteCount: 47"}}.

When I change the route and use bean component 2 times (both variant of bean method invocation), then I got:

{noformat}
2013-10-01 12:26:37.259 DEBUG {main} [SendProcessor] >>>> Endpoint[bean://isBodyBindingBean?method=bodyBinding%28%24%7Bbody%7D%29] Exchange[Message: [Body is instance of org.apache.camel.StreamCache]]
ByteCount: 0
2013-10-01 12:26:37.289 DEBUG {main} [SendProcessor] >>>> Endpoint[bean://isBodyBindingBean] Exchange[Message: [Body is instance of org.apache.camel.StreamCache]]
ByteCount: 47
2013-10-01 12:26:37.307 DEBUG {main} [SendProcessor] >>>> Endpoint[mock://body-input-stream-binding-out] Exchange[Message: [Body is instance of org.apache.camel.StreamCache]] 
{noformat}

The strange for me is {{MethodInfo}} class, line 526:
{code}
// the parameter value was not already valid, but since the simple language have evaluated the expression
// which may change the parameterValue, so we have to check it again to see if its now valid
exp = exchange.getContext().getTypeConverter().convertTo(String.class, parameterValue);
// String values from the simple language is always valid
if (!valid) {
  ...
}
{code}

The line after comment caused that my "InputStream" is transformed into String, what can be a problem in case of "big" InputStream.

I know that I can use only second variant of "bean method invocation", which is enough for my need, but I only want to point out to this situation.



--
This message was sent by Atlassian JIRA
(v6.1#6144)