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 freenet.node.PeerNode.sendAsync()

          File tmp = null;
          FileRandomAccessBuffer raf = null;
          try {
            System.out.println("Fetching "+saveTo+" from "+fetchFrom);
            long uid = updateManager.node.fastWeakRandom.nextLong();
            fetchFrom.sendAsync(DMT.createUOMFetchDependency(uid, expectedHash, size), null, updateManager.ctr);
            tmp = FileUtil.createTempFile(saveTo.getName(), NodeUpdateManager.TEMP_FILE_SUFFIX, saveTo.getParentFile());
            raf = new FileRandomAccessBuffer(tmp, size, false);
            PartiallyReceivedBulk prb = 
              new PartiallyReceivedBulk(updateManager.node.getUSM(), size,
                Node.PACKET_SIZE, raf, false);

View Full Code Here

Examples of org.mule.module.client.MuleClient.sendAsync()

    }


    public void testDynamicEndpoint() throws Exception
    {
        MuleClient client = new MuleClient(muleContext);
        FutureMessageResult result = client.sendAsync("vm://inBound", "Hello,world", null, 5000);
        MuleMessage response = result.getMessage(5000);
        assertNotNull(response);
        assertNotNull(response.getPayload());
        assertEquals("step2Service", response.getPayloadAsString());
    }

View Full Code Here

Examples of org.mule.module.client.MuleClient.sendAsync()

    }


    public void testDynamicEndpoint() throws Exception
    {
        MuleClient client = new MuleClient(muleContext);
        FutureMessageResult result = client.sendAsync("vm://inBound", "Hello,world", null, 5000);
        MuleMessage response = result.getMessage(5000);
        assertNotNull(response);
        assertNotNull(response.getPayload());
        assertEquals("step2Service", response.getPayloadAsString());
    }

View Full Code Here

Examples of org.mule.module.client.MuleClient.sendAsync()


    @Test
    public void testDynamicEndpoint() throws Exception
    {
        MuleClient client = new MuleClient(muleContext);
        FutureMessageResult result = client.sendAsync("vm://inBound", "Hello,world", null, 5000);
        MuleMessage response = result.getMessage(5000);
        assertNotNull(response);
        assertNotNull(response.getPayload());
        assertEquals("step2Service", response.getPayloadAsString());
    }

View Full Code Here

Examples of org.mule.module.client.MuleClient.sendAsync()


    @Test
    public void testDynamicEndpoint() throws Exception
    {
        MuleClient client = new MuleClient(muleContext);
        FutureMessageResult result = client.sendAsync("vm://inBound", "Hello,world", null, 5000);
        MuleMessage response = result.getMessage(5000);
        assertNotNull(response);
        assertNotNull(response.getPayload());
        assertEquals("step2Service", response.getPayloadAsString());
    }

View Full Code Here

Examples of org.mule.module.client.MuleClient.sendAsync()

    @Test
    public void usesConnectionTimeout() throws Exception
    {


        final MuleClient client = new MuleClient(muleContext);
        FutureMessageResult result = client.sendAsync("vm://testInput", TEST_MESSAGE, null);


        MuleMessage message = null;
        try
        {
            message = result.getMessage(1000);

View Full Code Here

Examples of org.mule.module.client.MuleClient.sendAsync()


    @Test
    public void usesConnectionTimeout() throws Exception
    {
        final MuleClient client = new MuleClient(muleContext);
        FutureMessageResult result = client.sendAsync("vm://testInput", TEST_MESSAGE, null);


        MuleMessage message = null;
        try
        {
            message = result.getMessage(1000);

View Full Code Here

Examples of org.mule.module.client.MuleClient.sendAsync()


    @Test
    public void socketReadWriteResponseTimeout() throws Exception
    {
        final MuleClient client = new MuleClient(muleContext);
        FutureMessageResult result = client.sendAsync("vm://inboundTest1", "something", null);
        MuleMessage message = null;
        try
        {
            message = result.getMessage(1000);
        }

View Full Code Here

Examples of org.mule.module.client.MuleClient.sendAsync()


    @Test
    public void socketConnectionResponseTimeout() throws Exception
    {
        final MuleClient client = new MuleClient(muleContext);
        FutureMessageResult result = client.sendAsync("vm://inboundTest2", "something", null);
        MuleMessage message = null;
        try
        {
            message = result.getMessage(1000);
        }

View Full Code Here

Examples of org.wicketstuff.push.examples.chatservice.ChatRoom.sendAsync()

      @Override
      public void onDisconnect(final IPushChannel<?> pChannel)
      {
        if (pChannel.equals(pushChannel))
        {
          chatRoom.sendAsync("<System>", "A USER JUST LEFT THE ROOM.");
          pushService.removePushChannelDisconnectedListener(this);
        }
      }
    });

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.