org.nuxeo.runtime.services.streaming
Class StreamManagerClient

java.lang.Object
  org.nuxeo.runtime.services.streaming.StreamManagerClient

All Implemented Interfaces:

StreamManager

public class StreamManagerClient
extends Object
implements StreamManager

Author:

Bogdan Stefanescu

Constructor Summary

StreamManagerClient(String serverLocator)

StreamManagerClient(String serverLocator, int minBufSize, int maxBufSize)

Method Summary

String	addStream(StreamSource src)
StreamingServer	getServer()
StreamSource	getStream(String uri)
boolean	hasStream(String uri)
static void	main(String[] args)
void	removeStream(String uri)
void	setMaxBufferSize(int maxBufSize)
void	setMinBufferSize(int minBufSize)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamManagerClient

public StreamManagerClient(String serverLocator)
                    throws Exception

Throws:

Exception

StreamManagerClient

public StreamManagerClient(String serverLocator,
                           int minBufSize,
                           int maxBufSize)
                    throws Exception

Throws:

Exception

Method Detail

start

public void start()
           throws Exception

Specified by:

start in interface StreamManager

Throws:

Exception

stop

public void stop()

Specified by:

stop in interface StreamManager

addStream

public String addStream(StreamSource src)
                 throws IOException

Specified by:

addStream in interface StreamManager

Throws:

IOException

getStream

public StreamSource getStream(String uri)
                       throws IOException

Specified by:

getStream in interface StreamManager

Throws:

IOException

hasStream

public boolean hasStream(String uri)

Specified by:

hasStream in interface StreamManager

removeStream

public void removeStream(String uri)

Specified by:

removeStream in interface StreamManager

setMaxBufferSize

public void setMaxBufferSize(int maxBufSize)

setMinBufferSize

public void setMinBufferSize(int minBufSize)

getServer

public StreamingServer getServer()

main

public static void main(String[] args)