Package io.antmedia.streamsource

Class RTMPClusterStreamFetcher

java.lang.Object

io.antmedia.streamsource.RTMPClusterStreamFetcher

public class RTMPClusterStreamFetcher
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	RTMPClusterStreamFetcher.RtmpFetcherThread

Field Summary

Fields

Modifier and Type	Field	Description
private AppSettings	appSettings
(package private) int	checkNumberOfViewers
private AtomicBoolean	finishing
private org.slf4j.Logger	logger
RtmpProvider	rtmpProvider
private String	rtmpUrl
private IScope	scope
private StreamFetcher.IStreamFetcherListener	streamFetcherListener
private String	streamId
private RTMPClusterStreamFetcher.RtmpFetcherThread	thread
private AtomicBoolean	threadActive
private io.vertx.core.Vertx	vertx

Constructor Summary

Constructors

Constructor	Description
RTMPClusterStreamFetcher(String streamUrl, String streamId, IScope scope)

Method Summary

Modifier and Type	Method	Description
AppSettings	getAppSettings()
RtmpProvider	getRtmpProvider()
String	getStreamUrl()
AtomicBoolean	getThreadActive()
RtmpProvider	initRtmpProvider(org.bytedeco.ffmpeg.avutil.AVRational videoTimeBase, org.bytedeco.ffmpeg.avutil.AVRational audioTimeBase)
boolean	isFinishing()
void	setCheckNumberOfViewers(int checkNumberOfViewers)
void	setRtmpProvider(RtmpProvider rtmpProvider)
void	setStreamFetcherListener(StreamFetcher.IStreamFetcherListener streamFetcherListener)
void	setThreadActive(boolean threadActive)
void	startStream()
boolean	stopIfNoViewer()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

rtmpUrl

private String rtmpUrl

scope

private IScope scope

vertx

private io.vertx.core.Vertx vertx

rtmpProvider

public RtmpProvider rtmpProvider

appSettings

private AppSettings appSettings

logger

private org.slf4j.Logger logger

thread

private RTMPClusterStreamFetcher.RtmpFetcherThread thread

threadActive

private AtomicBoolean threadActive

streamFetcherListener

private StreamFetcher.IStreamFetcherListener streamFetcherListener

streamId

private String streamId

checkNumberOfViewers

int checkNumberOfViewers

finishing

private AtomicBoolean finishing

Constructor Details

RTMPClusterStreamFetcher

public RTMPClusterStreamFetcher(String streamUrl,
 String streamId,
 IScope scope)

Method Details

initRtmpProvider

public RtmpProvider initRtmpProvider(org.bytedeco.ffmpeg.avutil.AVRational videoTimeBase,
 org.bytedeco.ffmpeg.avutil.AVRational audioTimeBase)

isFinishing

public boolean isFinishing()

getAppSettings

public AppSettings getAppSettings()

setStreamFetcherListener

public void setStreamFetcherListener(StreamFetcher.IStreamFetcherListener streamFetcherListener)

getStreamUrl

public String getStreamUrl()

setThreadActive

public void setThreadActive(boolean threadActive)

getThreadActive

public AtomicBoolean getThreadActive()

startStream

public void startStream()

getRtmpProvider

public RtmpProvider getRtmpProvider()

setRtmpProvider

public void setRtmpProvider(RtmpProvider rtmpProvider)

setCheckNumberOfViewers

public void setCheckNumberOfViewers(int checkNumberOfViewers)

stopIfNoViewer

public boolean stopIfNoViewer()