Package org.jboss.errai.bus.client.api

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


  }

  public static Message uglyReEncode(Message message) {
    Map<String, Object> parts = (Map<String, Object>) JSONDecoder.decode(ServerBusUtils.encodeJSON(message.getParts()));

    Message newMessage = CommandMessage.createWithParts(parts);
//        if (parts.containsKey(SerializationParts.MARSHALLED_TYPES)) {
//            TypeDemarshallHelper.demarshallAll((String) parts.get(SerializationParts.MARSHALLED_TYPES), newMessage);
//        }
    return newMessage;
  }
View Full Code Here


            /**
             * Prepare to send a message back to the client, informing it that a successful login has
             * been performed.
             */
            Message successfulMsg = MessageBuilder.createConversation(message)
                    .subjectProvided()
                    .command(SecurityCommands.SuccessfulAuth)
                    .with(SecurityParts.Roles, authSubject.toRolesString())
                    .with(SecurityParts.Name, name).getMessage();

            try {
                ResourceBundle bundle = ResourceBundle.getBundle("errai");
                String motdText = bundle.getString("errai.login_motd");

                /**
                 * If the MOTD is configured, then add it to the message.
                 */
                if (motdText != null) {
                    successfulMsg.set(MessageParts.MessageText, motdText);
                }
            }
            catch (Exception e) {
                // do nothing.
            }

            /**
             * Transmit the message back to the client.
             */
            successfulMsg.sendNowWith(bus);
        }
        catch (LoginException e) {
            /**
             * The login failed. How upsetting. Life must go on, and we must inform the client of the
             * unfortunate news.
View Full Code Here

    if (!queueRunning) {
      JSONStreamEncoder.encode(new QueueStopMessage().getParts(), outstream);
      return;
    }

    Message m = null;

    checkSession();

    if (lock.tryAcquire()) {
      outstream.write('[');

      int payLoadSize = 0;
      try {

        if (wait) {
          m = queue.poll(45, TimeUnit.SECONDS);

        }
        else {
          m = queue.poll();
        }

        if (m instanceof HasEncoded) {
          outstream.write(((HasEncoded) m).getEncoded().getBytes());
        }
        else if (m instanceof QueueStopMessage) {
          JSONStreamEncoder.encode(m.getParts(), outstream);
          queueRunning = false;
          bus.closeQueue(this);
        }
        else if (m != null) {
          JSONStreamEncoder.encode(m.getParts(), outstream);
        }

        if (_windowPolling) {
          windowPolling = true;
          _windowPolling = false;
        }
        else if (windowPolling) {
          while (!queue.isEmpty() && payLoadSize < MAXIMUM_PAYLOAD_SIZE
                  && !isWindowExceeded()) {
            outstream.write(',');
            if ((m = queue.poll()) instanceof HasEncoded) {
              outstream.write(((HasEncoded) m).getEncoded().getBytes());
            }
            else {
              JSONStreamEncoder.encode(m.getParts(), outstream);
            }
            payLoadSize++;
          }
        }
View Full Code Here

        sb.append(buffer.get());
      }
      buffer.rewind();
    }

    Message msg = createCommandMessage(sessionProvider.getSession(request.getSession(),
        request.getHeader(REMOTE_QUEUE_ID_HEADER)), sb.toString());
    if (msg != null) {
      try {
        service.store(msg);
      }
View Full Code Here

        sb.append(buffer.get());
      }
      buffer.rewind();
    }

    Message msg = createCommandMessage(session, sb.toString());
    if (msg != null) {
      try {
        service.store(msg);
      }
      catch (Exception e) {
View Full Code Here

        sb.append(buffer.get());
      }
      buffer.rewind();
    }

    Message m = createCommandMessage(session, sb.toString());
    if (m != null) {
      try {
        service.store(m);
      }
      catch (Exception e) {
View Full Code Here

        }
        buffer.rewind();
      }


      Message msg = createCommandMessage(sessionProvider.getSession(request.getSession(),
          request.getHeader(ClientMessageBus.REMOTE_QUEUE_ID_HEADER)), sb.toString());
      if (msg != null) {
        try {
          service.store(msg);
        }
View Full Code Here

  public void stop(boolean sendDisconnect) {
    if (sendDisconnect) {
      sendBuilder.setHeader("phase", "disconnect");

      Message m = MessageBuilder.createMessage()
              .toSubject("ServerBus")
              .command(BusCommands.Disconnect).getMessage();

      encodeAndTransmit(m);
    }
View Full Code Here

    addSubscription(subject, REMOTE_CALLBACK);
  }

  private void sendAllDeferred() {
    for (Iterator<Message> iter = deferredMessages.iterator(); iter.hasNext(); ) {
      Message m = iter.next();
      if (m.hasPart(MessageParts.PriorityProcessing)) {
        directStore(m);
        iter.remove();
      }
    }
View Full Code Here

      synchronized (queue) {
        if (deferredQueue.containsKey(queue)) {
          List<Message> deferredMessages = deferredQueue.get(queue);
          Iterator<Message> dmIter = deferredMessages.iterator();

          Message m;
          while (dmIter.hasNext()) {
            if ((m = dmIter.next()).hasPart(MessageParts.PriorityProcessing.toString())) {
              queue.offer(m);
              dmIter.remove();
            }
View Full Code Here

TOP

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

Copyright © 2018 www.massapicom. All rights reserved.
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.