org.wso2.esb.integration.common.utils.servers

Class ThriftServer

java.lang.Object

org.wso2.esb.integration.common.utils.servers.ThriftServer

All Implemented Interfaces:

Runnable

public class ThriftServer
extends Object
implements Runnable

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	ThriftServer.GenericExtFilter

Constructor Summary

Constructors

Constructor and Description
ThriftServer(String testCaseResourceFolderName, int listeningPort, boolean isPreservingEvents)

Method Summary

Modifier and Type	Method and Description
long	getMsgCount()
List<org.wso2.carbon.databridge.commons.Event>	getPreservedEventList()
String	getResourceFilePath(String testCaseFolderName, String resourceFileName)
List<org.wso2.carbon.databridge.commons.StreamDefinition>	loadStreamDefinitions()
void	resetMsgCount()
void	resetPreservedEventList()
void	run()
void	start(int receiverPort)
void	startServer()
void	stop()
void	waitToReceiveEvents(int maxWaitTime, int expectedCount)

Methods inherited from class java.lang.Object

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

Constructor Detail

ThriftServer

public ThriftServer(String testCaseResourceFolderName,
                    int listeningPort,
                    boolean isPreservingEvents)

Method Detail

startServer

public void startServer()
                 throws org.wso2.carbon.databridge.core.exception.DataBridgeException,
                        org.wso2.carbon.databridge.core.exception.StreamDefinitionStoreException

Throws:

org.wso2.carbon.databridge.core.exception.DataBridgeException

org.wso2.carbon.databridge.core.exception.StreamDefinitionStoreException

start

public void start(int receiverPort)
           throws org.wso2.carbon.databridge.core.exception.DataBridgeException,
                  org.wso2.carbon.databridge.core.exception.StreamDefinitionStoreException

Throws:

org.wso2.carbon.databridge.core.exception.DataBridgeException

org.wso2.carbon.databridge.core.exception.StreamDefinitionStoreException

stop

public void stop()

run

public void run()

Specified by:

run in interface Runnable

getMsgCount

public long getMsgCount()

getPreservedEventList

public List<org.wso2.carbon.databridge.commons.Event> getPreservedEventList()

resetMsgCount

public void resetMsgCount()

resetPreservedEventList

public void resetPreservedEventList()

loadStreamDefinitions

public List<org.wso2.carbon.databridge.commons.StreamDefinition> loadStreamDefinitions()

getResourceFilePath

public String getResourceFilePath(String testCaseFolderName,
                                  String resourceFileName)

waitToReceiveEvents

public void waitToReceiveEvents(int maxWaitTime,
                                int expectedCount)