|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
java.lang.Objectorg.red5.server.messaging.AbstractPipe
org.red5.server.messaging.InMemoryPullPullPipe
public class InMemoryPullPullPipe
A simple in-memory version of pull-pull pipe. It is triggered by an active consumer that pulls messages through it from a pullable provider.
| Field Summary |
|---|
| Fields inherited from class org.red5.server.messaging.AbstractPipe |
|---|
consumers, listeners, providers |
| Constructor Summary | |
|---|---|
InMemoryPullPullPipe()
|
|
| Method Summary | |
|---|---|
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<?,?> paramMap)
Connect consumer to this pipe. |
boolean |
subscribe(IProvider provider,
Map<?,?> paramMap)
Connect provider to this pipe. |
| Methods inherited from class org.red5.server.messaging.AbstractPipe |
|---|
addPipeConnectionListener, fireConsumerConnectionEvent, firePipeConnectionEvent, fireProviderConnectionEvent, getConsumers, getListeners, getProviders, removePipeConnectionListener, sendOOBControlMessage, sendOOBControlMessage, setListeners, unsubscribe, unsubscribe |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Constructor Detail |
|---|
public InMemoryPullPullPipe()
| Method Detail |
|---|
public boolean subscribe(IConsumer consumer,
Map<?,?> paramMap)
subscribe in interface IMessageInputsubscribe in class AbstractPipeconsumer - ConsumerparamMap - Parameters passed with connection, used in concrete pipe implementations
true if consumer was added, false otherwise
public boolean subscribe(IProvider provider,
Map<?,?> paramMap)
subscribe in interface IMessageOutputsubscribe in class AbstractPipeprovider - ProviderparamMap - Parameters passed with connection, used in concrete pipe implementations
true if provider was added, false otherwise
public 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.
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||