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
StreamManagerClient
public StreamManagerClient(String serverLocator)
throws Exception
- Throws:
Exception
StreamManagerClient
public StreamManagerClient(String serverLocator,
int minBufSize,
int maxBufSize)
throws Exception
- Throws:
Exception
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)
Copyright © 2011 Nuxeo SAS. All Rights Reserved.