Send 'APP_START' to any plugins that listen for it, and loop around
        waiting for messages and sending them to their listening plugins until
        it's time to shutdown.
505484
def start(self):
        
        self.recieve('APP_START')
        self.alive = True
        while self.alive:
            message, payload = self.messages.get()
            if message == 'APP_STOP':
                for plugin in self.plugins:
                    plugin.recieve('SHUTDOWN')
                self.alive = False
            else:
                self.recieve(message, payload)
1078528
def _app_base_start(self, option: str, args: list or tuple) -> None:
        '''
        
        '''
        _, error = self._execute('-s', self.device_sn,
                                 'shell', 'am', 'start', option, *args)
        if error and error.startswith('Error'):
            raise ApplicationsException(error.split(':', 1)[-1].strip())
741078
function _firePause()
        {
            exec(
                    function ()
                    {
                        window.console.log(JS_HANDLE
                                + ": fired pause event to native plugin");
                    },
                    _logError,
                    CDV_HANDLE,
                    CDV_HANDLE_ACTIONS.APP_PAUSED,
                    []
            );
        }
104932
void start(final Context context) {
		checkConversationQueue();

		ApptentiveLog.i(TROUBLESHOOT, "Overriding log level: " + VERBOSE);
		oldLogLevel = ApptentiveLog.getLogLevel();
		ApptentiveLog.overrideLogLevel(VERBOSE);

		// show debug notification
		showDebugNotification(context);
	}
447425
def restart_listener(self, topics):
        '''
        '''
        if self.listener is not None:
            if self.listener.running:
                self.stop()
        self.__init__(topics=topics)
95504
def init_app(self, app):
        '''
        
        '''
        self.app = app
        if not hasattr(app, 'extensions'):
            app.extensions = {}
        app.extensions['plugin_manager'] = self
        self.reload()
966324
function runApp (appDir, appName) {
    var binPath = path.join(appDir, 'Contents', 'MacOS', appName);
    events.emit('log', 'Starting: ' + binPath);
    return spawn(binPath);
}
689249
def app_start_service(self, *args) -> None:
        ''''''
        _, error = self._execute('-s', self.device_sn,
                                 'shell', 'am', 'startservice', *args)
        if error and error.startswith('Error'):
            raise ApplicationsException(error.split(':', 1)[-1].strip())
1374220
def on_app_shutdown(self, app):
        ''''''

        if self.filewatcher:
            self.filewatcher.stop()
        if self.profile:
            self.upload_page.on_destroy()
            self.download_page.on_destroy()
684163
def listen_init(self):
        """"""
        self.dispatcher = ObjectDispatch(self)
        self.factory = MsgPackProtocolFactory(self.dispatcher)
        self.server = UnixServer(self.loop, self.factory, self.path)
        self.server.start()
1099861
def start(self):
        
        if self._shutdown:
            raise ShutdownError()

        self.read_watcher.start()
        logger.info("server started listening on {}".format(self.address))
1318647
def start(self):
        
        if not self.thread_started:
            super(SkypeAPI, self).start()
            self.thread_started = True
368233
function doPluginTask(owner, taskCallback) {
        var plugins = grunt.config.get('app_plugins_work_plugins');
        var plugin;
        if (!!plugins && 0 < plugins.length) {
            plugin = plugins.shift();
            // update variable.
            grunt.config.set('app_plugins_work_plugins', plugins);
            taskCallback(plugin);
            grunt.task.run(owner.nameArgs);
        }
    }
1077947
def register(self, plugin):
        
        for listener in plugin.listeners:
            self.listeners[listener].add(plugin)
        self.plugins.add(plugin)
        plugin.messenger = self.messages
        plugin.start()
732662
def on_message(self, started_waiting):
        
        watcher = self.settings.watcher
        if started_waiting:
            watcher.start_waiting()
        else:
            watcher.done_waiting()
497748
public static void waitForAppStart(String appName, String className, LibertyServer server) {
        LOG.info("Setup : wait for the app startup complete (CWWKZ0001I) message for " + appName);

        String appStarted = server.waitForStringInLog("CWWKZ0001I.* " + appName, APP_STARTUP_TIMEOUT);
        if (appStarted == null) {
            Assert.fail(className + ": application " + appName + " failed to start within " + APP_STARTUP_TIMEOUT +"ms");
        }
    }
166046
private void firePluginStarted(final Plugin plugin) {
        PluginEvent e = null;
        synchronized (listenerList) {
            for (Iterator iter = listenerList.iterator(); iter.hasNext();) {
                PluginListener l = (PluginListener) iter.next();
                if (e == null) {
                    e = new PluginEvent(plugin);
                }
                l.pluginStarted(e);
            }
        }
    }