package com.example.switchyard.switchyard_transformation;

import org.junit.Assert;

import org.junit.Test;
import org.junit.runner.RunWith;
import org.switchyard.component.test.mixins.cdi.CDIMixIn;
import org.switchyard.test.Invoker;
import org.switchyard.test.ServiceOperation;
import org.switchyard.test.SwitchYardRunner;
import org.switchyard.test.SwitchYardTestCaseConfig;
import org.switchyard.test.SwitchYardTestKit;
import org.switchyard.transform.config.model.TransformSwitchYardScanner;

@SwitchYardTestCaseConfig(
        config = SwitchYardTestCaseConfig.SWITCHYARD_XML)
@RunWith(SwitchYardRunner.class)
public class CamelBindyToXstream {

    @ServiceOperation("CamelService")
    private Invoker camelService;

    private SwitchYardTestKit _testKit;

    @Test
    public void processCSVRecordsToXStream() throws Exception {
        String requestTxt = _testKit.readResourceString("input.txt");
        camelService.sendInOnly(requestTxt);
    }
}

<?xml version="1.0" encoding="UTF-8"?>
<switchyard xmlns="urn:switchyard-config:switchyard:1.0"
               xmlns:camel="urn:switchyard-component-camel:config:1.0"
               xmlns:file="urn:switchyard-component-camel-file:config:1.0"
               xmlns:sca="http://docs.oasis-open.org/ns/opencsa/sca/200912" name="switchyard-transformation" targetNamespace="urn:com.example.switchyard:switchyard-transformation:1.0">
  <sca:composite name="switchyard-transformation" targetNamespace="urn:com.example.switchyard:switchyard-transformation:1.0">
    <sca:service name="CamelService" promote="CamelServiceBuilder/CamelService">
      <sca:interface.java interface="com.example.switchyard.switchyard_transformation.CamelService"/>
          <file:binding.file name="file1">
<!--        <file:directory>/Users/sjayanti/Downloads/</file:directory>-->
          <file:directory>/Users/chmoulli/Temp/fsw/</file:directory>
        <file:charset>UTF-8</file:charset>
        <file:consume>
          <file:moveFailed>.failed</file:moveFailed>
          <file:include>input*.txt</file:include>
        </file:consume>
      </file:binding.file>
    </sca:service>
    <sca:component name="CamelServiceBuilder">
      <camel:implementation.camel>
        <camel:java class="com.example.switchyard.switchyard_transformation.CamelServiceBuilder"/>
      </camel:implementation.camel>
      <sca:service name="CamelService">
        <sca:interface.java interface="com.example.switchyard.switchyard_transformation.CamelService"/>
      </sca:service>
    </sca:component>
  </sca:composite>
</switchyard>