Package io.antmedia.console

Class AdminApplication

java.lang.Object

org.red5.server.adapter.AbstractScopeAdapter

org.red5.server.adapter.StatefulScopeWrappingAdapter

org.red5.server.adapter.MultiThreadedApplicationAdapter

io.antmedia.console.AdminApplication

All Implemented Interfaces:

IEventHandler, IAttributeStore, ISchedulingService, IScopeAware, IScopeHandler, IScopeService, IBroadcastStreamService, IOnDemandStreamService, IStreamSecurityService, ISubscriberStreamService, IStreamAwareScopeHandler, ApplicationMXBean, AttributeStoreMXBean

public class AdminApplication
extends MultiThreadedApplicationAdapter

Sample application that uses the client manager.

Author:

The Red5 Project ([email protected])

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AdminApplication.ApplicationInfo
static class	AdminApplication.BroadcastInfo

Field Summary

Fields

Modifier and Type	Field	Description
static final String	APP_NAME
private IClusterNotifier	clusterNotifier
static final String	CREATE_APP_COMMAND
private Queue<String>	currentApplicationCreationProcesses
private ConsoleDataStoreFactory	dataStoreFactory
static final String	DELETE_APP_COMMAND
static final String	ENABLE_SSL_COMMAND
private boolean	isCluster
private static final int	JWT_TOKEN_TIMEOUT_MS
private static final org.slf4j.Logger	log
private IScope	rootScope
private io.vertx.core.Vertx	vertx
private WarDeployer	warDeployer

Fields inherited from class org.red5.server.adapter.MultiThreadedApplicationAdapter

logger, schedulingService

Fields inherited from class org.red5.server.adapter.StatefulScopeWrappingAdapter

plugins, scope

Fields inherited from interface org.red5.server.api.service.IBroadcastStreamService

BROADCAST_STREAM_SERVICE

Fields inherited from interface org.red5.server.api.service.IOnDemandStreamService

BEAN_NAME

Fields inherited from interface org.red5.server.api.scheduling.ISchedulingService

BEAN_NAME

Fields inherited from interface org.red5.server.api.service.IStreamSecurityService

BEAN_NAME

Fields inherited from interface org.red5.server.api.service.ISubscriberStreamService

BEAN_NAME

Constructor Summary

Constructors

Constructor	Description
AdminApplication()

Method Summary

Modifier and Type	Method	Description
boolean	appStart(IScope app)	Called once on scope (that is, application or application room) start.
boolean	connect(IConnection conn, IScope scope, Object[] params)	Returns connection result for given scope and parameters.
boolean	createApplication(String appName, String warFileFullPath)
boolean	createApplicationWithURL(String appName, String warFileURI, String secretKey)
boolean	deleteApplication(String appName, boolean deleteDB)
boolean	deleteVoDStream(String appname, String streamName)
void	disconnect(IConnection conn, IScope scope)	Returns disconnection result for given scope and parameters.
File	downloadWarFile(String appName, String warFileUrl, String jwtSecretKey)
AntMediaApplicationAdapter	getApplicationAdaptor(IScope appScope)
ApplicationContext	getApplicationContext(String scopeName)
List<AdminApplication.ApplicationInfo>	getApplicationInfo()
List<String>	getApplications()
int	getAppLiveStreamCount(IScope appScope)
List<AdminApplication.BroadcastInfo>	getAppLiveStreams(String name)
IClusterNotifier	getClusterNotifier()
Queue<String>	getCurrentApplicationCreationProcesses()
ConsoleDataStoreFactory	getDataStoreFactory()
static long	getDirectorySize(Path dir)
org.apache.http.impl.client.CloseableHttpClient	getHttpClient()
static String	getJavaTmpDirectory()
IScope	getRootScope()
private IScope	getScope(String scopeName)
private IScope	getScopes(IGlobalScope root, String scopeName)	Gt only application scope
int	getTotalConnectionSize()
int	getTotalLiveStreamSize()
int	getVoDCount(IScope appScope)
static File	getWarFileInTmpDirectory(String warFileName)
static String	getWarName(String appName)
boolean	runConfiguredCommand(String configuredCommand, String... args)
boolean	runCreateAppScript(String appName)
boolean	runCreateAppScript(String appName, boolean isCluster, String dbConnectionUrl, String warFileName)
boolean	runDeleteAppScript(String appName)
static File	saveWARFile(String appName, InputStream inputStream)
void	setDataStoreFactory(ConsoleDataStoreFactory dataStoreFactory)
void	setVertx(io.vertx.core.Vertx vertx)
void	setWarDeployer(WarDeployer warDeployer)

