org.eclipse.scada.base.pipe.internal

Class PipeServiceImpl

java.lang.Object

org.eclipse.scada.base.pipe.internal.PipeServiceImpl

All Implemented Interfaces:

PipeService

public class PipeServiceImpl
extends Object
implements PipeService

Constructor Summary

Constructors

Constructor and Description
PipeServiceImpl()
PipeServiceImpl(File storage)

Method Summary

Modifier and Type	Method and Description
void	closeTestWorker()
Producer	createProducer(String pipeName)
WorkerHandle	createWorker(String pipeName, Worker worker)
void	drop(String pipeName)
Long	fetchNextEvents(String pipeName, int max, List<File> result)
static File	getDefaultDirectory()
void	list(String pipeName)
protected void	performClose(String pipeName)
void	pipes()
void	processNextEvent(Worker worker, String pipeName)
protected void	publishEvent(String pipeName, byte[] data, int retries)
void	start()
void	startTestWorker(String pipeName)
void	stop()
void	testPublish(String pipeName, String data)

Methods inherited from class java.lang.Object

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

Constructor Detail

PipeServiceImpl

public PipeServiceImpl()

PipeServiceImpl

public PipeServiceImpl(File storage)

Method Detail

start

public void start()

stop

public void stop()

getDefaultDirectory

public static File getDefaultDirectory()

createProducer

public Producer createProducer(String pipeName)

Specified by:

createProducer in interface PipeService

publishEvent

protected void publishEvent(String pipeName,
                            byte[] data,
                            int retries)
                     throws IOException

Throws:

IOException

createWorker

public WorkerHandle createWorker(String pipeName,
                                 Worker worker)
                          throws WorkerAlreadyCreated

Specified by:

createWorker in interface PipeService

Throws:

WorkerAlreadyCreated

fetchNextEvents

public Long fetchNextEvents(String pipeName,
                            int max,
                            List<File> result)

processNextEvent

public void processNextEvent(Worker worker,
                             String pipeName)
                      throws IOException

Throws:

IOException

performClose

protected void performClose(String pipeName)

pipes

public void pipes()

list

public void list(String pipeName)

startTestWorker

public void startTestWorker(String pipeName)
                     throws WorkerAlreadyCreated

Throws:

WorkerAlreadyCreated

closeTestWorker

public void closeTestWorker()

testPublish

public void testPublish(String pipeName,
                        String data)
                 throws IOException

Throws:

IOException

drop

public void drop(String pipeName)
          throws IOException

Throws:

IOException