Package com.wowza.wms.stream.publish

Class Publisher

  • public class Publisher
extends Object

    Publisher: clientless stream publisher. This class can be used to publish raw video, audio and metadata packets to the Wowza Pro server. Here is a quick snippet of code that illustrates how to use it.

    This code below will publish data the stream named "myStream". It will be streamed to the default virtual host and avaible at the rtmp address rtmp://[server-ip-address]/streamtest.

    IVHost vhost = VHostSingleton.getInstance(VHost.VHOST_DEFAULT);
Publisher publisher = Publisher.createInstance(vhost, "streamtest");

publisher.setFileExtension("flv");
publisher.setStreamType("live");

publisher.publish("myStream", "live");

// sit in a loop adding data
boolean done = false;
while(true)
{
        AMFPacket amfPacket;

        // read packet from audio, video, data source
        // amfPacket = readPacketFromSomewhere();

        switch (amfPacket.getType())
        {
        case IVHost.CONTENTTYPE_AUDIO:
                publisher.addAudioData(amfPacket.getData(), amfPacket.getSize(), amfPacket.getTimecode());
                break;
        case IVHost.CONTENTTYPE_VIDEO:
                publisher.addVideoData(amfPacket.getData(), amfPacket.getSize(), amfPacket.getTimecode());
                break;
        case IVHost.CONTENTTYPE_DATA:
                publisher.addDataData(amfPacket.getData(), amfPacket.getSize(), amfPacket.getTimecode());
                break;
        }
        if (done)
                break;
}

publisher.unpublish();
publisher.close();

    Basic packet format:

Audio:

AAC
[1-byte header]
[1-byte codec config indicator (1 - audio data, 0 - codec config packet)]
[n-bytes audio content or codec config data]

All others
[1-byte header]
[n-bytes audio content]

Below is the bit
layout of the header byte of data (table goes from least significant bit to most significant bit):

1 bit Number of channels:
  0    mono
  1    stereo

1 bit Sample size:
  0    8 bits per sample
  1    16 bits per sample

2 bits Sample rate:
  0    special or 8KHz
  1    11KHz
  2    22KHz
  3    44KHz

4 bits Audio type:
  0    PCM (big endian)
  1    PCM (swf - ADPCM)
  2    MP3
  3    PCM (little endian)
  4    Nelly Moser ASAO 16KHz Mono
  5    Nelly Moser ASAO 8KHz Mono
  6    Nelly Moser ASAO
  7    G.711 ALaw
  8    G.711 MULaw
  9    Reserved
  a    AAC
  b    Speex
  f    MP3 8Khz

Note: For AAC the codec config data is generally a two byte packet that describes the stream. It must
be published first. Here is the basic code to fill in the codec config data.

AACFrame frame = new AACFrame();
int sampleRate = 22100;
int channels = 2;
frame.setSampleRate(sampleRate);
frame.setRateIndex(AACUtils.sampleRateToIndex(sampleRate));
frame.setChannels(channels);
frame.setChannelIndex(AACUtils.channelCountToIndex(sampleRate));
byte[] codecConfig = new byte[2];
AACUtils.encodeAACCodecConfig(frame, codecConfig, 0);

Note: For AAC the header byte is always 0xaf

Note: For Speex the audio data must be encoded as 16000Hz wide band

Video:

H.264
[1-byte header]
[1-byte codec config indicator (1 - video data, 0 - codec config packet)]
[3-byte time difference between dts and pts in milliseconds]
[n-bytes video content or codec config data]

All others
[1-byte header]
[n-bytes audio content]

Below is the bit layout of the header byte of data (table goes from least significant bit to most significant bit):

4 bits Video type:
  2    Sorenson Spark (H.263)
  3    Screen
  4    On2 VP6
  5    On2 VP6A
  6    Screen2
  7    H.264

2 bit Frame type:
  1    K frame (key frame)
  2    P frame
  3    B frame

Note: H.264 codec config data is the same as the AVCc packet in a QuickTime container.