Methods inherited from class org.red5.server.adapter.MultiThreadedApplicationAdapter

addListener, addScheduledJob, addScheduledJobAfterDelay, addScheduledOnceJob, addScheduledOnceJob, appConnect, appDisconnect, appJoin, appLeave, appStop, connect, FCPublish, FCSubscribe, FCUnpublish, FCUnpublish, getBroadcastStream, getBroadcastStreamNames, getClientTTL, getGhostConnsCleanupPeriod, getListeners, getOnDemandStream, getScheduledJobNames, getStreamLength, getStreamPlaybackSecurity, getStreamPublishSecurity, getSubscriberStream, handleEvent, hasBroadcastStream, hasOnDemandStream, join, leave, measureBandwidth, measureBandwidth, pauseScheduledJob, registerStreamPlaybackSecurity, registerStreamPublishSecurity, rejectClient, rejectClient, removeListener, removeScheduledJob, resumeScheduledJob, roomConnect, roomDisconnect, roomJoin, roomLeave, roomStart, roomStop, setClientTTL, setGhostConnsCleanupPeriod, start, startTransmit, stop, stopTransmit, stopTransmit, streamBroadcastClose, streamBroadcastStart, streamPlayItemPause, streamPlayItemPlay, streamPlayItemResume, streamPlayItemSeek, streamPlayItemStop, streamPublishStart, streamRecordStart, streamRecordStop, streamSubscriberClose, streamSubscriberStart, unregisterStreamPlaybackSecurity, unregisterStreamPublishSecurity

Methods inherited from class org.red5.server.adapter.StatefulScopeWrappingAdapter

createChildScope, getAttribute, getAttribute, getAttributeNames, getAttributes, getChildScope, getChildScopeNames, getClients, getConnections, getContext, getDepth, getName, getParent, getPath, getPlugins, getResource, getResources, getScope, hasAttribute, hasChildScope, hasParent, lookupConnections, removeAttribute, removeAttributes, setAttribute, setAttributes, setAttributes, setPlugins, setScope, size

Methods inherited from class org.red5.server.adapter.AbstractScopeAdapter

addChildScope, checkBandwidth, checkBandwidthUp, removeChildScope, serviceCall, setCanCallService, setCanConnect, setCanStart, setJoin

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.red5.server.api.scope.IScopeHandler

addChildScope, removeChildScope, serviceCall

Field Details

JWT_TOKEN_TIMEOUT_MS

private static final int JWT_TOKEN_TIMEOUT_MS

See Also:

• Constant Field Values

CREATE_APP_COMMAND

public static final String CREATE_APP_COMMAND

See Also:

• Constant Field Values

DELETE_APP_COMMAND

public static final String DELETE_APP_COMMAND

See Also:

• Constant Field Values

ENABLE_SSL_COMMAND

public static final String ENABLE_SSL_COMMAND

See Also:

• Constant Field Values

log

private static final org.slf4j.Logger log

APP_NAME

public static final String APP_NAME

See Also:

• Constant Field Values

dataStoreFactory

private ConsoleDataStoreFactory dataStoreFactory

rootScope

private IScope rootScope

vertx

private io.vertx.core.Vertx vertx

warDeployer

private WarDeployer warDeployer

isCluster

private boolean isCluster

clusterNotifier

private IClusterNotifier clusterNotifier

currentApplicationCreationProcesses

private Queue<String> currentApplicationCreationProcesses

Constructor Details

AdminApplication

public AdminApplication()

Method Details

appStart

public boolean appStart(IScope app)

Description copied from class: MultiThreadedApplicationAdapter

Called once on scope (that is, application or application room) start. You override MultiThreadedApplicationAdapter.appStart(IScope) or MultiThreadedApplicationAdapter.roomStart(IScope) in your application to make it act the way you want.

