Hi,

    I am trying to use Jboss ESB as an interceptor for IP socket comunication.

Usecase:

   Simple message, which used to get communicated through IP socket client & server program. But now i need to do the same communication through Jboss ESB queues.

Configured the Jboss-esb.xml as below.

1)Using the Jbr-provider

2)Client code placed below(i am able to get the connection properly)

3)Listener code is placed below.

Queues are created properly,But listener java class is not getting invoked.(so that i get the message which has been transfered from client).

console of jboss esb server 4.9 below

15:29:38,519 INFO  [JBoss4ESBDeployer] create esb service, Socket.esb
15:29:38,769 INFO  [QueueService] Queue[/queue/socket_in_q] started, fullSize=200000, pageSize=2000, downCacheSize=2000
15:32:22,518 INFO  [JBossRemotingGatewayListener] JBoss Remoting Gateway listener 'listener' started.

<?xml version="1.0"?>
<jbossesb parameterReloadSecs="5"
    xmlns="http://anonsvn.labs.jboss.com/labs/jbossesb/trunk/product/etc/schemas/xml/jbossesb-1.2.0.xsd"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://anonsvn.labs.jboss.com/labs/jbossesb/trunk/product/etc/schemas/xml/jbossesb-1.2.0.xsd http://anonsvn.jboss.org/repos/labs/labs/jbossesb/trunk/product/etc/schemas/xml/jbossesb-1.2.0.xsd">
    <providers>
        <jbr-provider host="localhost" name="JBR-Socket"
            protocol="socket">
            <jbr-bus busid="sockettest" port="6969" />
        </jbr-provider>
        <jms-provider connection-factory="ConnectionFactory"
            name="socket-jms-provider">
            <jms-bus busid="socketJmsProvider">
                <jms-message-filter dest-name="queue/socket_in_q"
                    dest-type="QUEUE" />
            </jms-bus>
        </jms-provider>
    </providers>
    <services>
        <service category="Socket" description="testSocket" name="socket-JMS-Service">
            <listeners>
                <jbr-listener busidref="sockettest" is-gateway="true"
                    name="socketGateway" />
                <jms-listener busidref="socketJmsProvider" name="JMSEsbAware" />
            </listeners>
            <actions>
                <action class="listener.SocketListener" name="socketlistener"
                    process="process" />
            </actions>
        </service>
    </services>
</jbossesb>

Client Code:

     public class SendMessage {

    public static void main(String args[]) throws Throwable {
        SendMessage sm = new SendMessage();

        sm.sendMessageToJBRListener("http", 8080, "sandeep gowda");

    }

    private void sendMessageToJBRListener(String protocol, int port,
            String message) throws Throwable {
        String locatorURI = protocol + "://localhost:" + port;
        InvokerLocator locator = new InvokerLocator(locatorURI);
        System.out
                .println("Calling JBoss Remoting Listener using locator URI: "
                        + locatorURI);

        Client remotingClient = null;
        try {
            remotingClient = new Client(locator);
            remotingClient.connect();

            // Deliver the message to the listener...
            Object response = remotingClient.invoke(message);
            System.out.println("JBR Class: " + response.getClass().getName());
            System.out.println("Response from JBoss Remoting Listener '"
                    + locatorURI + "' was '" + response + "'.");
        } finally {
            if (remotingClient != null) {
                remotingClient.disconnect();
            }
        }
    }
}

Listener code:

public class SocketListener extends AbstractActionPipelineProcessor{
   
    protected ConfigTree _config;

    public SocketListener(ConfigTree config) {
        _config = config;
    }
   
    public Message process(Message arg0) throws ActionProcessingException {

        arg0.getContext();
       
        return arg0;
    }

}

Thanks

Sandeep