How use AsynchronousServerSocketChannel with JCA 1.6 ?

[rockerced]

Hello at all,

I want to develop a AsynchronousServerSocketChannel with NIO.2 by using ThreadGroup with JCA 1.6. But I doesn't know how use AsynchronousChannelGroup with the javax.resource.spi.work.Work interface.
In the example of google jca-sockets implementation. When a new client is accepted (ServerSocket) a work is created to manage socket client.

INBOUND mode in JCA 1.6

Exemple of code for asynchronous server :
    ExecutorService es = Executors.newCachedThreadPool();
    if (es instanceof ThreadPoolExecutor){
    ((ThreadPoolExecutor)es).setMaximumPoolSize(serverInfo.getMaxThread());
    }
    AsynchronousChannelGroup threadGroup = AsynchronousChannelGroup.withCachedThreadPool(es,serverInfo.getMinThread());

    /*server configuration*/
    SocketAddress sa = new InetSocketAddress(Inet4Address.getByName(socketInfo.getHost()), socketInfo.getPort());

    /*server instantiation*/
    server = AsynchronousServerSocketChannel.open(threadGroup).bind(sa);

Thread management is performed by AsynchronousChannelGroup.

Is it necessary to use only ServerSocket for JCA 1.6 implementation ?

Can you give an example of implementation ?

Best regards
GOSSET Cédric

[jesper.pedersen]

The executor services passed in to withCachedThreadPool should be wrapper for submitting Work instances to the WorkManager.

You could run your server socket in a Work instance too - I probably would...

See http://www.ironjacamar.org/doc/userguide/1.1/en-US/html/ch01.html#overview for your outbound/inbound architecture.

Otherwise let us know more details about your setup - but read the above first.

[rockerced]

Thanks for your response,

I launch the server in a Work instance but i don't know how wrap Thread of the ThreadPool with the wor instance.

The ThreadPool manage lifecycle of Threads. How to wrap all the states of the life cycle of the thread with the WorkManager.

Do you have an example of an NIO.2 implementation ?

Best regards

[jesper.pedersen]

No, do a wrapper class that implements the ExecutorService interface, and take a WorkManager instance in its constructor.

Then the methods uses the WorkManager to execute whatever is passed in.

I would start the ServerSocket in the ResourceAdapter::start() method...

I don't have any NIO.2 examples.

HTH