Specified by:

appStart in interface ApplicationMXBean

Overrides:

appStart in class MultiThreadedApplicationAdapter

Parameters:

app - Application scope object

Returns:

true if scope can be started, false otherwise

createApplicationWithURL

public boolean createApplicationWithURL(String appName,
 String warFileURI,
 String secretKey)

connect

public boolean connect(IConnection conn,
 IScope scope,
 Object[] params)

Returns connection result for given scope and parameters. Whether the scope is room or app level scope, this method distinguishes it and acts accordingly. You override MultiThreadedApplicationAdapter.appConnect(IConnection, Object[]) or MultiThreadedApplicationAdapter.roomConnect(IConnection, Object[]) in your application to make it act the way you want.

Specified by:

connect in interface IScopeHandler

Overrides:

connect in class MultiThreadedApplicationAdapter

Parameters:

conn - Connection object

scope - Scope

params - List of params passed to connection handler

Returns:

true if connect is successful, false otherwise

disconnect

public void disconnect(IConnection conn,
 IScope scope)

Returns disconnection result for given scope and parameters. Whether the scope is room or app level scope, this method distinguishes it and acts accordingly.

Specified by:

disconnect in interface IScopeHandler

Overrides:

disconnect in class MultiThreadedApplicationAdapter

Parameters:

conn - Connection object

scope - Scope

getRootScope

public IScope getRootScope()

getTotalLiveStreamSize

public int getTotalLiveStreamSize()

getApplicationInfo

public List<AdminApplication.ApplicationInfo> getApplicationInfo()

getApplicationAdaptor

public AntMediaApplicationAdapter getApplicationAdaptor(IScope appScope)

getDirectorySize

public static long getDirectorySize(Path dir)

getVoDCount

public int getVoDCount(IScope appScope)

getAppLiveStreams

public List<AdminApplication.BroadcastInfo> getAppLiveStreams(String name)

deleteVoDStream

public boolean deleteVoDStream(String appname,
 String streamName)

getApplications

public List<String> getApplications()

getTotalConnectionSize

public int getTotalConnectionSize()

getApplicationContext

public ApplicationContext getApplicationContext(String scopeName)

getScope

private IScope getScope(String scopeName)

getScopes

private IScope getScopes(IGlobalScope root,
 String scopeName)

Gt only application scope

Parameters:

root -

scopeName -

Returns:

IScope the requested scope

getDataStoreFactory

public ConsoleDataStoreFactory getDataStoreFactory()

setDataStoreFactory

public void setDataStoreFactory(ConsoleDataStoreFactory dataStoreFactory)

getAppLiveStreamCount

public int getAppLiveStreamCount(IScope appScope)

createApplication

public boolean createApplication(String appName,
 String warFileFullPath)

getCurrentApplicationCreationProcesses

public Queue<String> getCurrentApplicationCreationProcesses()

getJavaTmpDirectory

public static String getJavaTmpDirectory()

getWarFileInTmpDirectory

public static File getWarFileInTmpDirectory(String warFileName)

getWarName

public static String getWarName(String appName)

saveWARFile

@Nullable
public static File saveWARFile(String appName,
 InputStream inputStream)

getHttpClient

public org.apache.http.impl.client.CloseableHttpClient getHttpClient()

downloadWarFile

public File downloadWarFile(String appName,
 String warFileUrl,
 String jwtSecretKey)
                     throws IOException

Throws:

IOException

deleteApplication

public boolean deleteApplication(String appName,
 boolean deleteDB)

runCreateAppScript

public boolean runCreateAppScript(String appName)

runCreateAppScript

public boolean runCreateAppScript(String appName,
 boolean isCluster,
 String dbConnectionUrl,
 String warFileName)

runDeleteAppScript

public boolean runDeleteAppScript(String appName)

getClusterNotifier

public IClusterNotifier getClusterNotifier()

runConfiguredCommand

public boolean runConfiguredCommand(String configuredCommand,
 String... args)

setVertx

public void setVertx(io.vertx.core.Vertx vertx)

setWarDeployer

public void setWarDeployer(WarDeployer warDeployer)