public class InMemoryPullPullPipe extends AbstractPipe
consumers, listeners, providers
Constructor and Description |
---|
InMemoryPullPullPipe() |
Modifier and Type | Method and Description |
---|---|
IMessage |
pullMessage()
Pull message from this input endpoint.
|
IMessage |
pullMessage(long wait)
Pull message from this input endpoint.
|
void |
pushMessage(IMessage message)
Push a message to this output endpoint.
|
boolean |
subscribe(IConsumer consumer,
Map<String,Object> paramMap)
Connect consumer to this pipe.
|
boolean |
subscribe(IProvider provider,
Map<String,Object> paramMap)
Connect provider to this pipe.
|
addPipeConnectionListener, close, fireConsumerConnectionEvent, firePipeConnectionEvent, fireProviderConnectionEvent, getConsumers, getListeners, getProviders, removePipeConnectionListener, sendOOBControlMessage, sendOOBControlMessage, setListeners, unsubscribe, unsubscribe
public boolean subscribe(IConsumer consumer, Map<String,Object> paramMap)
subscribe
in interface IMessageInput
subscribe
in class AbstractPipe
consumer
- ConsumerparamMap
- Parameters passed with connection, used in concrete pipe implementationstrue
if consumer was added, false
otherwisepublic boolean subscribe(IProvider provider, Map<String,Object> paramMap)
subscribe
in interface IMessageOutput
subscribe
in class AbstractPipe
provider
- ProviderparamMap
- Parameters passed with connection, used in concrete pipe implementationstrue
if provider was added, false
otherwisepublic IMessage pullMessage() throws IOException
IOException
- on errorpublic IMessage pullMessage(long wait)
wait
- milliseconds to wait when message is not
available.public void pushMessage(IMessage message)
message
- Message to be pushed.Copyright © 2006-2012 The Red5 Project