org.nuxeo.runtime.services.streaming
Class StreamManagerClient
java.lang.Object
org.nuxeo.runtime.services.streaming.StreamManagerClient
- All Implemented Interfaces:
- StreamManager
public class StreamManagerClient
- extends java.lang.Object
- implements StreamManager
- Author:
- Bogdan Stefanescu
Methods inherited from class java.lang.Object |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
StreamManagerClient
public StreamManagerClient(java.lang.String serverLocator)
throws java.lang.Exception
- Throws:
java.lang.Exception
StreamManagerClient
public StreamManagerClient(java.lang.String serverLocator,
int minBufSize,
int maxBufSize)
throws java.lang.Exception
- Throws:
java.lang.Exception
start
public void start()
throws java.lang.Exception
- Specified by:
start
in interface StreamManager
- Throws:
java.lang.Exception
stop
public void stop()
- Specified by:
stop
in interface StreamManager
addStream
public java.lang.String addStream(StreamSource src)
throws java.io.IOException
- Specified by:
addStream
in interface StreamManager
- Throws:
java.io.IOException
getStream
public StreamSource getStream(java.lang.String uri)
throws java.io.IOException
- Specified by:
getStream
in interface StreamManager
- Throws:
java.io.IOException
hasStream
public boolean hasStream(java.lang.String uri)
- Specified by:
hasStream
in interface StreamManager
removeStream
public void removeStream(java.lang.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(java.lang.String[] args)
Copyright © 2010 Nuxeo SAS. All Rights Reserved.