Package org.wso2.carbon.cloud.gateway.agent.transport

Class CGPollingTransportTaskManager

java.lang.Object

org.wso2.carbon.cloud.gateway.agent.transport.CGPollingTransportTaskManager

public class CGPollingTransportTaskManager
extends Object

The polling task implementation for transport receiver, there will be a task per deployed service

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	CGPollingTransportTaskManager.STATE

Constructor Summary

Constructors

Constructor	Description
CGPollingTransportTaskManager()

Method Summary

Modifier and Type	Method	Description
String	getServiceName()
void	setConcurrentClients(int concurrentClients)
void	setEndpoint(CGPollingTransportEndpoint endpoint)
void	setHostName(String hostName)
void	setInitialReconnectDuration(int initialReconnectDuration)
void	setMessageProcessingBlockSize(int messageProcessingBlockSize)
void	setNoOfDispatchingTask(int noOfDispatchingTask)
void	setPollingTaskSuspendDuration(long pollingTaskSuspendDuration)
void	setPort(int port)
void	setReconnectionProgressionFactor(double reconnectionProgressionFactor)
void	setRequestBlockSize(int requestBlockSize)
void	setResponseBlockSize(int responseBlockSize)
void	setServiceName(String serviceName)
void	setSubject(CGAgentSubject subject)
void	setTaskBuffers(CGPollingTransportBuffers taskBuffers)
void	setTimeout(int timeout)
void	setToken(String token)
void	setTrustStoreLocation(String trustStoreLocation)
void	setTrustStorePassWord(String trustStorePassWord)
void	setWorkerPool(org.apache.axis2.transport.base.threads.WorkerPool workerPool)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

CGPollingTransportTaskManager

public CGPollingTransportTaskManager()

Method Detail

setConcurrentClients

public void setConcurrentClients(int concurrentClients)

getServiceName

public String getServiceName()

setInitialReconnectDuration

public void setInitialReconnectDuration(int initialReconnectDuration)

setReconnectionProgressionFactor

public void setReconnectionProgressionFactor(double reconnectionProgressionFactor)

setHostName

public void setHostName(String hostName)

setPort

public void setPort(int port)

setTimeout

public void setTimeout(int timeout)

setServiceName

public void setServiceName(String serviceName)

setEndpoint

public void setEndpoint(CGPollingTransportEndpoint endpoint)

setWorkerPool

public void setWorkerPool(org.apache.axis2.transport.base.threads.WorkerPool workerPool)

setRequestBlockSize

public void setRequestBlockSize(int requestBlockSize)

setResponseBlockSize

public void setResponseBlockSize(int responseBlockSize)

setToken

public void setToken(String token)

setTrustStoreLocation

public void setTrustStoreLocation(String trustStoreLocation)

setTrustStorePassWord

public void setTrustStorePassWord(String trustStorePassWord)

setNoOfDispatchingTask

public void setNoOfDispatchingTask(int noOfDispatchingTask)

setSubject

public void setSubject(CGAgentSubject subject)

setMessageProcessingBlockSize

public void setMessageProcessingBlockSize(int messageProcessingBlockSize)

setTaskBuffers

public void setTaskBuffers(CGPollingTransportBuffers taskBuffers)

setPollingTaskSuspendDuration

public void setPollingTaskSuspendDuration(long pollingTaskSuspendDuration)

start

public void start()

stop

public void stop()