Package com.wowza.wms.pushpublish.protocol.rtp

Class PushPublishRTP

Object
com.wowza.wms.pushpublish.model.PushPublishBase
com.wowza.wms.pushpublish.protocol.rtp.PushPublishRTP
All Implemented Interfaces:
IPushPublish
public class PushPublishRTP extends PushPublishBase
The Class PushPublishRTP.

  • Field Details

    • CLASS

      public static final Class<PushPublishRTP> CLASS

    • CLASSNAME

      public static final String CLASSNAME
      See Also:

    • SDPFILEEXTENSION

      public static final String SDPFILEEXTENSION
      The Constant SDPFILEEXTENSION.
      See Also:

    • rtpPushPublishSession

      protected RTPPushPublishSession rtpPushPublishSession
      The rtp push publish session.

    • singleStreamAV

      protected boolean singleStreamAV
      The stream packetizer.

    • audioPort

      protected int audioPort
      The audio port.

    • videoPort

      protected int videoPort
      The video port.

    • audioHost

      protected String audioHost
      The audio host.

    • videoHost

      protected String videoHost
      The video host.

    • isRTPWrapped

      protected boolean isRTPWrapped
      The is rtp wrapped.

    • writeSDPFiles

      protected boolean writeSDPFiles
      The write sdp files.

    • removeSDPFiles

      protected boolean removeSDPFiles
      The remove sdp files

    • multicastInterfaceAddress

      protected String multicastInterfaceAddress

    • mRtpDestination

      protected RTPDestination mRtpDestination
      The m rtp destination.

    • lock

      protected Object lock

  • Constructor Details

    • PushPublishRTP

      public PushPublishRTP() throws com.wowza.wms.server.LicensingException
      Throws:
      com.wowza.wms.server.LicensingException

  • Method Details

    • init

      public void init(IApplicationInstance appInstance, String streamName, IMediaStream stream, Map<String,String> profileData, Map<String,String> maps, com.wowza.wms.pushpublish.manager.IPushPublisher pushPublisher, boolean debug)
      Description copied from class: PushPublishBase
      Inits the instance.
      Specified by:
      init in interface IPushPublish
      Overrides:
      init in class PushPublishBase
      Parameters:
      appInstance - the app instance
      streamName - the source stream name
      profileData - the profile params
      maps - the map entry params
      debug - stream debug flag

    • connect

      public void connect()

    • disconnect

      public void disconnect()

    • disconnect

      public void disconnect(boolean hard)

    • resetConnection

      public void resetConnection()

    • resetConnection

      public void resetConnection(int delay)

    • getRTPPushPublishSession

      public RTPPushPublishSession getRTPPushPublishSession()
      Gets the rTP push publish session.
      Returns:
      the rTP push publish session

    • setRTPPushPublishSession

      public void setRTPPushPublishSession(RTPPushPublishSession rtpPushPublishSession)
      Sets the rTP push publish session.
      Parameters:
      rtpPushPublishSession - the new rTP push publish session

    • getAppInstance

      public IApplicationInstance getAppInstance()
      Description copied from class: PushPublishBase
      Get appInstance interface.
      Overrides:
      getAppInstance in class PushPublishBase
      Returns:
      appInstance interface

    • setAppInstance

      public void setAppInstance(IApplicationInstance appInstance)
      Description copied from class: PushPublishBase
      Set appInstance interface.
      Overrides:
      setAppInstance in class PushPublishBase
      Parameters:
      appInstance - appInstance interface

    • isSingleStreamAV

      public boolean isSingleStreamAV()
      Checks if is stream is packatized.
      Returns:
      true, if is stream packetizer

    • setSingleStreamAV

      public void setSingleStreamAV(boolean inSingleStreamAV)
      Sets the stream packetizer.
      Parameters:
      inSingleStreamAV - whether stream is packatized

    • setSingleStreamAV

      public void setSingleStreamAV(String inSingleStreamAV)

    • getHostname

      public String getHostname()
      Description copied from class: PushPublishBase
      Get destination server host name.
      Specified by:
      getHostname in interface IPushPublish
      Overrides:
      getHostname in class PushPublishBase
      Returns:
      destination server host name

    • setHostname

      public void setHostname(String hostname)
      Specified by:
      setHostname in interface IPushPublish
      Overrides:
      setHostname in class PushPublishBase

    • setPort

      public void setPort(int port)
      Set destination server port.
      Specified by:
      setPort in interface IPushPublish
      Overrides:
      setPort in class PushPublishBase
      Parameters:
      port - destination server port

    • setPort

      public void setPort(String portIn)
      Description copied from class: PushPublishBase
      Set destination server port.
      Specified by:
      setPort in interface IPushPublish
      Overrides:
      setPort in class PushPublishBase
      Parameters:
      portIn - destination server port

    • getAudioPort

      public int getAudioPort()
      Gets the audio port.
      Returns:
      the audio port

    • setAudioPort

      public void setAudioPort(int audioPort)
      Sets the audio port.
      Parameters:
      audioPort - the new audio port

    • setVideoPort

      public void setVideoPort(int videoPort)

    • getAudioHost

      public String getAudioHost()
      Gets the audio host.
      Returns:
      the audio host

    • setAudioHost

      public void setAudioHost(String audioHost)
      Sets the audio host.
      Parameters:
      audioHost - the new audio host

    • getVideoHost

      public String getVideoHost()
      Gets the video host.
      Returns:
      the video host

    • setVideoHost

      public void setVideoHost(String videoHost)
      Sets the video host.
      Parameters:
      videoHost - the new video host

    • setAudioPort

      public void setAudioPort(String audioPort)
      Sets the audio port.
      Parameters:
      audioPort - the new audio port

    • getVideoPort

      public int getVideoPort()
      Gets the video port.
      Returns:
      the video port

    • setVideoPort

      public void setVideoPort(String videoPort)
      Sets the video port.
      Parameters:
      videoPort - the new video port

    • isRTPWrapped

      public boolean isRTPWrapped()
      Checks if is rTP wrapped.
      Returns:
      true, if is rTP wrapped

    • setRTPWrapped

      public void setRTPWrapped(String string)
      Sets the rTP wrapped.
      Parameters:
      string - the new rTP wrapped

    • getHostType

      public String getHostType()
      Gets the host type.
      Returns:
      the host type

    • setHostType

      public void setHostType(String hostType)
      Sets the host type.
      Parameters:
      hostType - the new host type

    • setTimeToLive

      public void setTimeToLive(String ttl)
      Sets the time to live.
      Parameters:
      ttl - the new time to live

    • getTimeToLive

      public int getTimeToLive()
      Gets the time to live.
      Returns:
      the time to live

    • load

      public void load(HashMap<String,String> dataMap)
      Description copied from class: PushPublishBase
      Loads map and profile parameters
      Overrides:
      load in class PushPublishBase
      Parameters:
      dataMap - the data map

    • getRtpStreamWaitTimeout

      public long getRtpStreamWaitTimeout()

    • setRtpStreamWaitTimeout

      public void setRtpStreamWaitTimeout(String rtpStreamWaitTimeout)

    • setRtpStreamWaitTimeout

      public void setRtpStreamWaitTimeout(long rtpStreamWaitTimeout)

    • createPushPublishSession

      public IPushPublishSession createPushPublishSession()
      Specified by:
      createPushPublishSession in interface IPushPublish
      Overrides:
      createPushPublishSession in class PushPublishBase

    • getContextStr

      public String getContextStr()
      Specified by:
      getContextStr in interface IPushPublish
      Specified by:
      getContextStr in class PushPublishBase

    • getmRtpDestination

      public RTPDestination getmRtpDestination()

    • getConnectedState

      public int getConnectedState()

    • setConnectionStatus

      public void setConnectionStatus(Boolean connected)

    • getMessagesAttemptedCount

      public long getMessagesAttemptedCount()

    • getMessagesRetriedCount

      public long getMessagesRetriedCount()

    • getMessagesFailedCount

      public long getMessagesFailedCount()

    • add

      public void add(IOPerformanceCounter totalValue)
      Overrides:
      add in class PushPublishBase

    • addIOPerformance2

      public void addIOPerformance2(IOPerformanceCounter totalIOPerformanceResult)
      Overrides:
      addIOPerformance2 in class PushPublishBase

    • isWriteSDPFiles

      public boolean isWriteSDPFiles()

    • setWriteSDPFiles

      public void setWriteSDPFiles(boolean writeSDPFiles)

    • isRemoveSDPFiles

      public boolean isRemoveSDPFiles()

    • setRemoveSDPFiles

      public void setRemoveSDPFiles(boolean removeSDPFiles)

    • setRTPWrapped

      public void setRTPWrapped(boolean isRTPWrapped)

    • getMulticastInterfaceAddress

      public String getMulticastInterfaceAddress()

    • setMulticastInterfaceAddress

      public void setMulticastInterfaceAddress(String multicastInterfaceAddress)