// 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" );
    }
}