public class MyLogAction {

                @Process
 		    public void log(Message message) {
		        // log the message...
		    }
		}

<service .....>
		    <actions>
		        <action name="logger" class="com.acme.actions.MyLogAction" />
		    </actions>
		</service>

<service .....>
		    <actions>
		        <action name="logger" class="com.acme.actions.MyLogAction" 
                                           process="log" />
		    </actions>
		</service>

public class OrderPersister {

		    @Process
		    public OrderAck storeOrder(OrderHeader orderHeader,
								OrderItems orderItems) {
		        // process the order parameters and return an ack...
		    }
		}

public class OrderDecoder {

		    @Process
		    public Order decodeOrder(String orderXML) {
		        // decode the order XML to an ORder instance... 
		    }
		}

		public class OrderPersister {

		    @Process
		    public OrderAck storeOrder(Order order) {
		        // persist the order and return an ack...
		    }
		}

<actions>
    <action name="decode" class="com.acme.orders.OrderDecoder" />
    <action name="persist" class="com.acme.orders.OrderPersister" />
</actions>

public class OrderPersister {

  		    @Process
		    public OrderAck storeOrder(
		                   @BodyParam("order-header") OrderHeader orderHeader,
		                   @BodyParam("order-items") OrderItems orderItems) {
			
		        // process the order parameters and return an ack...
		    }
		}

<action name="logger" class="com.acme.actions.MyLogAction">
    <property name="logFile" value="logs/my-log.log" />
    <property name="logLevel" value="DEBUG" />
</action>

public class MyLogAction {

		    @ConfigProperty
		    private File logFile;

		    @ConfigProperty
		    private LogLevel logLevel;
 
		    public static enum LogLevel {
		        DEBUG, 
		        INFO, 
		        WARN
		    }

		    @Process
		    public void log(Message message) {
		        // log the message at the configured log level...
		    }
		}

public class MyLogAction {
		
		    @ConfigProperty(defaultVal = "logs/my-log.log")
		    private File logFile;

		    @ConfigProperty(use = Use.OPTIONAL)
		    private LogLevel logLevel;

		    public static enum LogLevel {
		        DEBUG, 
		        INFO, 
		        WARN
		    }

		    @Process
		    public void log(Message message) {
		        // log the message...
		    }
		}

<action ...>
		    <property name="log-file" value="logs/my-log.log" />
		    <property name="log-level" value="DEBUG" />
		</action>

public class MyLogAction {
		
		    @ConfigProperty(name = "log-file")
		    private File logFile;

		    @ConfigProperty(name = "log-level")
		    private LogLevel logLevel;

		    public static enum LogLevel {
		        DEBUG, 
		        INFO, 
		        WARN
		    }

		    @Process
		    public void log(Message message) {
		        // log the message...
		    }
		}

public class MyLogAction {

		    @ConfigProperty
		    private File logFile;

		    @ConfigProperty
		    private LogLevel logLevel;

		    public static enum LogLevel {
		        DEBUG, 
		        INFO, 
		        WARN
		    }

		    @Initialize
		    public void initializeLogger() {
			// Check if file already exists… check if parent folder 
			// exists etc...
			// Open the file for writing...
		    }
 
		    @Destroy
		    public void cleanupLogger() {
		        // Close the file...
		    }

		    @Process
		    public void log(Message message) {
		        // log the message...
		    }
		}

public class OrderPersister {

		    @Process
		    public OrderAck storeOrder(Order order) {
		        // persist the order and return an ack...
		    }

		    @OnSuccess
		    public void logOrderPersisted(Message message) {
		        // log it...
		    }

		    @OnException
		    public void manualRollback(Message message, 
                                           Throwable theError) {
		        // manually rollback...
		    }
		}

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>

<listeners>
    <http-gateway name="Http" urlPattern="esb-cars/*">
        <asyncResponse />
    </http-gateway>
</listeners>

<listeners>
    <http-gateway name="Http" urlPattern="esb-cars/*">
        <asyncResponse statusCode="202" />
    </http-gateway>
</listeners>

<listeners>
    <http-gateway name="Http" urlPattern="esb-cars/*">
        <asyncResponse statusCode="202">
            <payload classpathResource="/202-static-response.xml"
                     content-type="text/xml"
                     characterEncoding="UTF-8" />
        <asyncResponse>
    </http-gateway>
</listeners>

HttpResponse responseInfo = new HttpResponse(HttpServletResponse.SC_OK);
 
responseInfo.setContentType("text/xml");
// Set other response info ...
 
