Package net.sf.clairv.p2p

Examples of net.sf.clairv.p2p.RequestHandler


          return;
        }
        if (enclosed instanceof RequestMessage) {
          // request message, see if we need to handle it
          RequestMessage requestMsg = (RequestMessage) enclosed;
          final RequestHandler handler = (RequestHandler) messageHandlers
              .get(requestMsg.getClass());
          if (handler != null) {
            final PastryRequest request = new PastryRequest();
            request.setContext(PastryNetwork.this.context);
            request.setMessage(requestMsg);
            request.setRemoteNodeId(wrapper.getSourceNodeId());
            new Thread() {
              public void run() {
                ResponseMessage resp = handler
                    .handleRequest(request);
                // internal send
                if (resp != null) {
                  try {
                    internalSend(wrapper.getSourceNodeId(),
View Full Code Here

TOP

Related Classes of net.sf.clairv.p2p.RequestHandler

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.