|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.red5.server.net.rtmp.codec.RTMPProtocolEncoder
public class RTMPProtocolEncoder
RTMP protocol encoder encodes RTMP messages and packets to byte buffers.
Field Summary | |
---|---|
protected static Logger |
log
|
protected Serializer |
serializer
Serializer object. |
Constructor Summary | |
---|---|
RTMPProtocolEncoder()
|
Method Summary | |
---|---|
protected boolean |
dropMessage(RTMP rtmp,
int channelId,
IRTMPEvent message)
Determine if this message should be dropped for lateness. |
IoBuffer |
encode(ProtocolState state,
Object message)
Encodes object with given protocol state to byte buffer |
IoBuffer |
encodeAggregate(Aggregate aggregate)
Encodes Aggregate event to byte buffer. |
IoBuffer |
encodeAudioData(AudioData audioData)
Encodes AudioData event to byte buffer. |
IoBuffer |
encodeBytesRead(BytesRead bytesRead)
Encodes BytesRead event to byte buffer. |
IoBuffer |
encodeChunkSize(ChunkSize chunkSize)
Encodes ChunkSize event to byte buffer. |
IoBuffer |
encodeFlexMessage(FlexMessage msg,
RTMP rtmp)
Encodes Flex message event. |
IoBuffer |
encodeFlexSharedObject(ISharedObjectMessage so,
RTMP rtmp)
Encodes SharedObjectMessage event to byte buffer using AMF3 encoding. |
IoBuffer |
encodeFlexStreamSend(FlexStreamSend msg)
|
IoBuffer |
encodeHeader(RTMP rtmp,
Header header,
Header lastHeader)
Encode RTMP header. |
void |
encodeHeader(RTMP rtmp,
Header header,
Header lastHeader,
IoBuffer buf)
Encode RTMP header into given IoBuffer. |
IoBuffer |
encodeInvoke(Invoke invoke,
RTMP rtmp)
Encodes Invoke event to byte buffer. |
IoBuffer |
encodeMessage(RTMP rtmp,
Header header,
IRTMPEvent message)
Encode message. |
IoBuffer |
encodeNotify(Notify notify,
RTMP rtmp)
Encodes Notify event to byte buffer. |
protected void |
encodeNotifyOrInvoke(IoBuffer out,
Notify invoke,
RTMP rtmp)
Encode notification event and fill given byte buffer. |
protected IoBuffer |
encodeNotifyOrInvoke(Notify invoke,
RTMP rtmp)
Encode notification event. |
IoBuffer |
encodePacket(RTMP rtmp,
Packet packet)
Encode packet. |
IoBuffer |
encodePing(Ping ping)
Encodes Ping event to byte buffer. |
IoBuffer |
encodeSharedObject(ISharedObjectMessage so,
RTMP rtmp)
Encodes SharedObjectMessage event to byte buffer. |
IoBuffer |
encodeStreamMetadata(Notify metaData)
|
IoBuffer |
encodeUnknown(Unknown unknown)
Encodes Unknown event to byte buffer. |
IoBuffer |
encodeVideoData(VideoData videoData)
Encodes VideoData event to byte buffer. |
protected StatusObject |
generateErrorResult(String code,
Throwable error)
Generate error object to return for given exception. |
long |
getBaseTolerance()
|
void |
setBaseTolerance(long baseTolerance)
|
void |
setConnection(RTMPConnection conn)
Set the connection being used with this encoder |
void |
setDropLiveFuture(boolean dropLiveFuture)
Setter for dropLiveFuture |
void |
setSerializer(Serializer serializer)
Setter for serializer. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected static Logger log
protected Serializer serializer
Constructor Detail |
---|
public RTMPProtocolEncoder()
Method Detail |
---|
public IoBuffer encode(ProtocolState state, Object message) throws Exception
state
- Protocol statemessage
- Object to encode
Exception
- Any decoding exceptionpublic IoBuffer encodePacket(RTMP rtmp, Packet packet)
rtmp
- RTMP protocol statepacket
- RTMP packet
protected boolean dropMessage(RTMP rtmp, int channelId, IRTMPEvent message)
rtmp
- the protocol statechannelId
- the channel IDmessage
- the message
public IoBuffer encodeHeader(RTMP rtmp, Header header, Header lastHeader)
rtmp
- The protocol stateheader
- RTMP message headerlastHeader
- Previous header
public void encodeHeader(RTMP rtmp, Header header, Header lastHeader, IoBuffer buf)
rtmp
- The protocol stateheader
- RTMP message headerlastHeader
- Previous headerbuf
- Buffer to write encoded header topublic IoBuffer encodeMessage(RTMP rtmp, Header header, IRTMPEvent message)
rtmp
- RTMP protocol stateheader
- RTMP message headermessage
- RTMP message (event)
public IoBuffer encodeChunkSize(ChunkSize chunkSize)
encodeChunkSize
in interface IEventEncoder
chunkSize
- ChunkSize event
public IoBuffer encodeFlexSharedObject(ISharedObjectMessage so, RTMP rtmp)
encodeFlexSharedObject
in interface IEventEncoder
so
- ISharedObjectMessage eventrtmp
- RTMP protocol state
public IoBuffer encodeSharedObject(ISharedObjectMessage so, RTMP rtmp)
encodeSharedObject
in interface IEventEncoder
so
- ISharedObjectMessage eventrtmp
- RTMP protocol state
public IoBuffer encodeNotify(Notify notify, RTMP rtmp)
encodeNotify
in interface IEventEncoder
notify
- Notify eventrtmp
- RTMP protocol state
public IoBuffer encodeInvoke(Invoke invoke, RTMP rtmp)
encodeInvoke
in interface IEventEncoder
invoke
- Invoke eventrtmp
- RTMP protocol state
protected IoBuffer encodeNotifyOrInvoke(Notify invoke, RTMP rtmp)
invoke
- Notification event
protected void encodeNotifyOrInvoke(IoBuffer out, Notify invoke, RTMP rtmp)
out
- Byte buffer to fillinvoke
- Notification eventpublic IoBuffer encodePing(Ping ping)
encodePing
in interface IEventEncoder
ping
- Ping event
public IoBuffer encodeBytesRead(BytesRead bytesRead)
encodeBytesRead
in interface IEventEncoder
bytesRead
- BytesRead event
public IoBuffer encodeAggregate(Aggregate aggregate)
encodeAggregate
in interface IEventEncoder
aggregate
- Aggregate event
public IoBuffer encodeAudioData(AudioData audioData)
encodeAudioData
in interface IEventEncoder
audioData
- AudioData event
public IoBuffer encodeVideoData(VideoData videoData)
encodeVideoData
in interface IEventEncoder
videoData
- VideoData event
public IoBuffer encodeUnknown(Unknown unknown)
encodeUnknown
in interface IEventEncoder
unknown
- Unknown event
public IoBuffer encodeStreamMetadata(Notify metaData)
protected StatusObject generateErrorResult(String code, Throwable error)
code
- callerror
- error
public IoBuffer encodeFlexMessage(FlexMessage msg, RTMP rtmp)
msg
- Flex message eventrtmp
- RTMP
public IoBuffer encodeFlexStreamSend(FlexStreamSend msg)
public void setSerializer(Serializer serializer)
serializer
- Serializerpublic void setBaseTolerance(long baseTolerance)
public void setDropLiveFuture(boolean dropLiveFuture)
public long getBaseTolerance()
public void setConnection(RTMPConnection conn)
conn
- active connection
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |