Package com.espertech.esperio.csv

Class SenderThreadPool

java.lang.Object

com.espertech.esperio.csv.AbstractSender

com.espertech.esperio.csv.DirectSender

com.espertech.esperio.csv.SenderThreadPool

public class SenderThreadPool
extends DirectSender

Implementation of Sender to send to esper runtime using a thread pool

Author:

Jerry Shea

Field Summary

Fields inherited from class com.espertech.esperio.csv.AbstractSender

runtime

Constructor Summary

Constructors

Constructor	Description
SenderThreadPool(int threadPoolSize)	Ctor.
SenderThreadPool(ExecutorService executorService)	Ctor.

Method Summary

Modifier and Type	Method	Description
void	sendEvent(Object beanToSend)	Send an event.
void	sendEvent(Map mapToSend, String eventTypeName)	Send an event.

Methods inherited from class com.espertech.esperio.csv.DirectSender

onFinish, sendEvent, sendEvent

Methods inherited from class com.espertech.esperio.csv.AbstractSender

setRuntime

Methods inherited from class java.lang.Object

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

Constructor Details

SenderThreadPool

public SenderThreadPool(int threadPoolSize)

Ctor.

Parameters:

threadPoolSize - size of pool

SenderThreadPool

public SenderThreadPool(ExecutorService executorService)

Ctor.

Parameters:

executorService - threadpool to use

Method Details

sendEvent

public void sendEvent(Object beanToSend)

Send an event.

Parameters:

beanToSend - event to send

sendEvent

public void sendEvent(Map mapToSend,
 String eventTypeName)

Send an event.

Parameters:

mapToSend - event to send

eventTypeName - name of event type