Data Archiving Service can't connect to Fuseki

[KMax]

If the service can't connect to Fuseki at the first time, then it should try to connect in 30 seconds while it's not connected, in example.

dataarchivingservice_1   | HTTP/1.1 200 OK
dataarchivingservice_1   | Content-Type: text/html
dataarchivingservice_1   | Last-Modified: Sun, 08 Mar 2015 09:49:16 GMT
dataarchivingservice_1   | Accept-Ranges: bytes
dataarchivingservice_1   | Content-Length: 4216
dataarchivingservice_1   | Server: Jetty(9.1.z-SNAPSHOT)
dataarchivingservice_1   | 
dataarchivingservice_1   | HTTP/1.1 200 OK
dataarchivingservice_1   | Content-Type: text/html; charset=UTF-8
dataarchivingservice_1   | Content-Length: 1152
dataarchivingservice_1   | 
dataarchivingservice_1   | Wed Oct 21 18:14:10 UTC 2015 - connected successfully
dataarchivingservice_1   | 18:14:11.621 [main] DEBUG r.s.s.d.Launcher - Connecting to ws://wamprouter:8080/ws
dataarchivingservice_1   | 18:14:11.805 [WampClientEventLoop] INFO  r.s.s.d.Launcher - Connected to ws://wamprouter:8080/ws
dataarchivingservice_1   | 18:14:11.806 [WampClientEventLoop] INFO  r.s.s.d.WAMPClient - Made subscription to ru.semiot.devices.newandobserving
dataarchivingservice_1   | 18:14:12.411 [WampClientEventLoop] WARN  i.n.channel.DefaultChannelPipeline - An exceptionCaught() event was fired, and it reached at the tail of the pipeline. It usually means the last handler in the pipeline did not handle the exception.
dataarchivingservice_1   | rx.exceptions.OnErrorNotImplementedException: Unexpected error making the query: org.apache.http.conn.HttpHostConnectException: Connection to http://localhost:3030 refused
dataarchivingservice_1   |  at rx.Observable$32.onError(Observable.java:7322) ~[data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at rx.observers.SafeSubscriber._onError(SafeSubscriber.java:154) ~[data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at rx.observers.SafeSubscriber.onError(SafeSubscriber.java:111) ~[data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at rx.observers.SafeSubscriber.onNext(SafeSubscriber.java:137) ~[data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at rx.internal.operators.NotificationLite.accept(NotificationLite.java:150) ~[data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at rx.subjects.SubjectSubscriptionManager$SubjectObserver.emitNext(SubjectSubscriptionManager.java:254) ~[data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at rx.subjects.BehaviorSubject.onNext(BehaviorSubject.java:159) ~[data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at ws.wamp.jawampa.WampClient.onMessageReceived(WampClient.java:547) ~[data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at ws.wamp.jawampa.WampClient.access$3(WampClient.java:516) ~[data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at ws.wamp.jawampa.WampClient$SessionHandler.channelRead0(WampClient.java:359) ~[data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at ws.wamp.jawampa.WampClient$SessionHandler.channelRead0(WampClient.java:1) ~[data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105) ~[data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333) [data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319) [data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103) [data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333) [data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319) [data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at ws.wamp.jawampa.transport.WampClientWebsocketHandler.channelRead(WampClientWebsocketHandler.java:59) [data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333) [data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319) [data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103) [data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333) [data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319) [data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103) [data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333) [data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319) [data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103) [data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333) [data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319) [data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:161) [data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333) [data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319) [data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:787) [data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:130) [data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:511) [data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468) [data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382) [data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354) [data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) [data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at java.lang.Thread.run(Thread.java:745) [na:1.8.0_60]
dataarchivingservice_1   | Caused by: com.hp.hpl.jena.sparql.engine.http.QueryExceptionHTTP: Unexpected error making the query: org.apache.http.conn.HttpHostConnectException: Connection to http://localhost:3030 refused
dataarchivingservice_1   |  at com.hp.hpl.jena.sparql.engine.http.HttpQuery.rewrap(HttpQuery.java:417) ~[data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at com.hp.hpl.jena.sparql.engine.http.HttpQuery.execGet(HttpQuery.java:358) ~[data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at com.hp.hpl.jena.sparql.engine.http.HttpQuery.exec(HttpQuery.java:295) ~[data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at com.hp.hpl.jena.sparql.engine.http.QueryEngineHTTP.execResultSetInner(QueryEngineHTTP.java:346) ~[data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at com.hp.hpl.jena.sparql.engine.http.QueryEngineHTTP.execSelect(QueryEngineHTTP.java:338) ~[data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at ru.semiot.services.data_archiving_service.SubscribeListener.subscribeTopics(SubscribeListener.java:92) ~[data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at ru.semiot.services.data_archiving_service.SubscribeListener.<init>(SubscribeListener.java:45) ~[data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at ru.semiot.services.data_archiving_service.Launcher.lambda$run$0(Launcher.java:36) ~[data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at rx.Observable$32.onNext(Observable.java:7327) ~[data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at rx.observers.SafeSubscriber.onNext(SafeSubscriber.java:130) ~[data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  ... 36 common frames omitted
dataarchivingservice_1   | Caused by: org.apache.http.conn.HttpHostConnectException: Connection to http://localhost:3030 refused
dataarchivingservice_1   |  at org.apache.http.impl.conn.DefaultClientConnectionOperator.openConnection(DefaultClientConnectionOperator.java:190) ~[data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at org.apache.http.impl.conn.ManagedClientConnectionImpl.open(ManagedClientConnectionImpl.java:294) ~[data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at org.apache.http.impl.client.DefaultRequestDirector.tryConnect(DefaultRequestDirector.java:643) ~[data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at org.apache.http.impl.client.DefaultRequestDirector.execute(DefaultRequestDirector.java:479) ~[data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at org.apache.http.impl.client.AbstractHttpClient.execute(AbstractHttpClient.java:906) ~[data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at org.apache.http.impl.client.DecompressingHttpClient.execute(DecompressingHttpClient.java:137) ~[data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at org.apache.http.impl.client.DecompressingHttpClient.execute(DecompressingHttpClient.java:118) ~[data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at org.apache.jena.riot.web.HttpOp.exec(HttpOp.java:1108) ~[data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at org.apache.jena.riot.web.HttpOp.execHttpGet(HttpOp.java:385) ~[data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at org.apache.jena.riot.web.HttpOp.execHttpGet(HttpOp.java:447) ~[data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at com.hp.hpl.jena.sparql.engine.http.HttpQuery.execGet(HttpQuery.java:346) ~[data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  ... 44 common frames omitted
dataarchivingservice_1   | Caused by: java.net.ConnectException: Connection refused
dataarchivingservice_1   |  at java.net.PlainSocketImpl.socketConnect(Native Method) ~[na:1.8.0_60]
dataarchivingservice_1   |  at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350) ~[na:1.8.0_60]
dataarchivingservice_1   |  at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206) ~[na:1.8.0_60]
dataarchivingservice_1   |  at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188) ~[na:1.8.0_60]
dataarchivingservice_1   |  at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392) ~[na:1.8.0_60]
dataarchivingservice_1   |  at java.net.Socket.connect(Socket.java:589) ~[na:1.8.0_60]
dataarchivingservice_1   |  at org.apache.http.conn.scheme.PlainSocketFactory.connectSocket(PlainSocketFactory.java:127) ~[data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  at org.apache.http.impl.conn.DefaultClientConnectionOperator.openConnection(DefaultClientConnectionOperator.java:180) ~[data-archiving-service-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
dataarchivingservice_1   |  ... 54 common frames omitted