# Check if node is listening before sending a request

**URL:** <https://discuss.elastic.co/t/check-if-node-is-listening-before-sending-a-request/5957>\
**Category:** Elasticsearch\
**Created:** [November 23, 2011, 8:09pm UTC](https://discuss.elastic.co/t/check-if-node-is-listening-before-sending-a-request/5957 "2011-11-23T20:09:06Z")\
**Posts on this page:** 3\
**Page:** 1

<div class="post-metadata">

**Author:** ![Diego\_Medina](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/diego_medina/32/2675_2.png) [@Diego\_Medina](https://discuss.elastic.co/u/Diego_Medina)\
**Post date:** [November 23, 2011, 8:09pm UTC](https://discuss.elastic.co/t/check-if-node-is-listening-before-sending-a-request/5957/1 "2011-11-23T20:09:06Z")

</div>

Hi,

I'm using Elastic Search with Scala and the liftweb framework and on  
several areas I have something like this:

client.prepareIndex("inventory", "main", c.id.toString)  
.setSource(jsonBuilder()  
.startObject()  
.field("id", c.id.is)  
.field("part\_number", c.part\_number.toString)  
.field("category", ~(c.category.obj map (_.category\_name.toString)))  
.field("subcategory", ~(c.subcategory.obj map  
(_.subcategory\_name.toString)))  
.endObject()  
)  
.execute()  
.actionGet()

and client is:

val client: Box[Client] = {  
info("Calling client!")  
new TransportClient().addTransportAddress(  
new InetSocketTransportAddress("192.168.0.100", 9300)  
)  
}

pretty much just a translation from java to scala. The problem I have  
is that is my elastic search instance is down, and I execute the code  
above, I get an exception on my logs, something along the lines:

org.elasticsearch.transport.ConnectTransportException:  
[][inet[/192.168.0.100:9300]] connect\_timeout[30s]  
at org.elasticsearch.transport.netty.NettyTransport.connectToChannels(NettyTransport.java:562)  
~[elasticsearch-0.18.2.jar:na]  
at org.elasticsearch.transport.netty.NettyTransport.connectToNode(NettyTransport.java:505)  
~[elasticsearch-0.18.2.jar:na]  
at org.elasticsearch.transport.netty.NettyTransport.connectToNode(NettyTransport.java:484)  
~[elasticsearch-0.18.2.jar:na]  
at org.elasticsearch.transport.TransportService.connectToNode(TransportService.java:124)  
~[elasticsearch-0.18.2.jar:na]  
at org.elasticsearch.client.transport.TransportClientNodesService$SimpleNodeSampler.sample(TransportClientNodesService.java:262)  
~[elasticsearch-0.18.2.jar:na]  
at org.elasticsearch.client.transport.TransportClientNodesService$ScheduledNodeSampler.run(TransportClientNodesService.java:245)  
[elasticsearch-0.18.2.jar:na]  
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)  
[na:1.6.0\_25]  
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)  
[na:1.6.0\_25]  
at java.lang.Thread.run(Thread.java:662) [na:1.6.0\_25]  
Caused by: java.net.ConnectException: Connection refused  
at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) ~[na:1.6.0\_25]  
at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:567)  
~[na:1.6.0\_25]  
at org.elasticsearch.common.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.connect(NioClientSocketPipelineSink.java:384)  
~[elasticsearch-0.18.2.jar:na]  
at org.elasticsearch.common.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.processSelectedKeys(NioClientSocketPipelineSink.java:354)  
~[elasticsearch-0.18.2.jar:na]  
at org.elasticsearch.common.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.run(NioClientSocketPipelineSink.java:276)  
~[elasticsearch-0.18.2.jar:na]  
at org.elasticsearch.common.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)  
~[elasticsearch-0.18.2.jar:na]  
at org.elasticsearch.common.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:44)  
~[elasticsearch-0.18.2.jar:na]  
... 3 common frames omitted

While my app is running I handle this nicely and I show a message on  
the browser telling the user what to do, but during unit test (ES is  
not running) I want to first check if the port is not listening, and  
if that is the case, just not even try to run:  
...  
.execute()  
.actionGet()

Is there an API to do this or should I do it in plain java?

Thanks

Diego

P.S. The integration with Scala and Lift is working out really smooth 🙂

