List of sendAsync() Examples

Examples of sendAsync()

com.almende.eve.transport.TransportService.sendAsync()
Asynchronously Send a message to an other agent @param senderId @oaran receiverUrl @param request @param callback with a JSONResponse
freenet.io.xfer.BlockTransmitter.sendAsync()
Send the data, off-thread.
freenet.node.PeerNode.sendAsync()
Send a message, off-thread, to this node. @param msg The message to be sent. @param cb The callback to be called when the packet has been sent, or null. @param ctr A callback to tell how many bytes were used to send this message.
org.mule.module.client.MuleClient.sendAsync()
Sends an event request to a URL, making the result of the event trigger available as a Future result that can be accessed later by client code. @param url the url to make a request on @param payload the object that is the payload of the event @param messageProperties any properties to be associated with the payload. asnull @return the result message if any of the invocation @throws org.mule.api.MuleException if the dispatch fails or the components ortransfromers cannot be found
org.wicketstuff.push.examples.chatservice.ChatRoom.sendAsync()
sends the chat message asynchronously (in a background thread) to all listeners

Examples of com.almende.eve.transport.TransportService.sendAsync()

        senderUri = getSenderUrl(sender.getId(), receiverUrl);
      }
      service = getTransportService(protocol);
      if (service != null) {
        // TODO: message should already be a String?
        service.sendAsync(senderUri, receiverUrl, message.toString(),
            tag);
      } else {
        throw new ProtocolException(
            "No transport service configured for protocol '"
                + protocol + "'.");

View Full Code Here

Examples of com.almende.eve.transport.TransportService.sendAsync()

      if (separator != -1) {
        protocol = receiverUrl.substring(0, separator);
        service = getTransportService(protocol);
      }
      if (service != null) {
        service.sendAsync(senderId, receiverUrl, request, callback);
      }
      else {
        throw new ProtocolException(
          "No transport service configured for protocol '" + protocol + "'.");
      }

View Full Code Here

Examples of com.almende.eve.transport.TransportService.sendAsync()

        senderUri = getSenderUrl(sender.getId(), receiverUrl);
      }
      service = getTransportService(protocol);
      if (service != null) {
        // TODO: message should already be a String?
        service.sendAsync(senderUri, receiverUrl, message.toString(),
            tag);
      } else {
        throw new ProtocolException(
            "No transport service configured for protocol '"
                + protocol + "'.");

View Full Code Here

Examples of com.almende.eve.transport.TransportService.sendAsync()

      if (separator != -1) {
        protocol = receiverUrl.substring(0, separator);
        service = getTransportService(protocol);
      }
      if (service != null) {
        service.sendAsync(senderUrl, receiverUrl, request,
            callback);
      } else {
        throw new ProtocolException(
            "No transport service configured for protocol '"
                + protocol + "'.");

View Full Code Here

Examples of com.almende.eve.transport.TransportService.sendAsync()

            receiverUrl.toASCIIString());
      }
      protocol = receiverUrl.getScheme();
      service = getTransportService(protocol);
      if (service != null) {
        service.sendAsync(senderUrl, receiverUrl.toASCIIString(),
            request, callback);
      } else {
        throw new ProtocolException(
            "No transport service configured for protocol '"
                + protocol + "'.");

View Full Code Here

Examples of com.almende.eve.transport.TransportService.sendAsync()

        senderUri = getSenderUrl(sender.getId(), receiverUrl);
      }
      service = getTransportService(protocol);
      if (service != null) {
        // TODO: message should already be a String?
        service.sendAsync(senderUri, receiverUrl, message.toString(),
            tag);
      } else {
        throw new ProtocolException(
            "No transport service configured for protocol '"
                + protocol + "'.");

View Full Code Here

Examples of com.almende.eve.transport.TransportService.sendAsync()

      if (separator != -1) {
        protocol = receiverUrl.substring(0, separator);
        service = getTransportService(protocol);
      }
      if (service != null) {
        service.sendAsync(senderId, receiverUrl, request, callback);
      }
      else {
        throw new ProtocolException(
          "No transport service configured for protocol '" + protocol + "'.");
      }

View Full Code Here

Examples of freenet.io.xfer.BlockTransmitter.sendAsync()

          return NativeThread.HIGH_PRIORITY;
        }


        @Override
        public void run() {
          bt.sendAsync();
        }
            
          }, "CHK offer sender");
    }
  }

View Full Code Here

Examples of freenet.io.xfer.BlockTransmitter.sendAsync()

          }
          
        }, realTimeFlag, node.nodeStats);
      tag.handlerTransferBegins();
      source.sendAsync(df, null, this);
      bt.sendAsync();
    } else
      throw new IllegalStateException();
  }


  private void unregisterRequestHandlerWithNode() {

View Full Code Here

Examples of freenet.node.PeerNode.sendAsync()

          final MessageFilter filter = createResponseFilter(type, candidate, uid, htl);
          message.set(DMT.HTL, htl);
          try {
            node.getUSM().addAsyncFilter(filter, new ResultListener(listener), this);
            if (logDEBUG) Logger.debug(Probe.class, "Sending.");
            candidate.sendAsync(message, null, this);
            return true;
          } catch (NotConnectedException e) {
            if (logMINOR) Logger.minor(Probe.class, "Peer became disconnected between check and send attempt.", e);
            // Peer no longer connected - sending was not successful. Try again.
          } catch (DisconnectedException e) {

View Full Code Here

0 1 2

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.