org.red5.server.stream
Class StreamingProxy
java.lang.Object
org.red5.server.stream.StreamingProxy
- All Implemented Interfaces:
- IPendingServiceCallback, IConsumer, IMessageComponent, IPipeConnectionListener, IPushableConsumer, INetStreamEventHandler
public class StreamingProxy
- extends Object
- implements IPushableConsumer, IPipeConnectionListener, INetStreamEventHandler, IPendingServiceCallback
A proxy to publish stream from server to server.
TODO: Use timer to monitor the connect/stream creation.
- Author:
- Steven Gong (steven.gong@gmail.com), Andy Shaules (bowljoman@hotmail.com)
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
LIVE
public static final String LIVE
- See Also:
- Constant Field Values
RECORD
public static final String RECORD
- See Also:
- Constant Field Values
APPEND
public static final String APPEND
- See Also:
- Constant Field Values
StreamingProxy
public StreamingProxy()
init
public void init()
start
public void start(String publishName,
String publishMode,
Object[] params)
stop
public void stop()
onPipeConnectionEvent
public void onPipeConnectionEvent(PipeConnectionEvent event)
- Description copied from interface:
IPipeConnectionListener
- Pipe connection event handler
- Specified by:
onPipeConnectionEvent
in interface IPipeConnectionListener
- Parameters:
event
- Pipe connection event
pushMessage
public void pushMessage(IPipe pipe,
IMessage message)
throws IOException
- Description copied from interface:
IPushableConsumer
- Pushes message through pipe
- Specified by:
pushMessage
in interface IPushableConsumer
- Parameters:
pipe
- Pipemessage
- Message
- Throws:
IOException
- if message could not be written
onOOBControlMessage
public void onOOBControlMessage(IMessageComponent source,
IPipe pipe,
OOBControlMessage oobCtrlMsg)
- Specified by:
onOOBControlMessage
in interface IMessageComponent
- Parameters:
source
- Message component sourcepipe
- Connection pipe
TODOoobCtrlMsg
- Out-of-band control message
setHost
public void setHost(String host)
setPort
public void setPort(int port)
setApp
public void setApp(String app)
onStreamEvent
public void onStreamEvent(Notify notify)
- Specified by:
onStreamEvent
in interface INetStreamEventHandler
resultReceived
public void resultReceived(IPendingServiceCall call)
- Description copied from interface:
IPendingServiceCallback
- Triggered when results are recieved
- Specified by:
resultReceived
in interface IPendingServiceCallback
- Parameters:
call
- Call object this callback is applied to
Copyright © 2006-2010 The Red5 Project