from("file://inbox")
  .unmarshal(bindy)
  .to("direct:handleOrders");
from("file://inbox")
  .unmarshal(bindy)
  .to("direct:handleOrders");
Copy to Clipboard
Copied!
Toggle word wrap
Toggle overflow
 
 
from("file://inbox")
  .unmarshal("myBindyDataFormat")
  .to("direct:handleOrders");
from("file://inbox")
  .unmarshal("myBindyDataFormat")
  .to("direct:handleOrders");
Copy to Clipboard
Copied!
Toggle word wrap
Toggle overflow
 
 
List<Map<String, Object>> unmarshaledModels = (List<Map<String, Object>>) exchange.getIn().getBody();
int modelCount = 0;
for (Map<String, Object> model : unmarshaledModels) {
  for (String className : model.keySet()) {
     Object obj = model.get(className);
     LOG.info("Count : " + modelCount + ", " + obj.toString());
  }
 modelCount++;
}
LOG.info("Total CSV records received by the csv bean : " + modelCount);
List<Map<String, Object>> unmarshaledModels = (List<Map<String, Object>>) exchange.getIn().getBody();
int modelCount = 0;
for (Map<String, Object> model : unmarshaledModels) {
  for (String className : model.keySet()) {
     Object obj = model.get(className);
     LOG.info("Count : " + modelCount + ", " + obj.toString());
  }
 modelCount++;
}
LOG.info("Total CSV records received by the csv bean : " + modelCount);
Copy to Clipboard
Copied!
Toggle word wrap
Toggle overflow
 
 
from("file://inbox")
    .unmarshal(bindy)
    .split(body())
        .process(new Processor() {
            public void process(Exchange exchange) throws Exception {
                Message in = exchange.getIn();
                Map<String, Object> modelMap = (Map<String, Object>) in.getBody();
                in.setBody(modelMap.get(Order.class.getCanonicalName()));
            }
        })
        .to("direct:handleSingleOrder")
    .end();
from("file://inbox")
    .unmarshal(bindy)
    .split(body())
        .process(new Processor() {
            public void process(Exchange exchange) throws Exception {
                Message in = exchange.getIn();
                Map<String, Object> modelMap = (Map<String, Object>) in.getBody();
                in.setBody(modelMap.get(Order.class.getCanonicalName()));
            }
        })
        .to("direct:handleSingleOrder")
    .end();
Copy to Clipboard
Copied!
Toggle word wrap
Toggle overflow
 
 
					请注意,Bindy 使用 CHARSET_NAME 属性或 CHARSET_NAME 标头,如 Exchange 界面中所定义,为 unmarshalling 接收输入流的字符转换。在一些制作者(如 file-endpoint)中,您可以定义一个 characterset。字符集转换过程可能已经由此制作者完成。有时,您需要从交换中删除此属性或标头,然后再将其发送到 unmarshal。如果您没有删除它,则转换可能会进行两次,这可能会导致不必要的结果。
				
from("file://inbox?charset=Cp922")
  .removeProperty(Exchange.CHARSET_NAME)
  .unmarshal("myBindyDataFormat")
  .to("direct:handleOrders");
from("file://inbox?charset=Cp922")
  .removeProperty(Exchange.CHARSET_NAME)
  .unmarshal("myBindyDataFormat")
  .to("direct:handleOrders");
Copy to Clipboard
Copied!
Toggle word wrap
Toggle overflow