Examples of org.jboss.errai.bus.client.api.MessageCallback

org.jboss.errai.bus.client.api.MessageCallback
A MessageCallback defines an interface for receiving messages on the bus.

    transmissionbuffer = buffer;


    /**
     * Define the default ServerBus service used for intrabus communication.
     */
    subscribe(BuiltInServices.ServerBus.name(), new MessageCallback() {
      @Override
      @SuppressWarnings({"unchecked", "SynchronizationOnLocalVariableOrMethodParameter"})
      public void callback(final Message message) {
        try {
          final QueueSession session = getSession(message);

View Full Code Here

                                  final MessageCallback callback,
                                  final boolean local,
                                  final WrappedCallbackHolder callbackHolder) {
    final boolean isNew = !isSubscribed(subject);


    final MessageCallback cb = new MessageCallback() {
      @Override
      public void callback(final Message message) {
        try {
          callback.callback(message);
        }

View Full Code Here


    if (isRemoteCommunicationEnabled()) {
      remoteSubscribe(BuiltInServices.ServerEchoService.name());
    }


    directSubscribe(BuiltInServices.ClientBus.name(), new MessageCallback() {
      @Override
      @SuppressWarnings({"unchecked"})
      public void callback(final Message message) {
        switch (BusCommands.valueOf(message.getCommandType())) {
          case RemoteSubscribe:
            if (message.hasPart(MessageParts.SubjectsList)) {
              LogUtil.log("remote services available: " + message.get(List.class, MessageParts.SubjectsList));


              for (final String subject : (List<String>) message.get(List.class, MessageParts.SubjectsList)) {
                remoteSubscribe(subject);
              }
            }
            else {
              remoteSubscribe(message.get(String.class, Subject));
            }
            break;


          case RemoteUnsubscribe:
            unsubscribeAll(message.get(String.class, Subject));
            break;


          case CapabilitiesNotice:
            LogUtil.log("received capabilities notice from server. supported capabilities of remote: "
                + message.get(String.class, MessageParts.CapabilitiesFlags));


            final String[] capabilities = message.get(String.class, MessageParts.CapabilitiesFlags).split(",");


            for (final String capability : capabilities) {
              switch (Capabilities.valueOf(capability)) {
                case WebSockets:
                  webSocketUrl = message.get(String.class, MessageParts.WebSocketURL);
                  webSocketToken = message.get(String.class, MessageParts.WebSocketToken);
                  webSocketUpgradeAvailable = true;
                  break;
                case LongPollAvailable:


                  LogUtil.log("initializing long poll subsystem");
                  receiveCommCallback = new LongPollRequestCallback();
                  break;
                case NoLongPollAvailable:
                  receiveCommCallback = new ShortPollRequestCallback();
                  if (message.hasPart(MessageParts.PollFrequency)) {
                    POLL_FREQUENCY = message.get(Integer.class, MessageParts.PollFrequency);
                  }
                  else {
                    POLL_FREQUENCY = 500;
                  }
                  break;
                case Proxy:
                  break;
              }
            }
            break;


          case RemoteMonitorAttach:
            break;


          case FinishStateSync:
            if (isInitialized()) {
              return;
            }


            new Timer() {
              @Override
              public void run() {
                LogUtil.log("received FinishStateSync message. preparing to bring up the federation");


                stateSyncInProgress = true;


                for (final Runnable deferredSubscription : deferredSubscriptions) {
                  deferredSubscription.run();
                }


                final List<String> subjects = new ArrayList<String>();
                for (final String s : subscriptions.keySet()) {
                  if (s.startsWith("local:")) continue;
                  if (!remotes.containsKey(s)) subjects.add(s);
                }


                sessionId = message.get(String.class, MessageParts.ConnectionSessionKey);


                remoteSubscribe(BuiltInServices.ServerBus.name());


                encodeAndTransmit(CommandMessage.createWithParts(new HashMap<String, Object>())
                    .toSubject(BuiltInServices.ServerBus.name())
                    .command(RemoteSubscribe)
                    .set(MessageParts.SubjectsList, subjects)
                    .set(PriorityProcessing, "1"));


                encodeAndTransmit(CommandMessage.createWithParts(new HashMap<String, Object>())
                    .toSubject(BuiltInServices.ServerBus.name())
                    .command(BusCommands.FinishStateSync)
                    .set(PriorityProcessing, "1"));




                /**
                 * ... also send RemoteUnsubscribe signals.
                 */
                addSubscribeListener(new SubscribeListener() {
                  @Override
                  public void onSubscribe(final SubscriptionEvent event) {
                    if (event.isLocalOnly() || event.getSubject().startsWith("local:")
                        || remotes.containsKey(event.getSubject())) {
                      return;
                    }


                    if (event.isNew()) {
                      encodeAndTransmit(CommandMessage.createWithParts(new HashMap<String, Object>())
                          .toSubject(BuiltInServices.ServerBus.name())
                          .command(RemoteSubscribe)
                          .set(Subject, event.getSubject())
                          .set(PriorityProcessing, "1"));
                    }
                  }
                });


                addUnsubscribeListener(new UnsubscribeListener() {
                  @Override
                  public void onUnsubscribe(final SubscriptionEvent event) {
                    encodeAndTransmit(CommandMessage.createWithParts(new HashMap<String, Object>())
                        .toSubject(BuiltInServices.ServerBus.name())
                        .command(RemoteUnsubscribe)
                        .set(Subject, event.getSubject())
                        .set(PriorityProcessing, "1"));
                  }
                });


                subscribe(DefaultErrorCallback.CLIENT_ERROR_SUBJECT, new MessageCallback() {
                  @Override
                  public void callback(final Message message) {
                    final String errorTo = message.get(String.class, MessageParts.ErrorTo);
                    if (errorTo == null) {
                      logError(message.get(String.class, MessageParts.ErrorMessage),

View Full Code Here

        Service svc = method.getAnnotation(Service.class);
        String svcName = svc.value().equals("") ? method.getJavaMember().getName() : svc.value();


        final Method callMethod = method.getJavaMember();


        bus.subscribe(svcName, new MessageCallback() {


          @Override
          public void callback(Message message) {
            Object targetBean = CDIServerUtil.lookupBean(beanManager, type);


            try {
              callMethod.invoke(targetBean, message);
            }
            catch (Exception e) {
              ErrorHelper.sendClientError(bus, message, "Error dispatching service", e);
            }
          }
        });
      }
    }


    for (final AnnotatedType<?> type : managedTypes.getServiceEndpoints()) {
      // Discriminate on @Command
      Map<String, Method> commandPoints = new HashMap<String, Method>();
      for (final AnnotatedMethod method : type.getMethods()) {
        if (method.isAnnotationPresent(Command.class)) {
          Command command = method.getAnnotation(Command.class);
          for (String cmdName : command.value()) {
            if (cmdName.equals(""))
              cmdName = method.getJavaMember().getName();
            commandPoints.put(cmdName, method.getJavaMember());
          }
        }
      }


      final String subjectName = CDIServerUtil.resolveServiceName(type.getJavaClass());


      final MessageCallback callback = (MessageCallback) CDIServerUtil.lookupBean(beanManager,
              type.getJavaClass());


      if (commandPoints.isEmpty()) {
        bus.subscribe(subjectName, callback);
      }

View Full Code Here

        }, method, bus));
      }
    }


    final RemoteServiceCallback delegate = new RemoteServiceCallback(epts);
    bus.subscribe(remoteIface.getName() + ":RPC", new MessageCallback() {
      @Override
      public void callback(Message message) {
        delegate.callback(message);
      }
    });

View Full Code Here


            final String receiverName = "RandomNumberReceiver" + i;


            final Style resultStyle = resultBox.getElement().getStyle();


            /**
             * Create a callback receiver to receive the data from the server.
             */
            final MessageCallback receiver = new MessageCallback() {
                public void callback(Message message) {
                    counter.increment();
                    Double value = message.get(Double.class, "Data");
                    resultBox.setText(String.valueOf(value));

View Full Code Here

        Service svc = method.getAnnotation(Service.class);
        String svcName = svc.value().equals("") ? method.getJavaMember().getName() : svc.value();


        final Method callMethod = method.getJavaMember();


        bus.subscribe(svcName, new MessageCallback() {


          @Override
          public void callback(Message message) {
            Object targetBean = CDIServerUtil.lookupBean(beanManager, type);


            try {
              callMethod.invoke(targetBean, message);
            }
            catch (Exception e) {
              ErrorHelper.sendClientError(bus, message, "Error dispatching service", e);
            }
          }
        });
      }
    }


    for (final AnnotatedType<?> type : managedTypes.getServiceEndpoints()) {
      // Discriminate on @Command
      Map<String, Method> commandPoints = new HashMap<String, Method>();
      for (final AnnotatedMethod method : type.getMethods()) {
        if (method.isAnnotationPresent(Command.class)) {
          Command command = method.getAnnotation(Command.class);
          for (String cmdName : command.value()) {
            if (cmdName.equals(""))
              cmdName = method.getJavaMember().getName();
            commandPoints.put(cmdName, method.getJavaMember());
          }
        }
      }


      final String subjectName = CDIServerUtil.resolveServiceName(type.getJavaClass());


      final MessageCallback callback = (MessageCallback) CDIServerUtil.lookupBean(beanManager,
              type.getJavaClass());


      if (commandPoints.isEmpty()) {
        bus.subscribe(subjectName, callback);
      }

View Full Code Here

            }, method, bus));
      }
    }


    final RemoteServiceCallback delegate = new RemoteServiceCallback(epts);
    bus.subscribe(remoteIface.getName() + ":RPC", new MessageCallback() {
      @Override
      public void callback(Message message) {
        delegate.callback(message);
      }
    });

View Full Code Here

      }
    };


    bus.addPostInitTask(busReadyEvent);


    bus.subscribe(CDI.CLIENT_DISPATCHER_SUBJECT, new MessageCallback() {
      public void callback(Message message) {
        switch (BusCommands.valueOf(message.getCommandType())) {
          case RemoteSubscribe:
            CDI.addRemoteEventTypes(message.get(String[].class, MessageParts.Value));

View Full Code Here


    public void onModuleLoad() {
        final Label label = new Label();
        final Button button = new Button("Click");


        ErraiBus.get().subscribe("ClientListener", new MessageCallback() {
            public void callback(Message message) {
                label.setText(message.get(String.class, "Text"));
            }
        });

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

Related Classes of org.jboss.errai.bus.client.api.MessageCallback

$.HelloWorldClient

org.errai.samples.asyncdemo.client.AsyncClient

org.errai.samples.asyncdemo.client.local.AsyncClient

org.errai.samples.broadcastservice.client.BroadcastClient

org.errai.samples.broadcastservice.client.local.BroadcastClient

org.errai.samples.errorhandling.client.HelloWorld

org.errai.samples.helloworld.client.local.HelloWorld

org.errai.samples.serialization.client.Serialization

org.errai.samples.stockdemo.client.local.StockClient

org.errai.samples.stockdemo.client.StockClient

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.