com.bstek.dorado.view.task

Class LongTaskSocketServer

java.lang.Object

com.bstek.dorado.view.task.LongTaskSocketServer

All Implemented Interfaces:

SocketLongTaskConnectorListener

public class LongTaskSocketServer
extends java.lang.Object
implements SocketLongTaskConnectorListener

Since:

2014-1-26

Author:

Benny Bao (mailto:benny.bao@bstek.com)

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	LongTaskSocketServer.AbortException
static class	LongTaskSocketServer.TaskStatePacket

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	LONG_TASK_KEY_PREFIX
static java.lang.String	TASK_CONNECTOR_KEY_PREFIX
static java.lang.String	TASK_SCHEDULER_KEY_PREFIX

Constructor Summary

Constructors

Constructor and Description
LongTaskSocketServer()

Method Summary

Methods

Modifier and Type	Method and Description
LongTaskSocketServer.TaskStatePacket	connectLongTask(DoradoContext context, Socket socket, java.lang.String taskName)
protected TaskScheduler	findTaskSchedular(DoradoContext context, java.lang.String taskName)
protected LongTask	getLongTask(DoradoContext context, ExposedServiceDefintion exposedService, java.lang.Object parameter)
protected LongTask	invokeByParameterName(java.lang.Object serviceBean, java.lang.reflect.Method[] methods, java.lang.Object parameter, boolean disassembleParameter)
protected LongTask	invokeByParameterType(java.lang.Object serviceBean, java.lang.reflect.Method[] methods, java.lang.Object parameter, boolean disassembleParameter)
void	onClose(SocketLongTaskConnector connector)
void	setExposedServiceManager(ExposedServiceManager exposedServiceManager)
void	setLongPollingManager(LongPollingManager longPollingManager)
void	startLongTask(DoradoContext context, java.util.Map<java.lang.String,java.lang.Object> parameter)

Methods inherited from class java.lang.Object

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

Field Detail

LONG_TASK_KEY_PREFIX

public static final java.lang.String LONG_TASK_KEY_PREFIX

TASK_SCHEDULER_KEY_PREFIX

public static final java.lang.String TASK_SCHEDULER_KEY_PREFIX

TASK_CONNECTOR_KEY_PREFIX

public static final java.lang.String TASK_CONNECTOR_KEY_PREFIX

Constructor Detail

LongTaskSocketServer

public LongTaskSocketServer()

Method Detail

setExposedServiceManager

public void setExposedServiceManager(ExposedServiceManager exposedServiceManager)

setLongPollingManager

public void setLongPollingManager(LongPollingManager longPollingManager)

connectLongTask

public LongTaskSocketServer.TaskStatePacket connectLongTask(DoradoContext context,
                                                   Socket socket,
                                                   java.lang.String taskName)
                                                     throws java.lang.Exception

Throws:

java.lang.Exception

startLongTask

public void startLongTask(DoradoContext context,
                 java.util.Map<java.lang.String,java.lang.Object> parameter)
                   throws java.lang.Exception

Throws:

java.lang.Exception

findTaskSchedular

protected TaskScheduler findTaskSchedular(DoradoContext context,
                              java.lang.String taskName)

onClose

public void onClose(SocketLongTaskConnector connector)

Specified by:

onClose in interface SocketLongTaskConnectorListener

getLongTask

protected LongTask getLongTask(DoradoContext context,
                   ExposedServiceDefintion exposedService,
                   java.lang.Object parameter)
                        throws java.lang.Exception

Throws:

java.lang.Exception

invokeByParameterName

protected LongTask invokeByParameterName(java.lang.Object serviceBean,
                             java.lang.reflect.Method[] methods,
                             java.lang.Object parameter,
                             boolean disassembleParameter)
                                  throws MethodAutoMatchingException,
                                         java.lang.Exception

Throws:

MethodAutoMatchingException

java.lang.Exception

invokeByParameterType

protected LongTask invokeByParameterType(java.lang.Object serviceBean,
                             java.lang.reflect.Method[] methods,
                             java.lang.Object parameter,
                             boolean disassembleParameter)
                                  throws MethodAutoMatchingException,
                                         java.lang.Exception

Throws:

MethodAutoMatchingException

java.lang.Exception