1 Reply Latest reply on Jan 17, 2013 7:48 AM by Keith Babo

    FileBinding custom message composer

    Hamid RAHMOUNI Newbie

      Hi,

      I try to define my own message composer for a FileBinding component. My switchyard configuration :

       

      <?xml version="1.0" encoding="UTF-8"?>

       

      <switchyard xmlns="urn:switchyard-config:switchyard:1.0" xmlns:bean="urn:switchyard-component-bean:config:1.0" xmlns:file="urn:switchyard-component-camel-file:config:1.0" xmlns:jms="urn:switchyard-component-camel-jms:config:1.0" xmlns:sca="http://docs.oasis-open.org/ns/opencsa/sca/200912" name="PATT_SWYARD_ESB" targetNamespace="urn:com.patt.switchyard:PATT_SWYARD_ESB:1.0">

       

        <sca:composite name="PATT_SWYARD_ESB" targetNamespace="urn:com.patt.switchyard:PATT_SWYARD_ESB:1.0">

          <sca:service name="FileBinding" promote="Component/FileBinding">

            <sca:interface.java interface="com.patt.switchyard.pattesb.FileBinding"/>

            <file:binding.file>

              <file:contextMapper class="com.patt.switchyard.pattesb.FileBindingContextMapper"/>

              <file:messageComposer class="com.patt.switchyard.pattesb.FileBindingMessageComposer"/>

              <file:directory>C:/datas_prod/queues/in</file:directory>

              <file:consume>

                <file:initialDelay>50</file:initialDelay>

                <file:delay>50</file:delay>

                <file:recursive>true</file:recursive>

                <file:move>C:/datas_prod/queues/working/${file:onlyname.noext}.esbWorking</file:move>

                <file:moveFailed>C:/datas_prod/queues/error</file:moveFailed>

                <file:include>(.)*(_in_)(.)*\.(xml\.ok)</file:include>

              </file:consume>

            </file:binding.file>

          </sca:service>

          <sca:component name="Component">

            <bean:implementation.bean class="com.patt.switchyard.pattesb.FileBindingBean"/>

            <sca:service name="FileBinding">

              <sca:interface.java interface="com.patt.switchyard.pattesb.FileBinding"/>

            </sca:service>

          </sca:component>

        </sca:composite>

      </switchyard>

       

      My Custom Class Message Composer is defined below :

       

      public class FileBindingMessageComposer implements MessageComposer<CamelBindingData> {

       

          @Override

          public ContextMapper<CamelBindingData> getContextMapper() {

              // some code source

              return ....;

          }

       

          @Override

          public MessageComposer<CamelBindingData> setContextMapper(

                  ContextMapper<CamelBindingData> contextMapper) {

              // some code source

              return ....;

          }

       

          @Override

          public Message compose(CamelBindingData source, Exchange exchange,

                  boolean create) throws Exception {

              // some code source

              return ....;

          }

       

          @Override

          public CamelBindingData decompose(Exchange exchange, CamelBindingData target)

                  throws Exception {

          // some code source

              return ....;

      }

       

      I defined also a context mapper class :

       

      public class FileBindingContextMapper implements ContextMapper<CamelBindingData> {

         

       

          @Override

          public void mapFrom(CamelBindingData source, Context context)

                  throws Exception {

               // some code source

          }

       

          @Override

          public void mapTo(Context context, CamelBindingData target)

                  throws Exception {

              // some code source

          }

         

      }

       

      When i put the file in the source directory to be pulled from. No message composer is invoked (both method compose and decompose).

       

      Is there anything missing on my configuration ?