Re: Splitter processing end

Hi andrew ...

Thanx for your response ...

Look the current configuration that i have ...

StateDAO: Is a bean than updates the "status" of mentioned flag, and gets the current state (1=Running, 0=Ready)

StateDAO.java:

public String getState(String flag) throws SQLException {
        try {
            logger.debug("Flag: " + flag);
            State response = (State) sqlMapClient.queryForObject("getState");
            logger.info("State: " + response.getState());
            return response.getState();
        } catch (SQLException e) {
            logger.error("Exception.", e);
            throw e;
        }
    }

    public Object updateState(State state) throws SQLException {
        try {
            sqlMapClient.update("updateState", state);
            logger.info("state updated. " + state.getState());
            return state;
        } catch (SQLException e) {
            logger.error("Exception.", e);
            throw e;
        }
    }

--------------------------------------------------------------------------------------------------------

spring-beans.xml:

<bean id="cronTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean">
        <property name="jobDetail" ref="quartzEventSender" />
        <property name="cronExpression" value="0 0/1 7-22 * * ?" />
</bean>

<bean id="StateDAO" class="com.flamingo.inventarios.dao.StateDAO">
        <property name="sqlMapClient" ref="sqlMapState" />
 </bean>

--------------------------------------------------------------------------------------------------------

mule-config.xml:

StateRunning: Transformer that returns an object of type State with state attribute = 1
StateReady: Transformer that returns an object of type State with state attribute = 0

<mule-descriptor name="TxProcessVerifier"
            implementation="StateDAO">
            <inbound-router>
                <endpoint address="vm://txState" />
            </inbound-router>
            <outbound-router>
                <router className="org.mule.routing.outbound.FilteringOutboundRouter">
                    <endpoint address="vm://start" />
                    <filter className="org.mule.routing.filters.RegExFilter"
                        pattern="0">     <!-- ************ 0 is the "ready state" ************* -->
                    </filter>
                </router>
            </outbound-router>
        </mule-descriptor>

        <mule-descriptor name="startProcess"
            implementation="org.mule.components.simple.PassThroughComponent">
            <inbound-router>
                <endpoint address="vm://start" transformers="Eamcscf1Key" />
            </inbound-router>
            <outbound-router>
                <router className="org.mule.routing.outbound.MulticastingRouter">
                    <endpoint address="vm://tlog" />
                    <!-- Changes the status to 1 (running) -->
                    <endpoint address="vm://txState" transformers="StateRunning" />
                </router>
            </outbound-router>
        </mule-descriptor>

       <mule-descriptor name="TlogSplitter"
            implementation="org.mule.components.simple.PassThroughComponent">
            <inbound-router>
                <endpoint address="vm://tlog" />
            </inbound-router>
            <outbound-router>
                <router
                    className="com.lineai.paf.routing.outbound.tlog.TLOGFileMessageSplitter">
                    <endpoint address="vm://tlogOutNullFilterVerifier"
                        synchronous="true" />
                </router>
            </outbound-router>
        </mule-descriptor>
       
        <mule-descriptor name="tlogOutNullFilterVerifier"
            implementation="org.mule.components.simple.PassThroughComponent">
            <inbound-router>
                <endpoint address="vm://tlogOutNullFilterVerifier" />
            </inbound-router>
            <outbound-router>
                <router className="org.mule.routing.outbound.FilteringOutboundRouter">
                    <endpoint address="vm://tlog.out" />
                    <filter expectedType="com.lineai.smartmodule.recordset.SmartRecordSet"
                        className="org.mule.routing.filters.PayloadTypeFilter" />
                </router>
                <router className="org.mule.routing.outbound.FilteringOutboundRouter">
                    <endpoint address="vm://txState" transformers="StateReady" />
                    <filter  className="com.lineai.paf.routing.filters.NullPayloadFilter" />
                </router>
            </outbound-router>
        </mule-descriptor>


Ideas?

Thanks