java - httpAsyncClient.execute() callback method not invoked - 


package com.lt.uadb.app.resource.test;  import java.util.concurrent.future;  import org.apache.http.httpresponse; import org.apache.http.client.methods.httpget; import org.apache.http.concurrent.futurecallback; import org.apache.http.impl.nio.client.defaulthttpasyncclient; import org.apache.http.nio.client.httpasyncclient; import org.junit.test;  public class asyncsampleresourcetest {     private static final string path = "http://192.168.1.112:8080/uadb.app/rest/sample/async/get";      @test     public void testhttpasyncclientfuturecallback() throws exception {         final httpasyncclient httpasyncclient = new defaulthttpasyncclient();         httpasyncclient.start();         final httpget request = new httpget(path);         try {             (int = 0; < 5; i++) {                 system.out.println("*****get--------------");                 future<httpresponse> future = httpasyncclient.execute(request,                         new futurecallback<httpresponse>() {                             @override                             public void completed(httpresponse httpresponse) {                                 system.out                                         .println("*****completed--------------");                             }                              @override                             public void failed(exception e) {                                 system.out.println("*****failed--------------");                             }                              @override                             public void cancelled() {                                 system.out                                         .println("*****cancelled--------------");                             }                         });                 // if run code in try catch,the rest service invoke                 // try {                 // httpresponse result = future.get();                 // if (result != null) {                 // system.out.println("request executed");                 // } else {                 // system.out.println("request failed");                 // }                 // } catch (interruptedexception | executionexception e1) {                 // e1.printstacktrace();                 // }             }             system.out.println("*****loop--------------");         } catch (exception e) {             e.printstacktrace();         } {             system.out.println("shutting down");             httpasyncclient.getconnectionmanager().shutdown();         }      } }

the above code not invoking rest service, below log -

    *****get--------------     2015-06-04 16:51:53,372 [main] [org.apache.http.impl.nio.client.defaulthttpasyncclient] [debug] - [exchange: 1] start execution       2015-06-04 16:51:53,385 [main] [org.apache.http.impl.nio.client.defaulthttpasyncclient] [debug] - [exchange: 1] request connection {}->http://192.168.1.112:8080       2015-06-04 16:51:53,389 [main] [org.apache.http.impl.nio.conn.poolingclientasyncconnectionmanager] [debug] - connection request: [route: {}->http://192.168.1.112:8080][total kept alive: 0; route allocated: 0 of 2; total allocated: 0 of 20]       *****get--------------     2015-06-04 16:51:53,393 [main] [org.apache.http.impl.nio.client.defaulthttpasyncclient] [debug] - [exchange: 2] start execution       2015-06-04 16:51:53,394 [main] [org.apache.http.impl.nio.client.defaulthttpasyncclient] [debug] - [exchange: 2] request connection {}->http://192.168.1.112:8080       2015-06-04 16:51:53,394 [main] [org.apache.http.impl.nio.conn.poolingclientasyncconnectionmanager] [debug] - connection request: [route: {}->http://192.168.1.112:8080][total kept alive: 0; route allocated: 0 of 2; total allocated: 0 of 20]       *****get--------------     2015-06-04 16:51:53,394 [main] [org.apache.http.impl.nio.client.defaulthttpasyncclient] [debug] - [exchange: 3] start execution       2015-06-04 16:51:53,396 [main] [org.apache.http.impl.nio.client.defaulthttpasyncclient] [debug] - [exchange: 3] request connection {}->http://192.168.1.112:8080       2015-06-04 16:51:53,396 [main] [org.apache.http.impl.nio.conn.poolingclientasyncconnectionmanager] [debug] - connection request: [route: {}->http://192.168.1.112:8080][total kept alive: 0; route allocated: 0 of 2; total allocated: 0 of 20]       *****get--------------     2015-06-04 16:51:53,396 [main] [org.apache.http.impl.nio.client.defaulthttpasyncclient] [debug] - [exchange: 4] start execution       2015-06-04 16:51:53,397 [main] [org.apache.http.impl.nio.client.defaulthttpasyncclient] [debug] - [exchange: 4] request connection {}->http://192.168.1.112:8080       2015-06-04 16:51:53,397 [main] [org.apache.http.impl.nio.conn.poolingclientasyncconnectionmanager] [debug] - connection request: [route: {}->http://192.168.1.112:8080][total kept alive: 0; route allocated: 0 of 2; total allocated: 0 of 20]       *****get--------------     2015-06-04 16:51:53,397 [main] [org.apache.http.impl.nio.client.defaulthttpasyncclient] [debug] - [exchange: 5] start execution       2015-06-04 16:51:53,397 [main] [org.apache.http.impl.nio.client.defaulthttpasyncclient] [debug] - [exchange: 5] request connection {}->http://192.168.1.112:8080       2015-06-04 16:51:53,397 [main] [org.apache.http.impl.nio.conn.poolingclientasyncconnectionmanager] [debug] - connection request: [route: {}->http://192.168.1.112:8080][total kept alive: 0; route allocated: 0 of 2; total allocated: 0 of 20]       *****loop--------------     shutting down     2015-06-04 16:51:53,398 [main] [org.apache.http.impl.nio.conn.poolingclientasyncconnectionmanager] [debug] - connection manager shutting down       2015-06-04 16:51:53,401 [thread-0] [org.apache.http.impl.nio.client.defaulthttpasyncclient] [debug] - [exchange: 1] cancelled       *****cancelled--------------     2015-06-04 16:51:53,402 [main] [org.apache.http.impl.nio.conn.poolingclientasyncconnectionmanager] [debug] - connection manager shut down       2015-06-04 16:51:53,402 [thread-0] [org.apache.http.impl.nio.client.defaulthttpasyncclient] [debug] - [exchange: 2] cancelled       *****cancelled--------------     2015-06-04 16:51:53,402 [thread-0] [org.apache.http.impl.nio.client.defaulthttpasyncclient] [debug] - [exchange: 3] cancelled       *****cancelled--------------     2015-06-04 16:51:53,402 [thread-0] [org.apache.http.impl.nio.client.defaulthttpasyncclient] [debug] - [exchange: 4] cancelled       *****cancelled--------------     2015-06-04 16:51:53,403 [thread-0] [org.apache.http.impl.nio.client.defaulthttpasyncclient] [debug] - [exchange: 5] cancelled       *****cancelled--------------

the completed not getting logged.

if toggle comment of code shown below - 

    try {   httpresponse result = future.get();   if (result != null) {     system.out.println("request executed");   } else {     system.out.println("request failed");   } } catch (interruptedexception | executionexception e1) {   e1.printstacktrace(); }

then rest service invoked, shown below -

      *****get--------------        *****completed--------------     *****loop--------------      *****get--------------        *****completed--------------     *****loop--------------      *****get--------------        *****completed--------------     *****loop--------------      shutting down

it seems async not getting invoked, if it's invoke async, logged -

      *****get--------------      *****loop--------------      *****get--------------      *****loop--------------      *****get--------------      *****loop--------------         *****completed--------------       *****completed--------------       *****completed--------------      shutting down


Comments

Post a Comment

Popular posts from this blog

Magento/PHP - Get phones on all members in a customer group -

i working on custom magento extension. working around adminhtml part , i've created custom form there. here form code: <?php class vivasindustries_smsnotification_block_adminhtml_sms_sendmass_edit_form extends mage_adminhtml_block_widget_form { public function _preparelayout() { $extensionpath = mage::getmoduledir('js', 'vivasindustries_smsnotification'); $head = $this->getlayout()->getblock('head'); $head->addjs('jquery.js'); $head->addjs('vivas.js'); return parent::_preparelayout(); } protected function _prepareform() { $form = new varien_data_form(array( 'id' => 'edit_form', 'action' => $this->geturl('*/*/save', array('id' => $this->getrequest()->get...
Read more

php - Bypass Geo Redirect for specific directories -

i'm trying bypass redirect specific url within site. wondering if might able help. the code below code use, original urls replaces example.com i'd able access http://example.com/admin without redirect occuring. is there way this, , there way using own ip? function country_geo_redirect() { $country = getenv('http_geoip_country_code'); if ($country == "us" ) { wp_redirect("http://usa.example.com/"); exit; } else if ($country == "gb" ) { wp_redirect("http://uk.example.com/"); exit; } } add_action('init', 'country_geo_redirect'); you can bypass redirection code if server found ip address. if ip address == <my ip address> ' nothing here else country_georedirect() end if
Read more

php - .htaccess mod_rewrite for dynamic url which has domain names -

i want convert url ex:( example.com/link.php?url=facebook.com ) ( example.com/facebook.com.php ) how can using .htaccess. or there other process make job easier ? i tried adding script .htaccess file options +followsymlinks rewriteengine on rewriterule url-(.*)\.htm$ link.php?url=$1 but converting url adding "url-" ( example.com/url-facebook.com.php ) i want remove "url-" , want make ( example.com/facebook.com.php ) rewriteengine on rewritecond %{the_request} ^get.*link\.php\?url\= [nc] rewritecond %{request_uri} !/system/.* [nc] rewriterule (.*?)link\.php\?url\=/*(.*) /$1$2 [r=301,ne,l] not sure how above work edit of used use remove index.php url
Read more