org.mule.module.http.internal.listener.grizzly

Class ExecutorPerServerAddressIOStrategy

java.lang.Object

org.glassfish.grizzly.strategies.AbstractIOStrategy

org.mule.module.http.internal.listener.grizzly.ExecutorPerServerAddressIOStrategy

All Implemented Interfaces:

org.glassfish.grizzly.IOStrategy, org.glassfish.grizzly.strategies.WorkerThreadPoolConfigProducer

public class ExecutorPerServerAddressIOStrategy
extends org.glassfish.grizzly.strategies.AbstractIOStrategy

Grizzly IO Strategy that will handle each work to an specific Executor based on the ServerAddress of a Connection.

There's logic from WorkerThreadIOStrategy that need to be reused but unfortunately that class cannot be override.

Field Summary

Fields inherited from class org.glassfish.grizzly.strategies.AbstractIOStrategy

ENABLE_INTEREST_LIFECYCLE_LISTENER

Constructor Summary

Constructors

Constructor and Description
ExecutorPerServerAddressIOStrategy(ExecutorProvider executorProvider)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	executeIoEvent(org.glassfish.grizzly.Connection connection, org.glassfish.grizzly.IOEvent ioEvent, boolean isIoEventEnabled)
Executor	getThreadPoolFor(org.glassfish.grizzly.Connection connection, org.glassfish.grizzly.IOEvent ioEvent)

Methods inherited from class org.glassfish.grizzly.strategies.AbstractIOStrategy

createDefaultWorkerPoolConfig, executeIoEvent, fireIOEvent, isReadWrite

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ExecutorPerServerAddressIOStrategy

public ExecutorPerServerAddressIOStrategy(ExecutorProvider executorProvider)

Method Detail

executeIoEvent

public boolean executeIoEvent(org.glassfish.grizzly.Connection connection,
                     org.glassfish.grizzly.IOEvent ioEvent,
                     boolean isIoEventEnabled)
                       throws IOException

Throws:

IOException

getThreadPoolFor

public Executor getThreadPoolFor(org.glassfish.grizzly.Connection connection,
                        org.glassfish.grizzly.IOEvent ioEvent)

Specified by:

getThreadPoolFor in interface org.glassfish.grizzly.IOStrategy

Overrides:

getThreadPoolFor in class org.glassfish.grizzly.strategies.AbstractIOStrategy