// This Source Code is in the Public Domain per: http://unlicense.org
package org.litesoft.GWT.eventbus.server;

import org.litesoft.GWT.eventbus.client.*;
import org.litesoft.delayed.*;

/**
 * A simple, non-distributed Server implementation of an event bus.
 */
public class SimpleServerEventBus extends AbstractSimpleEventBus implements IServerEventBus
{
    public Type getType()
    {
        return Type.Simple;
    }

    public SimpleServerEventBus()
    {
        super( TimedRunnableManager.INSTANCE, LoggingUnexpectedEventPackageHandler.INSTANCE );
    }

    public void apply( ServerEventBusSubscriptionCollector pCollector )
    {
        if ( pCollector != null )
        {
            for ( ServerEventBusDisposeListener zListener : pCollector.getListeners() )
            {
                addListener( zListener );
            }
            subscribe( pCollector );
        }
    }

    public void addListener( ServerEventBusDisposeListener pServerEventBusDisposeListener )
    {
        throw noListenerSupport();
    }

    public void removeListener( ServerEventBusDisposeListener pServerEventBusDisposeListener )
    {
        throw noListenerSupport();
    }

    public ServerEventBusDisposeListener[] getServerEventBusDisposeListeners()
    {
        throw noListenerSupport();
    }

    private UnsupportedOperationException noListenerSupport()
    {
        return new UnsupportedOperationException(
                "ServerEventBusDisposeListener(s) not supported on SimpleServerEventBus" );
    }
}