--  
Diego Medina  
Web Developer  
[diego@fmpwizard.com](mailto:diego@fmpwizard.com)  
[http://www.fmpwizard.com](http://www.fmpwizard.com)

---

<div class="post-metadata">

**Author:** ![kimchy](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/kimchy/32/44952_2.png) [@kimchy](https://discuss.elastic.co/u/kimchy)\
**Post date:** [November 24, 2011, 2:06pm UTC](https://discuss.elastic.co/t/check-if-node-is-listening-before-sending-a-request/5957/2 "2011-11-24T14:06:40Z")

</div>

TransportClient has a method called connectedNodes that returns the nodes  
that the client is connected to.

On Wed, Nov 23, 2011 at 10:09 PM, Diego Medina [diego@fmpwizard.com](mailto:diego@fmpwizard.com) wrote:

> Hi,
> 
> I'm using Elastic Search with Scala and the liftweb framework and on  
> several areas I have something like this:
> 
> client.prepareIndex("inventory", "main", c.id.toString)  
> .setSource(jsonBuilder()  
> .startObject()  
> .field("id", c.id.is)  
> .field("part\_number", c.part\_number.toString)  
> .field("category", ~(c.category.obj map (_.category\_name.toString)))  
> .field("subcategory", ~(c.subcategory.obj map  
> (_.subcategory\_name.toString)))  
> .endObject()  
> )  
> .execute()  
> .actionGet()
> 
> and client is:
> 
> val client: Box[Client] = {  
> info("Calling client!")  
> new TransportClient().addTransportAddress(  
> new InetSocketTransportAddress("192.168.0.100", 9300)  
> )  
> }
> 
> pretty much just a translation from java to scala. The problem I have  
> is that is my Elasticsearch instance is down, and I execute the code  
> above, I get an exception on my logs, something along the lines:
> 
> org.elasticsearch.transport.ConnectTransportException:  
> [inet[/192.168.0.100:9300]] connect\_timeout[30s]  
> at  
> org.elasticsearch.transport.netty.NettyTransport.connectToChannels(NettyTransport.java:562)  
> ~[elasticsearch-0.18.2.jar:na]  
> at  
> org.elasticsearch.transport.netty.NettyTransport.connectToNode(NettyTransport.java:505)  
> ~[elasticsearch-0.18.2.jar:na]  
> at  
> org.elasticsearch.transport.netty.NettyTransport.connectToNode(NettyTransport.java:484)  
> ~[elasticsearch-0.18.2.jar:na]  
> at  
> org.elasticsearch.transport.TransportService.connectToNode(TransportService.java:124)  
> ~[elasticsearch-0.18.2.jar:na]  
> at  
> org.elasticsearch.client.transport.TransportClientNodesService$SimpleNodeSampler.sample(TransportClientNodesService.java:262)  
> ~[elasticsearch-0.18.2.jar:na]  
> at  
> org.elasticsearch.client.transport.TransportClientNodesService$ScheduledNodeSampler.run(TransportClientNodesService.java:245)  
> [elasticsearch-0.18.2.jar:na]  
> at  
> java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)  
> [na:1.6.0\_25]  
> at  
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)  
> [na:1.6.0\_25]  
> at java.lang.Thread.run(Thread.java:662) [na:1.6.0\_25]  
> Caused by: java.net.ConnectException: Connection refused  
> at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)  
> ~[na:1.6.0\_25]  
> at  
> sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:567)  
> ~[na:1.6.0\_25]  
> at  
> org.elasticsearch.common.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.connect(NioClientSocketPipelineSink.java:384)  
> ~[elasticsearch-0.18.2.jar:na]  
> at  
> org.elasticsearch.common.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.processSelectedKeys(NioClientSocketPipelineSink.java:354)  
> ~[elasticsearch-0.18.2.jar:na]  
> at  
> org.elasticsearch.common.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.run(NioClientSocketPipelineSink.java:276)  
> ~[elasticsearch-0.18.2.jar:na]  
> at  
> org.elasticsearch.common.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)  
> ~[elasticsearch-0.18.2.jar:na]  
> at  
> org.elasticsearch.common.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:44)  
> ~[elasticsearch-0.18.2.jar:na]  
> ... 3 common frames omitted
> 
> While my app is running I handle this nicely and I show a message on  
> the browser telling the user what to do, but during unit test (ES is  
> not running) I want to first check if the port is not listening, and  
> if that is the case, just not even try to run:  
> ...  
> .execute()  
> .actionGet()
> 
> Is there an API to do this or should I do it in plain java?
> 
> Thanks
> 
> Diego
> 
> P.S. The integration with Scala and Lift is working out really smooth 🙂
> 
> --  
> Diego Medina  
> Web Developer  
> [diego@fmpwizard.com](mailto:diego@fmpwizard.com)  
> [http://www.fmpwizard.com](http://www.fmpwizard.com)

---

<div class="post-metadata">

**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\
**Post date:** [July 6, 2017, 3:47am UTC](https://discuss.elastic.co/t/check-if-node-is-listening-before-sending-a-request/5957/3 "2017-07-06T03:47:36Z")

</div>

Closed on July 6, 2017, 3:47am UTC