Package | Description |
---|---|
org.red5.server.messaging | |
org.red5.server.scope | |
org.red5.server.stream | |
org.red5.server.stream.consumer | |
org.red5.server.stream.filter |
Modifier and Type | Interface and Description |
---|---|
interface |
IFilter
Filter marker interface groups consumer and provider interfaces
|
interface |
IPushableConsumer
A consumer that supports event-driven message handling and message pushing through pipes.
|
Modifier and Type | Field and Description |
---|---|
protected CopyOnWriteArrayList<IConsumer> |
AbstractPipe.consumers
Pipe consumers list
|
Modifier and Type | Method and Description |
---|---|
IConsumer |
PipeConnectionEvent.getConsumer()
Return pipe connection consumer
|
Modifier and Type | Method and Description |
---|---|
List<IConsumer> |
AbstractPipe.getConsumers()
Getter for consumers
|
List<IConsumer> |
IMessageInput.getConsumers()
Getter for consumers list.
|
Modifier and Type | Method and Description |
---|---|
static void |
PipeUtils.connect(IProvider provider,
IPipe pipe,
IConsumer consumer)
Connect a provider/consumer with a pipe.
|
static void |
PipeUtils.disconnect(IProvider provider,
IPipe pipe,
IConsumer consumer)
Disconnect a provider/consumer from a pipe.
|
protected void |
AbstractPipe.fireConsumerConnectionEvent(IConsumer consumer,
int type,
Map<String,Object> paramMap)
Broadcast consumer connection event
|
void |
AbstractPipe.sendOOBControlMessage(IConsumer consumer,
OOBControlMessage oobCtrlMsg)
Send out-of-band ("special") control message to all providers
|
void |
IMessageInput.sendOOBControlMessage(IConsumer consumer,
OOBControlMessage oobCtrlMsg)
Send OOB Control Message to all providers on the other side of pipe.
|
void |
PipeConnectionEvent.setConsumer(IConsumer consumer)
Setter for pipe connection consumer
|
boolean |
AbstractPipe.subscribe(IConsumer consumer,
Map<String,Object> paramMap)
Connect consumer to this pipe.
|
boolean |
IMessageInput.subscribe(IConsumer consumer,
Map<String,Object> paramMap)
Connect to a consumer.
|
boolean |
InMemoryPullPullPipe.subscribe(IConsumer consumer,
Map<String,Object> paramMap)
Connect consumer to this pipe.
|
boolean |
InMemoryPushPushPipe.subscribe(IConsumer consumer,
Map<String,Object> paramMap)
Connect consumer to this pipe.
|
boolean |
AbstractPipe.unsubscribe(IConsumer consumer)
Disconnects consumer from this pipe.
|
boolean |
IMessageInput.unsubscribe(IConsumer consumer)
Disconnect from a consumer.
|
Modifier and Type | Method and Description |
---|---|
List<IConsumer> |
BroadcastScope.getConsumers()
Getter for pipe consumers
|
Modifier and Type | Method and Description |
---|---|
void |
BroadcastScope.sendOOBControlMessage(IConsumer consumer,
OOBControlMessage oobCtrlMsg)
Send out-of-band ("special") control message
|
boolean |
BroadcastScope.subscribe(IConsumer consumer,
Map<String,Object> paramMap)
Connect scope's pipe to given consumer
|
boolean |
BroadcastScope.unsubscribe(IConsumer consumer)
Disconnects scope's pipe from given consumer
|
Modifier and Type | Class and Description |
---|---|
class |
ClientBroadcastStream
Represents live stream broadcasted from client.
|
class |
PlayEngine
A play engine for playing an IPlayItem.
|
class |
ServerStream
An implementation for server side stream.
|
Modifier and Type | Class and Description |
---|---|
class |
ConnectionConsumer
RTMP connection consumer.
|
class |
FileConsumer
Consumer that pushes messages to file.
|
Modifier and Type | Class and Description |
---|---|
class |
StreamBandwidthController
Controls stream bandwidth
|
Copyright © 2006-2012 The Red5 Project