123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180 |
- /*
- @VaadinApache2LicenseForJavaFiles@
- */
- package com.vaadin.terminal.gwt.client.ui;
-
- import java.util.ArrayList;
- import java.util.Collection;
- import java.util.Collections;
- import java.util.HashMap;
- import java.util.Map;
-
- import com.google.gwt.event.shared.GwtEvent;
- import com.google.gwt.event.shared.HandlerManager;
- import com.google.gwt.event.shared.HandlerRegistration;
- import com.vaadin.terminal.gwt.client.ApplicationConnection;
- import com.vaadin.terminal.gwt.client.ServerConnector;
- import com.vaadin.terminal.gwt.client.Util;
- import com.vaadin.terminal.gwt.client.VConsole;
- import com.vaadin.terminal.gwt.client.communication.ClientRpc;
- import com.vaadin.terminal.gwt.client.communication.StateChangeEvent;
- import com.vaadin.terminal.gwt.client.communication.StateChangeEvent.StateChangeHandler;
-
- /**
- * An abstract implementation of Connector.
- *
- * @author Vaadin Ltd
- * @version @VERSION@
- * @since 7.0.0
- *
- */
- public abstract class AbstractConnector implements ServerConnector,
- StateChangeHandler {
-
- private ApplicationConnection connection;
- private String id;
-
- private HandlerManager handlerManager;
- private Map<String, Collection<ClientRpc>> rpcImplementations;
-
- /*
- * (non-Javadoc)
- *
- * @see com.vaadin.terminal.gwt.client.VPaintable#getConnection()
- */
- public final ApplicationConnection getConnection() {
- return connection;
- }
-
- /*
- * (non-Javadoc)
- *
- * @see com.vaadin.terminal.gwt.client.Connector#getId()
- */
- public String getConnectorId() {
- return id;
- }
-
- /**
- * Called once by the framework to initialize the connector.
- * <p>
- * Note that the shared state is not yet available when this method is
- * called.
- * <p>
- * Connector classes should override {@link #init()} instead of this method.
- */
- public final void doInit(String connectorId,
- ApplicationConnection connection) {
- this.connection = connection;
- id = connectorId;
-
- addStateChangeHandler(this);
- init();
- }
-
- /**
- * Called when the connector has been initialized. Override this method to
- * perform initialization of the connector.
- */
- // FIXME: It might make sense to make this abstract to force users to
- // use init instead of constructor, where connection and id has not yet been
- // set.
- protected void init() {
-
- }
-
- /**
- * Registers an implementation for a server to client RPC interface.
- *
- * Multiple registrations can be made for a single interface, in which case
- * all of them receive corresponding RPC calls.
- *
- * @param rpcInterface
- * RPC interface
- * @param implementation
- * implementation that should receive RPC calls
- * @param <T>
- * The type of the RPC interface that is being registered
- */
- protected <T extends ClientRpc> void registerRpc(Class<T> rpcInterface,
- T implementation) {
- String rpcInterfaceId = rpcInterface.getName().replaceAll("\\$", ".");
- if (null == rpcImplementations) {
- rpcImplementations = new HashMap<String, Collection<ClientRpc>>();
- }
- if (null == rpcImplementations.get(rpcInterfaceId)) {
- rpcImplementations.put(rpcInterfaceId, new ArrayList<ClientRpc>());
- }
- rpcImplementations.get(rpcInterfaceId).add(implementation);
- }
-
- /**
- * Unregisters an implementation for a server to client RPC interface.
- *
- * @param rpcInterface
- * RPC interface
- * @param implementation
- * implementation to unregister
- */
- protected <T extends ClientRpc> void unregisterRpc(Class<T> rpcInterface,
- T implementation) {
- String rpcInterfaceId = rpcInterface.getName().replaceAll("\\$", ".");
- if (null != rpcImplementations
- && null != rpcImplementations.get(rpcInterfaceId)) {
- rpcImplementations.get(rpcInterfaceId).remove(implementation);
- }
- }
-
- public <T extends ClientRpc> Collection<T> getRpcImplementations(
- String rpcInterfaceId) {
- if (null == rpcImplementations) {
- return Collections.emptyList();
- }
- return (Collection<T>) rpcImplementations.get(rpcInterfaceId);
- }
-
- /*
- * (non-Javadoc)
- *
- * @see com.vaadin.terminal.gwt.client.Connector#isConnectorEnabled()
- */
- public boolean isConnectorEnabled() {
- // Client side can always receive message from the server
- return true;
- }
-
- public void fireEvent(GwtEvent<?> event) {
- if (handlerManager != null) {
- handlerManager.fireEvent(event);
- }
- }
-
- protected HandlerManager ensureHandlerManager() {
- if (handlerManager == null) {
- handlerManager = new HandlerManager(this);
- }
-
- return handlerManager;
- }
-
- public HandlerRegistration addStateChangeHandler(StateChangeHandler handler) {
- return ensureHandlerManager()
- .addHandler(StateChangeEvent.TYPE, handler);
- }
-
- public void onStateChanged(StateChangeEvent stateChangeEvent) {
- VConsole.log("State change event for "
- + Util.getConnectorString(stateChangeEvent.getConnector())
- + " received by " + Util.getConnectorString(this));
- }
-
- /*
- * (non-Javadoc)
- *
- * @see com.vaadin.terminal.gwt.client.ServerConnector#onUnregister()
- */
- public void onUnregister() {
- VConsole.log("Unregistered connector " + Util.getConnectorString(this));
-
- }
- }
|