Note: All timecode data is in milliseconds

    • Method Detail

      • createInstance

        public static Publisher createInstance​(IVHost vhost,
                                       String applicationName)

      • createInstance

        public static Publisher createInstance​(IVHost vhost,
                                       String applicationName,
                                       String appInstanceName)

      • getStream

        public IMediaStream getStream()
        Get the media stream object
        Returns:
        media stream object

      • getStreamType

        public String getStreamType()

      • setStreamType

        public void setStreamType​(String streamType)
        Set the stream type (default live)
        Parameters:
        streamType - stream type

      • publish

        public void publish​(String streamName)
        Publish a stream (null to stop publishing)
        Parameters:
        streamName - stream name

      • getFileExtension

        public String getFileExtension()
        Get the file extension (default flv)
        Returns:
        file extension

      • setFileExtension

        public void setFileExtension​(String fileExtension)
        Set the file extension
        Parameters:
        fileExtension - file extension

      • unpublish

        public void unpublish()

      • createStream

        public void createStream()
        Create underlying IMediaStream object if not already created

      • unregisterStreamFromStreamMap

        public void unregisterStreamFromStreamMap()
        Remove the stream from MediaStreamMap

      • publish

        public void publish​(String streamName,
                    String howToPublish)
        Start publishing a stream (streamName = null to stop). Valid howToPublish values are (live, record, append)
        Parameters:
        streamName - stream name
        howToPublish - publish method (live, record, append)

      • addVideoData

        public void addVideoData​(byte[] data,
                         long timecode)
        Add video data
        Parameters:
        data - data
        timecode - absolute timecode (milliseconds)

      • addVideoData

        public void addVideoData​(byte[] data,
                         int len,
                         long timecode)
        Add video data
        Parameters:
        data - data
        len - data length
        timecode - absolute timecode (milliseconds)

      • addVideoData

        public void addVideoData​(byte[] data,
                         int offset,
                         int len,
                         long timecode)
        Add video data
        Parameters:
        data - data
        offset - offset
        len - data length
        timecode - absolute timecode (milliseconds)

      • addVideoData

        public void addVideoData​(byte[] data,
                         int offset,
                         int len,
                         long timecode,
                         java.util.Map<String,​IAMFPacketExtraData> extraData)
        Add video data
        Parameters:
        data - data
        offset - offset
        len - data length
        timecode - absolute timecode (milliseconds)
        extraData - extra data

      • startVideoData

        public void startVideoData​(int len,
                           long timecode)

      • startVideoData

        public void startVideoData​(int len,
                           long timecode,
                           java.util.Map<String,​IAMFPacketExtraData> extraData)

      • addVideoDataInc

        public void addVideoDataInc​(byte[] data,
                            int offset,
                            int len)

      • startAudioData

        public void startAudioData​(int len,
                           long timecode)

      • startAudioData

        public void startAudioData​(int len,
                           long timecode,
                           java.util.Map<String,​IAMFPacketExtraData> extraData)

      • addAudioDataInc

        public void addAudioDataInc​(byte[] data,
                            int offset,
                            int len)

      • addAudioData

        public void addAudioData​(byte[] data,
                         long timecode)
        Add audio data
        Parameters:
        data - data
        timecode - absolute timecode (milliseconds)

      • addAudioData

        public void addAudioData​(byte[] data,
                         int len,
                         long timecode)
        Add audio data
        Parameters:
        data - data
        len - data length
        timecode - absolute timecode (milliseconds)

      • addAudioData

        public void addAudioData​(byte[] data,
                         int offset,
                         int len,
                         long timecode)

      • addAudioData

        public void addAudioData​(byte[] data,
                         int offset,
                         int len,
                         long timecode,
                         java.util.Map<String,​IAMFPacketExtraData> extraData)
        Add audio data
        Parameters:
        data - data
        len - data length
        offset - offset
        timecode - absolute timecode (milliseconds)

      • addDataData

        public void addDataData​(byte[] data,
                        long timecode)
        Add metadata
        Parameters:
        data - data
        timecode - absolute timecode (milliseconds)

      • addDataData

        public void addDataData​(byte[] data,
                        int len,
                        long timecode)
        Add metadata
        Parameters:
        data - data
        len - data length
        timecode - absolute timecode (milliseconds)

      • addDataData

        public void addDataData​(byte[] data,
                        int offset,
                        int len,
                        long timecode)

      • addDataData

        public void addDataData​(byte[] data,
                        int offset,
                        int len,
                        long timecode,
                        java.util.Map<String,​IAMFPacketExtraData> extraData)
        Add metadata
        Parameters:
        data - data
        offset - offset
        len - data length
        timecode - absolute timecode (milliseconds)

      • startDataData

        public void startDataData​(int len,
                          long timecode)

      • startDataData

        public void startDataData​(int len,
                          long timecode,
                          java.util.Map<String,​IAMFPacketExtraData> extraData)

      • addDataDataInc

        public void addDataDataInc​(byte[] data,
                           int offset,
                           int len)

      • flush

        public void flush()
        Flush the packets from the input buffer to the output buffer

      • close

        public void close()
        Close the publisher

      • getMaxTimecode

        public long getMaxTimecode()
        Highest timecode written through this publisher (millseconds).
        Returns:
        highest timecode written through this publisher (millseconds)

      • getLastAudioTimecode

        public long getLastAudioTimecode()
        Get last audio timecode written through this publisher (millseconds).
        Returns:
        last audio timecode written through this publisher (millseconds).

      • getLastGapAudioTimecode

        public long getLastGapAudioTimecode()
        Get gap time from last audio timecode.
        Returns:
        gap time from audio timecode written throughtime this publisher (millseconds).

      • getLastVideoTimecode

        public long getLastVideoTimecode()
        Get last video timecode written through this publisher (millseconds).
        Returns:
        last video timecode written through this publisher (millseconds).

      • getLastGapVideoTimecode

        public long getLastGapVideoTimecode()
        Get gap time from last video timecode.
        Returns:
        gap time from video timecode written through this publisher (millseconds).

      • getLastDataTimecode

        public long getLastDataTimecode()
        Get last data timecode written through this publisher (millseconds).
        Returns:
        last data timecode written through this publisher (millseconds).

      • isPublishDataEvents

        public boolean isPublishDataEvents()

      • setPublishDataEvents

        public void setPublishDataEvents​(boolean publishDataEvents)