public interface IMessageInput
Modifier and Type | Method and Description |
---|---|
List<IConsumer> |
getConsumers()
Getter for consumers list.
|
IMessage |
pullMessage()
Pull message from this input endpoint.
|
IMessage |
pullMessage(long wait)
Pull message from this input endpoint.
|
void |
sendOOBControlMessage(IConsumer consumer,
OOBControlMessage oobCtrlMsg)
Send OOB Control Message to all providers on the other side of pipe.
|
boolean |
subscribe(IConsumer consumer,
Map<String,Object> paramMap)
Connect to a consumer.
|
boolean |
unsubscribe(IConsumer consumer)
Disconnect from a consumer.
|
IMessage pullMessage() throws IOException
IOException
- on errorIMessage pullMessage(long wait)
wait
- milliseconds to wait when message is not
available.boolean subscribe(IConsumer consumer, Map<String,Object> paramMap)
consumer
- ConsumerparamMap
- Parameters mapboolean unsubscribe(IConsumer consumer)
consumer
- Consumer to disconnectvoid sendOOBControlMessage(IConsumer consumer, OOBControlMessage oobCtrlMsg)
consumer
- The consumer that sends the messageoobCtrlMsg
- Out-of-band control messageCopyright © 2006-2012 The Red5 Project