Examples of org.red5.server.messaging.ServiceAdapter.manage()

Class org.red5.server.messaging.ServiceAdapter

Examples of org.red5.server.messaging.ServiceAdapter.manage()

org.red5.server.messaging.ServiceAdapter.manage()
Accept a command from the adapter's service and perform some internal action based upon it. CommandMessages are used for messages which control the state of the connection between the client and the server. For example, this handles subscribe, unsubscribe, and ping operations. The messageRefType property of the CommandMessage is used to associate a command message with a particular service. Services are configured to handle messages of a particular concrete type. For example, the MessageService is typically invoked to handle messages of type flex.messaging.messages.AsyncMessage. To ensure a given CommandMessage is routed to the right service, its MessageRefType is set to the string name of the message type for messages handled by that service. @param commandMessage @return Exception if not implemented

            //this will be the body of the responding command message
            AsyncMessageExt ext = new AsyncMessageExt();
            ext.setClientId(clientId);
            ext.setCorrelationId(msg.getMessageId());
            ext.setDestination("Red5Chat");
            ext.setBody(adapter.manage(msg));
            /*
            //grab any headers
            Map<String, Object> headers = msg.getHeaders();
            log.debug("Headers: {}", headers);
            if (headers.containsKey(Message.FLEX_CLIENT_ID_HEADER)) {

View Full Code Here

            //this will be the body of the responding command message
            AsyncMessageExt ext = new AsyncMessageExt();
            ext.setClientId(clientId);
            ext.setCorrelationId(msg.getMessageId());
            ext.setDestination("Red5Chat");
            ext.setBody(adapter.manage(msg));
            //add as a child (body) of the command message
            result.setBody(new Object[]{ext});    
            
            return result;
          } else {

View Full Code Here

            if (endpoints.containsKey(destination)) {
              Object endpoint = endpoints.get(destination);
            //if the endpoint is an adapter, try to subscribe
              if (endpoint instanceof ServiceAdapter) {
                ServiceAdapter adapter = (ServiceAdapter) endpoint;
                boolean subscribed = ((Boolean) adapter.manage(msg));
                if (subscribed) {
                  log.debug("Client was subscribed");
                  registerClientToAdapter(clientId, adapter);
                } else {
                  log.debug("Client was not subscribed");

View Full Code Here


      case Constants.UNSUBSCRIBE_OPERATION: //1
        log.trace("Unsubscribe: {}", clientId);
        if (registrations.containsKey(clientId)) {
          ServiceAdapter adapter = registrations.get(clientId);
          boolean unsubscribed = ((Boolean) adapter.manage(msg));
          if (unsubscribed) {
            log.debug("Client was unsubscribed");
            unregisterClientFromAdapter(clientId);
          } else {
            log.debug("Client was not unsubscribed");

View Full Code Here

TOP

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.