|
||||||||||
| 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.InMemoryPushPushPipe
public class InMemoryPushPushPipe
A simple in-memory version of push-push pipe. It is triggered by an active provider to push messages through it to an event-driven consumer.
| Field Summary |
|---|
| Fields inherited from class org.red5.server.messaging.AbstractPipe |
|---|
consumers, listeners, providers |
| Constructor Summary | |
|---|---|
InMemoryPushPushPipe()
|
|
| Method Summary | |
|---|---|
IMessage |
pullMessage()
Pull message from this input endpoint. |
IMessage |
pullMessage(long wait)
Pull message from this input endpoint. |
void |
pushMessage(IMessage message)
Pushes a message out to all the PushableConsumers. |
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 InMemoryPushPushPipe()
| 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 otherwisepublic IMessage pullMessage()
public IMessage pullMessage(long wait)
wait - milliseconds to wait when message is not
available.
public void pushMessage(IMessage message)
throws IOException
message - Message to be pushed.
IOException - If message could not be written.
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||