MyOflaDemo

package com.testing.myoflademo;


import java.io.IOException;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;

import org.red5.server.adapter.MultiThreadedApplicationAdapter;
import org.red5.server.api.IClient;
import org.red5.server.api.IConnection;
import org.red5.server.api.Red5;
import org.red5.server.api.scope.IScope;
import org.red5.server.api.service.IServiceCapableConnection;
import org.red5.server.api.stream.IBroadcastStream;
import org.red5.server.api.stream.IStreamAwareScopeHandler;
import org.red5.server.api.stream.ResourceExistException;
import org.red5.server.api.stream.ResourceNotFoundException;

public class Application extends MultiThreadedApplicationAdapter implements IStreamAwareScopeHandler {

	private List<String> streamsInRoom = new ArrayList<String>();

	@Override
	public boolean appStart(IScope scope) {
		System.out.println("[ appStart ]");
		return true;
	}

	@Override
	public boolean appConnect(IConnection conn, Object[] params) {
		System.out.println("[ appConnect ]");
		return true;
	}

	@Override
	public boolean appJoin(IClient client, IScope scope) {
		System.out.println("[ appJoin ]");
		return true;
	}

	public void streamPublishStart(IBroadcastStream stream) {
		System.out.println("[ streamPublishStart ]");
	}

	public void streamBroadcastStart(IBroadcastStream stream) {
    	System.out.println("[ streamBroadcastStart ]");
    	for (String streamName : streamsInRoom) {
    		((IServiceCapableConnection) Red5.getConnectionLocal()).invoke("newStreamInRoom", new Object[] {streamName});
    	}
    	streamsInRoom.add(stream.getPublishedName());
    	// Save stream
		try {
			stream.saveAs(stream.getName(), false);
		} catch (IOException | ResourceNotFoundException
				| ResourceExistException e) {
			e.printStackTrace();
		}
    	// Notifico a todos los usuarios menos el actual
    	IClient newClient = Red5.getConnectionLocal().getClient();
    	Iterator<IConnection> itConnections = Red5.getConnectionLocal().getScope().getClientConnections().iterator();
    	while(itConnections.hasNext()) {
    		IConnection conn = itConnections.next();
    		if (!conn.getClient().getId().equals(newClient.getId()) && conn instanceof IServiceCapableConnection) {
    			((IServiceCapableConnection) conn).invoke("newStreamInRoom", new Object[] {stream.getPublishedName()});
    		}
    	}
	}

    public void streamBroadcastClose(IBroadcastStream stream) {
    	System.out.println("[ streamBroadcastClose ]");
    	streamsInRoom.remove(stream.getPublishedName());
	}

}