public class MyCustomGateway extends AbstractThreadedManagedLifecycle {
 
    private ConfigTree listenerConfig;
    private Service service;
    private ServiceInvoker serviceInvoker;
 
    public MyCustomGateway(final ConfigTree config) throws ConfigurationException {
        super(config);
        this.listenerConfig = config;
 
        String serviceCategory = listenerConfig.getRequiredAttribute(ListenerTagNames.TARGET_SERVICE_CATEGORY_TAG);
        String serviceName = listenerConfig.getRequiredAttribute(ListenerTagNames.TARGET_SERVICE_NAME_TAG);
 
        service = new Service(serviceCategory, serviceName);
    }
 
    protected void doInitialise() throws ManagedLifecycleException {
        // Create the ServiceInvoker instance for the target service....
        try {
            serviceInvoker = new ServiceInvoker(service);
        } catch (MessageDeliverException e) {
            throw new ManagedLifecycleException("Failed to create ServiceInvoker for Service '" + service + "'.");
        }
    }
 
    protected void doRun() {
        while(isRunning()) {
            // Wait for a message....
            Object payloadObject = waitForPayload();
 
            // Send the message to the target service's Action Pipeline via
            // the ServiceInvoker...
            try {
                Message esbMessage = MessageFactory.getInstance().getMessage();
 
                esbMessage.getBody().add(payloadObject);
                serviceInvoker.deliverAsync(esbMessage);
            } catch (MessageDeliverException e) {
                e.printStackTrace();
            }
        }
    }
 
    private Object waitForPayload() {
        // Wait for a message...
    }
}

<?xml version = "1.0" encoding = "UTF-8"?>
<jbossesb xmlns="http://anonsvn.labs.jboss.com/labs/jbossesb/trunk/product/etc/schemas/xml/jbossesb-1.0.1.xsd"
          parameterReloadSecs="5">

    <providers>
        <bus-provider name="CustomProvider">
            <property name="provider-property" value="buprovider-prop-value" />

            <bus busid="custom-bus">
                <property name="bus-property" value="bus-prop-value" />
            </bus>
        </bus-provider>
    </providers>

    <services>
        <service category="Custom" name="Listener" description="" invmScope="GLOBAL">
            <listeners>
                <listener name="custom-listener" busidref="custom-bus" is-gateway="true">
                    <property name="gatewayClass" value="com.acme.listeners.MyCustomGateway" />
                    <property name="listener-property" value="listener-prop-value" />
                </listener>
            </listeners>
            <actions mep="OneWay">
                ...
            </actions>
        </service>
    </services>

</jbossesb>

Public class OrderFileListener implements ScheduledEventMessageComposer {
 
    public void initialize(ConfigTree config) throws ConfigurationException {
        // TODO: Initialise File filters etc, using the config to access properties configured on the listener...
    }
 
    public Message composeMessage() throws SchedulingException {
        Message message = MessageFactory.getInstance().getMessage();
 
        // TODO: Read one or more order files and populate the data into the ESB message for pipeline processing...
 
        return message;
    }
 
    public Message onProcessingComplete(Message message) throws SchedulingException {
        // TODO: Post pipeline processing...
        return message;
    }
 
    public void uninitialize() {
        // TODO: Any relevant cleanup tasks...
    }
}

<?xml version = "1.0" encoding = "UTF-8"?>
<jbossesb xmlns="http://anonsvn.labs.jboss.com/labs/jbossesb/trunk/product/etc/schemas/xml/jbossesb-1.0.1.xsd">

    <providers>
        <schedule-provider name="schedules">
            <simple-schedule scheduleid="ordersPole" frequency="5" frequencyUnits="seconds" />
        </schedule-provider>
    </providers>

    <services>
        <service category="OrderManagement" name="OrderProcessing" description="Order Processing Service">

            <listeners>
                <scheduled-listener name="orderFileListener" scheduleidref="ordersPole" event-processor="com.acme.OrderFileListener"/>
            </listeners>

            <actions>
                <action name="action1" class="..."/>
                <action name="action2" class="..."/>
                <action name="action3" class="..."/>
            </actions>
        </service>
    </services>

</jbossesb>

public class OrderListener implements MessageListener {
    
    public void onMessage(final Message message) {
        if(message instanceof ObjectMessage) {
            Order order = ((ObjectMessage) message).getObject();
 
            // Create and populate an ESB message with the order....
            Message esbMessage = MessageFactory.getInstance().getMessage();
            esbMessage.getBody().add(order);
 
            // TODO: Add code to forward the ESB message to the Action Pipeline...
        }
    }
}

public class OrderListener implements MessageListener {
 
    private ActionProcessingPipeline pipeline;
 
    public void start(ConfigTree config) throws ConfigurationException {
        // Create and initialize the pipeline..
        pipeline = new ActionProcessingPipeline(config);
        pipeline.initialise();
 
        // TODO: Add JMS code for connecting this JMS MessageListener to the JMS Queue... 
    }
 
    public void onMessage(final Message message) {
        if(message instanceof ObjectMessage) {
            Order order = ((ObjectMessage) message).getObject();
 
            // Create and populate an ESB message with the order....
            Message esbMessage = MessageFactory.getInstance().getMessage();
            esbMessage.getBody().add(order);
           
            // Forward the ESB message to the Action Pipeline...
            boolean success = pipeline.process(message);            
            if(!success) {
                // TODO: Handle error....
            }
        }
    }
 
    public void stop() {
        try {
            // TODO: Add JMS code for disconnecting from JMS Queue....
        } finally {
            if(pipeline != null) {
                pipeline.destroy() ;
            }            
        }
    }
}

import com.acme.OrderListener;
 
OrderListener orderListener = new OrderListener();
 
// Start the listener (passing the config)...
orderListener.start(config);
 
// Wait until the Groovy Gateway is signaled to stop...
def stopped = false;
while(!stopped) {
    stopped = gateway.waitUntilStopping(200);
}
 
// Now stop the listener...
orderListener.stop();

<?xml version = "1.0" encoding = "UTF-8"?>
<jbossesb xmlns="http://anonsvn.labs.jboss.com/labs/jbossesb/trunk/product/etc/schemas/xml/jbossesb-1.0.1.xsd">

    <services>
        <service category="OrderManagement" name="OrderProcessing" description="Order Processing Service">

            <listeners>
                <groovy-listener name="orderJmsListener" script="/com/acme/OrderListener.groovy">
                    <property name="queueName" value="..."/>
                </groovy-listener>
            </listeners>

            <actions>
                <action name="action1" class="..."/>
                <action name="action2" class="..."/>
                <action name="action3" class="..."/>
            </actions>
        </service>
    </services>

</jbossesb>