// Set the HttpResponse instance on the ESB response Message instance
responseInfo.setResponse(responseMessage);

<listeners>
    <http-gateway name="Http" urlPattern="esb-cars/*">
        <property name="synchronousTimeout" value="120000"/>
    </http-gateway>
</listeners>

<http-gateway name="http-gateway">
    <exception>
        <mapping class="com.acme.AcmeException" status="503" />
    </exception>
</http-gateway>

<http-provider name="http">

    <!-- Global exception mappings file... -->
    <exception mappingsFile="/http-exception-mappings.properties" />
</http-provider>

<action name="JBossWSAdapter" class="org.jboss.soa.esb.actions.soap.SOAPProcessor">
    <property name="jbossws-endpoint" value="ABI_OrderManager" />
    <property name="jbossws-context" value="ABIV1OrderManager_war" />
    <property name="rewrite-endpoint-url" value="true" />
</action>

<action name="soapui-client-action" class="org.jboss.soa.esb.actions.soap.SOAPClient">
    <property name="wsdl" value="http://localhost:18080/acme/services/RetailerCallback?wsdl"/>
    <property name="operation" value="SendSalesOrderNotification"/>
</action>

<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" 
    xmlns:cus="http://schemas.acme.com">
    <soapenv:Header/>
    <soapenv:Body>
    
        <cus:customerOrder>
            <cus:header>
                <cus:customerNumber>123456</cus:customerNumber>
            </cus:header>
        </cus:customerOrder>
        
    </soapenv:Body>
</soapenv:Envelope>

<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"
    xmlns:cus="http://schemas.active-endpoints.com/sample/customerorder/2006/04/CustomerOrder.xsd"
    xmlns:stan="http://schemas.active-endpoints.com/sample/standardtypes/2006/04/StandardTypes.xsd">

    <soapenv:Header/>
    <soapenv:Body>
        <cus:customerOrder>
            <cus:items>
                <cus:item>
                    <cus:partNumber>FLT16100</cus:partNumber>
                    <cus:description>Flat 16 feet 100 count</cus:description>
                    <cus:quantity>50</cus:quantity>
                    <cus:price>490.00</cus:price>
                    <cus:extensionAmount>24500.00</cus:extensionAmount>
                </cus:item>
                <cus:item>
                    <cus:partNumber>RND08065</cus:partNumber>
                    <cus:description>Round 8 feet 65 count</cus:description>
                    <cus:quantity>9</cus:quantity>
                    <cus:price>178.00</cus:price>
                    <cus:extensionAmount>7852.00</cus:extensionAmount>
                </cus:item>
            </cus:items>
        </cus:customerOrder>
    </soapenv:Body>
    
</soapenv:Envelope>

<action name="soapui-client-action"  class="org.jboss.soa.esb.actions.soap.SOAPClient">
    <property name="wsdl"  value="http://localhost:18080/acme/services/RetailerService?wsdl"/>
    <property name="operation" value="GetOrder"/>
    <property name="get-payload-location" value="get-order-params" />
    <property name="set-payload-location" value="get-order-response" />
    <property name="responseXStreamConfig">
        <alias name="customerOrder" class="com.acme.order.Order"         
            namespace="http://schemas.acme.com/services/CustomerOrder.xsd" />
        <alias name="orderheader" class="com.acme.order.Header" 
            namespace="http://schemas.acme.com/services/CustomerOrder.xsd" />
        <alias name="item" class="com.acme.order.OrderItem" 
            namespace="http://schemas.acme.com/services/CustomerOrder.xsd" />
    </property>
</action>

<property name="responseXStreamConfig">
    <fieldAlias name="header" class="com.acme.order.Order" fieldName="headerFieldName" />
    <annotation class="com.acme.order.Order" />
</property>

<action name="soapui-client-action" class="org.jboss.soa.esb.actions.soap.SOAPClient">
    <property name="wsdl" value="http://localhost:18080/acme/services/RetailerService?wsdl"/>
    <property name="operation" value="GetOrder"/>
    <property name="get-payload-location" value="get-order-params" />
    <property name="set-payload-location" value="get-order-response" />
    <property name="responseAsOgnlMap" value="true" />
</action>

<property name="wsdl" value="https://localhost:18443/active-bpel/services/RetailerCallback?wsdl">
    <http-client-property name="file" value="/localhost-https-18443.properties" >
    
    </http-client-property>
</property>

<property name="http-client-properties"> 
    <http-client-property name="http.proxyHost" value="localhost"/>
    <http-client-property name="http.proxyPort" value="8080"/> 
</property>