Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   * Copyright 2011 JBoss, by Red Hat, Inc
   *
   * Licensed under the Apache License, Version 2.0 (the "License");
   * you may not use this file except in compliance with the License.
   * You may obtain a copy of the License at
   *
   *    http://www.apache.org/licenses/LICENSE-2.0
   *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
 package org.jboss.errai.enterprise.client.cdi;
 
 
The GWT entry point for the Errai CDI module.

Author(s):
Mike Brock <cbrock@redhat.com>
Christian Sadilek <csadilek@redhat.com>
 
 public class CDIClientBootstrap implements EntryPoint {
   private static final Logger logger = LoggerFactory.getLogger(CDIClientBootstrap.class);
 
   final static Runnable initRemoteCdiSubsystem = new Runnable() {
     @Override
     public void run() {
       .info("CDI subsystem syncing with server ...");
 
       BusErrorCallback serverDispatchErrorCallback = new BusErrorCallback() {
         @Override
         public boolean error(Message messageThrowable throwable) {
           try {
             throw throwable;
           }
           catch (NoSubscribersToDeliverTo e) {
             .warn("Server did not subscribe to " + . +
                 ". To activate the full Errai CDI functionality, make sure that Errai's Weld " +
                 "integration module has been deployed on the server.");
             CDI.activate();
             return false;
           }
           catch (Throwable t) {
             return true;
           }
         }
       };
 
       MessageBuilder.createMessage().toSubject(.)
           .command(.)
           .errorsHandledBy(serverDispatchErrorCallback)
           .sendNowWith(ErraiBus.get());
 
 
       CDI.fireEvent(new BusReadyEvent());
     }
 
     @Override
     public String toString() {
       return "BusReadyEvent";
     }
   };
 
   final static Runnable declareServices = new Runnable() {
     @Override
     public void run() {
       final ClientMessageBusImpl bus = (ClientMessageBusImpl) ErraiBus.get();
       if (!bus.isSubscribed(.)) {
         .info("declare CDI dispatch service");
         bus.subscribe(.new MessageCallback() {
           @Override
           public void callback(final Message message) {
             switch (CDICommands.valueOf(message.getCommandType())) {
             case :
                 CDI.activate(message.get(String.class.).split(","));
                 break;
 
               case :
                CDI.addRemoteEventTypes(message.get(String[].class.));
                break;
              case :
                CDI.consumeEventFromMessage(message);
                break;
              }
            }
        });
      }
    }
  };
  public void onModuleLoad() {
    InitVotes.waitFor(CDI.class);
    if (BusToolsCli.isRemoteCommunicationEnabled()) {
    }
    else {
      CDI.activate();
      CDI.fireEvent(new BusReadyEvent());
    }
  }
New to GrepCode? Check out our FAQ X