org.jboss.resteasy.core
Class AsynchronousDispatcher
java.lang.Object
org.jboss.resteasy.core.SynchronousDispatcher
org.jboss.resteasy.core.AsynchronousDispatcher
- All Implemented Interfaces:
- Dispatcher
public class AsynchronousDispatcher
- extends SynchronousDispatcher
- Version:
- $Revision: 1 $
- Author:
- Bill Burke
Field Summary |
protected java.util.concurrent.ExecutorService |
executor
|
Method Summary |
Response |
get(long wait,
boolean nowait,
java.lang.String jobId)
|
void |
invoke(HttpRequest in,
HttpResponse response)
|
void |
invokeSuper(HttpRequest request,
HttpResponse response)
|
boolean |
isAsynchrnousRequest(HttpRequest in)
|
void |
oneway(HttpRequest request,
HttpResponse response)
|
void |
postJob(HttpRequest request,
HttpResponse response)
|
protected Response |
process(long wait,
boolean nowait,
java.lang.String jobId,
boolean eatJob)
|
Response |
readAndRemove(long wait,
boolean nowait,
java.lang.String jobId)
|
void |
remove(java.lang.String jobId)
|
void |
setBasePath(java.lang.String basePath)
Set the base path to find jobs |
void |
setExecutor(java.util.concurrent.ExecutorService executor)
Plug in your own executor to process requests |
void |
setMaxCacheSize(int maxCacheSize)
Max response cache size default is 100 |
void |
setMaxWaitMilliSeconds(long maxWaitMilliSeconds)
Maximum wait time. |
void |
setThreadPoolSize(int threadPoolSize)
Fixed thread pool size of asynchronous delivery |
void |
start()
|
void |
stop()
|
Methods inherited from class org.jboss.resteasy.core.SynchronousDispatcher |
asynchronousDelivery, getDispatcherUtilities, getInvoker, getLanguageMappings, getMediaTypeMappings, getProviderFactory, getRegistry, handleApplicationException, handleException, handleFailure, handleInvokerException, handleWebApplicationException, handleWriteResponseException, invoke, preprocess, preprocessExtensions, setDispatcherUtilities, setLanguageMappings, setMediaTypeMappings, writeJaxrsResponse |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
executor
protected java.util.concurrent.ExecutorService executor
AsynchronousDispatcher
public AsynchronousDispatcher(ResteasyProviderFactory providerFactory)
setMaxCacheSize
public void setMaxCacheSize(int maxCacheSize)
- Max response cache size default is 100
- Parameters:
maxCacheSize
-
setMaxWaitMilliSeconds
public void setMaxWaitMilliSeconds(long maxWaitMilliSeconds)
- Maximum wait time. This overrides any wait query parameter
- Parameters:
maxWaitMilliSeconds
-
setBasePath
public void setBasePath(java.lang.String basePath)
- Set the base path to find jobs
- Parameters:
basePath
-
setThreadPoolSize
public void setThreadPoolSize(int threadPoolSize)
- Fixed thread pool size of asynchronous delivery
- Parameters:
threadPoolSize
-
setExecutor
public void setExecutor(java.util.concurrent.ExecutorService executor)
- Plug in your own executor to process requests
- Parameters:
executor
-
start
public void start()
stop
public void stop()
remove
public void remove(java.lang.String jobId)
readAndRemove
public Response readAndRemove(long wait,
boolean nowait,
java.lang.String jobId)
get
public Response get(long wait,
boolean nowait,
java.lang.String jobId)
process
protected Response process(long wait,
boolean nowait,
java.lang.String jobId,
boolean eatJob)
invokeSuper
public void invokeSuper(HttpRequest request,
HttpResponse response)
isAsynchrnousRequest
public boolean isAsynchrnousRequest(HttpRequest in)
invoke
public void invoke(HttpRequest in,
HttpResponse response)
- Specified by:
invoke
in interface Dispatcher
- Overrides:
invoke
in class SynchronousDispatcher
postJob
public void postJob(HttpRequest request,
HttpResponse response)
oneway
public void oneway(HttpRequest request,
HttpResponse response)
Copyright © 2009. All Rights Reserved.