Session closed but no message received from address: localhost/127.0.0.1:9999 when using camel-mina

[fab_can]

hello I am trying to build a route to proxy http traffic via camel-mina (I know of jetty and http endpoints but they are not suitable for my case). I have been trying all I can to make it work but still i haven't succeeded. The point I am at is that the request gets successfully to the to() endpoint but for whatever reason the response is never propagated back to the originating client.

the route looks like

    from("mina:tcp://localhost:8888?codec=#httpMinaCodec&sync=true&minaLogger=true&lazySessionCreation=true")
    .to("mina:tcp://localhost:9999?codec=#httpMinaCodec&sync=true&minaLogger=true&lazySessionCreation=true&timeout=10000");


and, with trace on the log looks like

[          AnonymousIoService-6] DefaultProducerServicePool     TRACE Acquire: Endpoint[mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000] service: Producer[mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000]
[          AnonymousIoService-6] MinaProducer                   DEBUG Creating connector to address: localhost/127.0.0.1:9999 using connector: org.apache.mina.transport.socket.nio.SocketConnector@c8d62f timeout: 10000 millis.
[SocketConnectorIoProcessor-1.0] MinaProducer$ResponseHandler   INFO  [localhost/127.0.0.1:9999] CREATED
[SocketConnectorIoProcessor-1.0] ExecutorFilter                 DEBUG Launching thread for localhost/127.0.0.1:9999
[          AnonymousIoService-7] MinaProducer$ResponseHandler   INFO  [localhost/127.0.0.1:9999] OPENED
[          AnonymousIoService-7] ExecutorFilter                 DEBUG Exiting since queue is empty for localhost/127.0.0.1:9999
[          AnonymousIoService-6] MinaProducer                   DEBUG Writing body : GET / HTTP/1.1
User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g zlib/1.2.3.3 libidn/1.8
Host: localhost:8888
Accept: */*


[          AnonymousIoService-6] MinaProducer$ResponseHandler   INFO  [localhost/127.0.0.1:9999] WRITE: GET / HTTP/1.1
User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g zlib/1.2.3.3 libidn/1.8
Host: localhost:8888
Accept: */*


Encoding message: GET / HTTP/1.1
User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g zlib/1.2.3.3 libidn/1.8
Host: localhost:8888
Accept: */*


[SocketConnectorIoProcessor-1.0] ExecutorFilter                 DEBUG Launching thread for localhost/127.0.0.1:9999
[          AnonymousIoService-8] ExecutorFilter                 DEBUG Exiting since queue is empty for localhost/127.0.0.1:9999
[          AnonymousIoService-6] MinaProducer                   DEBUG Waiting for response. Timeout: 10000
[SocketConnectorIoProcessor-1.0] ExecutorFilter                 DEBUG Launching thread for localhost/127.0.0.1:9999
[          AnonymousIoService-9] MinaProducer$ResponseHandler   INFO  [localhost/127.0.0.1:9999] SENT: GET / HTTP/1.1
User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g zlib/1.2.3.3 libidn/1.8
Host: localhost:8888
Accept: */*


[          AnonymousIoService-9] ExecutorFilter                 DEBUG Exiting since queue is empty for localhost/127.0.0.1:9999
[SocketConnectorIoProcessor-1.0] ExecutorFilter                 DEBUG Launching thread for localhost/127.0.0.1:9999
[         AnonymousIoService-10] ExecutorFilter                 DEBUG Exiting since queue is empty for localhost/127.0.0.1:9999
[SocketConnectorIoProcessor-1.0] ExecutorFilter                 DEBUG Launching thread for localhost/127.0.0.1:9999
[         AnonymousIoService-11] MinaProducer$ResponseHandler   INFO  [localhost/127.0.0.1:9999] CLOSED
[         AnonymousIoService-11] MinaProducer                   DEBUG Session closed but no message received from address: localhost/127.0.0.1:9999
[          AnonymousIoService-6] DefaultProducerServicePool     TRACE Release: Endpoint[mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000] service: Producer[mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000]
[          AnonymousIoService-6] DefaultTypeConverter           TRACE Converting com.myapp.mina.HttpMessage -> org.apache.camel.StreamCache with value: GET / HTTP/1.1
User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g zlib/1.2.3.3 libidn/1.8
Host: localhost:8888
Accept: */*


[          AnonymousIoService-6] DefaultTypeConverter           TRACE Converting org.apache.camel.impl.DefaultMessage -> org.apache.camel.StreamCache with value: Message: GET / HTTP/1.1
User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g zlib/1.2.3.3 libidn/1.8
Host: localhost:8888
Accept: */*


[          AnonymousIoService-6] DefaultTypeConverter           TRACE Converting com.myapp.mina.HttpMessage -> java.lang.String with value: GET / HTTP/1.1
User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g zlib/1.2.3.3 libidn/1.8
Host: localhost:8888
Accept: */*


[          AnonymousIoService-6] TraceInterceptor               INFO  ID-fc-laptop-56193-1257383273772-0-1 >>> from(mina://tcp://localhost:8888?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true) --> mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000, Pattern:InOut, BodyType:com.myapp.mina.HttpMessage, Body:GET / HTTP/1.1
User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g zlib/1.2.3.3 libidn/1.8
Host: localhost:8888
Accept: */*

, Exception: org.apache.camel.CamelExchangeException: No response received from remote server: mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000 on the exchange: Exchange[Message: GET / HTTP/1.1
User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g zlib/1.2.3.3 libidn/1.8
Host: localhost:8888
Accept: */*

I am really stuck here, so any help would be appreciated

thanks
fabrizio

[Claus Ibsen-2]

Hi

Do you have some server running and listening on port 9999 ???
The logs indicate that no response is received.

If you use wget or the likes from the cmd line can you access port
9999 and get a reply back?


On Thu, Nov 5, 2009 at 2:52 AM, fab_can <fabrizio.cannizzo@...> wrote:

>
> hello I am trying to build a route to proxy http traffic via camel-mina (I
> know of jetty and http endpoints but they are not suitable for my case). I
> have been trying all I can to make it work but still i haven't succeeded.
> The point I am at is that the request gets successfully to the to() endpoint
> but for whatever reason the response is never propagated back to the
> originating client.
>
> the route looks like
>
>
> from("mina:tcp://localhost:8888?codec=#httpMinaCodec&sync=true&minaLogger=true&lazySessionCreation=true")
>
> .to("mina:tcp://localhost:9999?codec=#httpMinaCodec&sync=true&minaLogger=true&lazySessionCreation=true&timeout=10000");
>
>
> and, with trace on the log looks like
>
> [          AnonymousIoService-6] DefaultProducerServicePool     TRACE
> Acquire:
> Endpoint[mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000]
> service:
> Producer[mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000]
> [          AnonymousIoService-6] MinaProducer                   DEBUG
> Creating connector to address: localhost/127.0.0.1:9999 using connector:
> org.apache.mina.transport.socket.nio.SocketConnector@c8d62f timeout: 10000
> millis.
> [SocketConnectorIoProcessor-1.0] MinaProducer$ResponseHandler   INFO
> [localhost/127.0.0.1:9999] CREATED
> [SocketConnectorIoProcessor-1.0] ExecutorFilter                 DEBUG
> Launching thread for localhost/127.0.0.1:9999
> [          AnonymousIoService-7] MinaProducer$ResponseHandler   INFO
> [localhost/127.0.0.1:9999] OPENED
> [          AnonymousIoService-7] ExecutorFilter                 DEBUG
> Exiting since queue is empty for localhost/127.0.0.1:9999
> [          AnonymousIoService-6] MinaProducer                   DEBUG
> Writing body : GET / HTTP/1.1
> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
> zlib/1.2.3.3 libidn/1.8
> Host: localhost:8888
> Accept: */*
>
>
> [          AnonymousIoService-6] MinaProducer$ResponseHandler   INFO
> [localhost/127.0.0.1:9999] WRITE: GET / HTTP/1.1
> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
> zlib/1.2.3.3 libidn/1.8
> Host: localhost:8888
> Accept: */*
>
>
> Encoding message: GET / HTTP/1.1
> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
> zlib/1.2.3.3 libidn/1.8
> Host: localhost:8888
> Accept: */*
>
>
> [SocketConnectorIoProcessor-1.0] ExecutorFilter                 DEBUG
> Launching thread for localhost/127.0.0.1:9999
> [          AnonymousIoService-8] ExecutorFilter                 DEBUG
> Exiting since queue is empty for localhost/127.0.0.1:9999
> [          AnonymousIoService-6] MinaProducer                   DEBUG
> Waiting for response. Timeout: 10000
> [SocketConnectorIoProcessor-1.0] ExecutorFilter                 DEBUG
> Launching thread for localhost/127.0.0.1:9999
> [          AnonymousIoService-9] MinaProducer$ResponseHandler   INFO
> [localhost/127.0.0.1:9999] SENT: GET / HTTP/1.1
> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
> zlib/1.2.3.3 libidn/1.8
> Host: localhost:8888
> Accept: */*
>
>
> [          AnonymousIoService-9] ExecutorFilter                 DEBUG
> Exiting since queue is empty for localhost/127.0.0.1:9999
> [SocketConnectorIoProcessor-1.0] ExecutorFilter                 DEBUG
> Launching thread for localhost/127.0.0.1:9999
> [         AnonymousIoService-10] ExecutorFilter                 DEBUG
> Exiting since queue is empty for localhost/127.0.0.1:9999
> [SocketConnectorIoProcessor-1.0] ExecutorFilter                 DEBUG
> Launching thread for localhost/127.0.0.1:9999
> [         AnonymousIoService-11] MinaProducer$ResponseHandler   INFO
> [localhost/127.0.0.1:9999] CLOSED
> [         AnonymousIoService-11] MinaProducer                   DEBUG
> Session closed but no message received from address:
> localhost/127.0.0.1:9999
> [          AnonymousIoService-6] DefaultProducerServicePool     TRACE
> Release:
> Endpoint[mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000]
> service:
> Producer[mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000]
> [          AnonymousIoService-6] DefaultTypeConverter           TRACE
> Converting com.myapp.mina.HttpMessage -> org.apache.camel.StreamCache with
> value: GET / HTTP/1.1
> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
> zlib/1.2.3.3 libidn/1.8
> Host: localhost:8888
> Accept: */*
>
>
> [          AnonymousIoService-6] DefaultTypeConverter           TRACE
> Converting org.apache.camel.impl.DefaultMessage ->
> org.apache.camel.StreamCache with value: Message: GET / HTTP/1.1
> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
> zlib/1.2.3.3 libidn/1.8
> Host: localhost:8888
> Accept: */*
>
>
> [          AnonymousIoService-6] DefaultTypeConverter           TRACE
> Converting com.myapp.mina.HttpMessage -> java.lang.String with value: GET /
> HTTP/1.1
> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
> zlib/1.2.3.3 libidn/1.8
> Host: localhost:8888
> Accept: */*
>
>
> [          AnonymousIoService-6] TraceInterceptor               INFO
> ID-fc-laptop-56193-1257383273772-0-1 >>>
> from(mina://tcp://localhost:8888?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true)
> -->
> mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000,
> Pattern:InOut, BodyType:com.myapp.mina.HttpMessage, Body:GET / HTTP/1.1
> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
> zlib/1.2.3.3 libidn/1.8
> Host: localhost:8888
> Accept: */*
>
> , Exception: org.apache.camel.CamelExchangeException: No response received
> from remote server:
> mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000
> on the exchange: Exchange[Message: GET / HTTP/1.1
> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
> zlib/1.2.3.3 libidn/1.8
> Host: localhost:8888
> Accept: */*
>
> I am really stuck here, so any help would be appreciated
>
> thanks
> fabrizio
> --
> View this message in context: http://old.nabble.com/Session-closed-but-no-message-received-from-address%3A-localhost-127.0.0.1%3A9999-when-using-camel-mina-tp26207954p26207954.html
> Sent from the Camel Development mailing list archive at Nabble.com.
>
>

--
Claus Ibsen
Apache Camel Committer

Author of Camel in Action: http://www.manning.com/ibsen/
Open Source Integration: http://fusesource.com
Blog: http://davsclaus.blogspot.com/
Twitter: http://twitter.com/davsclaus

[fab_can]

Hi Thanks for replying

Yes I have a server listening on port 9999 (a noddy http server) which works perfectly if invoked directly via curl or telnet

i will bundle a zip and upload the sample code i have to demonstrate the failing scenario

BTW - i use camel 2.0 and mina 1.1.7

cheers

fabrizio

Claus Ibsen-2 wrote:

Hi

Do you have some server running and listening on port 9999 ???
The logs indicate that no response is received.

If you use wget or the likes from the cmd line can you access port
9999 and get a reply back?


On Thu, Nov 5, 2009 at 2:52 AM, fab_can <[e-mail]> wrote:
>
> hello I am trying to build a route to proxy http traffic via camel-mina (I
> know of jetty and http endpoints but they are not suitable for my case). I
> have been trying all I can to make it work but still i haven't succeeded.
> The point I am at is that the request gets successfully to the to() endpoint
> but for whatever reason the response is never propagated back to the
> originating client.
>
> the route looks like
>
>
> from("mina:tcp://localhost:8888?codec=#httpMinaCodec&sync=true&minaLogger=true&lazySessionCreation=true")
>
> .to("mina:tcp://localhost:9999?codec=#httpMinaCodec&sync=true&minaLogger=true&lazySessionCreation=true&timeout=10000");
>
>
> and, with trace on the log looks like
>
> [          AnonymousIoService-6] DefaultProducerServicePool     TRACE
> Acquire:
> Endpoint[mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000]
> service:
> Producer[mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000]
> [          AnonymousIoService-6] MinaProducer                   DEBUG
> Creating connector to address: localhost/127.0.0.1:9999 using connector:
> org.apache.mina.transport.socket.nio.SocketConnector@c8d62f timeout: 10000
> millis.
> [SocketConnectorIoProcessor-1.0] MinaProducer$ResponseHandler   INFO
> [localhost/127.0.0.1:9999] CREATED
> [SocketConnectorIoProcessor-1.0] ExecutorFilter                 DEBUG
> Launching thread for localhost/127.0.0.1:9999
> [          AnonymousIoService-7] MinaProducer$ResponseHandler   INFO
> [localhost/127.0.0.1:9999] OPENED
> [          AnonymousIoService-7] ExecutorFilter                 DEBUG
> Exiting since queue is empty for localhost/127.0.0.1:9999
> [          AnonymousIoService-6] MinaProducer                   DEBUG
> Writing body : GET / HTTP/1.1
> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
> zlib/1.2.3.3 libidn/1.8
> Host: localhost:8888
> Accept: */*
>
>
> [          AnonymousIoService-6] MinaProducer$ResponseHandler   INFO
> [localhost/127.0.0.1:9999] WRITE: GET / HTTP/1.1
> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
> zlib/1.2.3.3 libidn/1.8
> Host: localhost:8888
> Accept: */*
>
>
> Encoding message: GET / HTTP/1.1
> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
> zlib/1.2.3.3 libidn/1.8
> Host: localhost:8888
> Accept: */*
>
>
> [SocketConnectorIoProcessor-1.0] ExecutorFilter                 DEBUG
> Launching thread for localhost/127.0.0.1:9999
> [          AnonymousIoService-8] ExecutorFilter                 DEBUG
> Exiting since queue is empty for localhost/127.0.0.1:9999
> [          AnonymousIoService-6] MinaProducer                   DEBUG
> Waiting for response. Timeout: 10000
> [SocketConnectorIoProcessor-1.0] ExecutorFilter                 DEBUG
> Launching thread for localhost/127.0.0.1:9999
> [          AnonymousIoService-9] MinaProducer$ResponseHandler   INFO
> [localhost/127.0.0.1:9999] SENT: GET / HTTP/1.1
> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
> zlib/1.2.3.3 libidn/1.8
> Host: localhost:8888
> Accept: */*
>
>
> [          AnonymousIoService-9] ExecutorFilter                 DEBUG
> Exiting since queue is empty for localhost/127.0.0.1:9999
> [SocketConnectorIoProcessor-1.0] ExecutorFilter                 DEBUG
> Launching thread for localhost/127.0.0.1:9999
> [         AnonymousIoService-10] ExecutorFilter                 DEBUG
> Exiting since queue is empty for localhost/127.0.0.1:9999
> [SocketConnectorIoProcessor-1.0] ExecutorFilter                 DEBUG
> Launching thread for localhost/127.0.0.1:9999
> [         AnonymousIoService-11] MinaProducer$ResponseHandler   INFO
> [localhost/127.0.0.1:9999] CLOSED
> [         AnonymousIoService-11] MinaProducer                   DEBUG
> Session closed but no message received from address:
> localhost/127.0.0.1:9999
> [          AnonymousIoService-6] DefaultProducerServicePool     TRACE
> Release:
> Endpoint[mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000]
> service:
> Producer[mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000]
> [          AnonymousIoService-6] DefaultTypeConverter           TRACE
> Converting com.myapp.mina.HttpMessage -> org.apache.camel.StreamCache with
> value: GET / HTTP/1.1
> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
> zlib/1.2.3.3 libidn/1.8
> Host: localhost:8888
> Accept: */*
>
>
> [          AnonymousIoService-6] DefaultTypeConverter           TRACE
> Converting org.apache.camel.impl.DefaultMessage ->
> org.apache.camel.StreamCache with value: Message: GET / HTTP/1.1
> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
> zlib/1.2.3.3 libidn/1.8
> Host: localhost:8888
> Accept: */*
>
>
> [          AnonymousIoService-6] DefaultTypeConverter           TRACE
> Converting com.myapp.mina.HttpMessage -> java.lang.String with value: GET /
> HTTP/1.1
> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
> zlib/1.2.3.3 libidn/1.8
> Host: localhost:8888
> Accept: */*
>
>
> [          AnonymousIoService-6] TraceInterceptor               INFO
> ID-fc-laptop-56193-1257383273772-0-1 >>>
> from(mina://tcp://localhost:8888?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true)
> -->
> mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000,
> Pattern:InOut, BodyType:com.myapp.mina.HttpMessage, Body:GET / HTTP/1.1
> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
> zlib/1.2.3.3 libidn/1.8
> Host: localhost:8888
> Accept: */*
>
> , Exception: org.apache.camel.CamelExchangeException: No response received
> from remote server:
> mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000
> on the exchange: Exchange[Message: GET / HTTP/1.1
> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
> zlib/1.2.3.3 libidn/1.8
> Host: localhost:8888
> Accept: */*
>
> I am really stuck here, so any help would be appreciated
>
> thanks
> fabrizio
> --
> View this message in context: http://old.nabble.com/Session-closed-but-no-message-received-from-address%3A-localhost-127.0.0.1%3A9999-when-using-camel-mina-tp26207954p26207954.html
> Sent from the Camel Development mailing list archive at Nabble.com.
>
>



--
Claus Ibsen
Apache Camel Committer

Author of Camel in Action: http://www.manning.com/ibsen/
Open Source Integration: http://fusesource.com
Blog: http://davsclaus.blogspot.com/
Twitter: http://twitter.com/davsclaus

[fab_can]

Hi Claus

i am attaching a simple eclipse project with code that demonstrates the issue.
mina-routing.tgz
there's a Server class that acts as a listener on port 9999 (connecting to it via wget/curl/telnet works for me). There's also a Client class that can send requests direct and via camel (on port 8888).
there's also a class HttpProxyBuilder with the route and a main method to start the context.

i haven't included the camel libs in the project, so you'll have to define an eclipse build variable called camel.home to point to a camel 2 distro

Any help would be much appreciated

regards

fabrizio

Claus Ibsen-2 wrote:

Hi

Do you have some server running and listening on port 9999 ???
The logs indicate that no response is received.

If you use wget or the likes from the cmd line can you access port
9999 and get a reply back?


On Thu, Nov 5, 2009 at 2:52 AM, fab_can <[e-mail]> wrote:
>
> hello I am trying to build a route to proxy http traffic via camel-mina (I
> know of jetty and http endpoints but they are not suitable for my case). I
> have been trying all I can to make it work but still i haven't succeeded.
> The point I am at is that the request gets successfully to the to() endpoint
> but for whatever reason the response is never propagated back to the
> originating client.
>
> the route looks like
>
>
> from("mina:tcp://localhost:8888?codec=#httpMinaCodec&sync=true&minaLogger=true&lazySessionCreation=true")
>
> .to("mina:tcp://localhost:9999?codec=#httpMinaCodec&sync=true&minaLogger=true&lazySessionCreation=true&timeout=10000");
>
>
> and, with trace on the log looks like
>
> [          AnonymousIoService-6] DefaultProducerServicePool     TRACE
> Acquire:
> Endpoint[mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000]
> service:
> Producer[mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000]
> [          AnonymousIoService-6] MinaProducer                   DEBUG
> Creating connector to address: localhost/127.0.0.1:9999 using connector:
> org.apache.mina.transport.socket.nio.SocketConnector@c8d62f timeout: 10000
> millis.
> [SocketConnectorIoProcessor-1.0] MinaProducer$ResponseHandler   INFO
> [localhost/127.0.0.1:9999] CREATED
> [SocketConnectorIoProcessor-1.0] ExecutorFilter                 DEBUG
> Launching thread for localhost/127.0.0.1:9999
> [          AnonymousIoService-7] MinaProducer$ResponseHandler   INFO
> [localhost/127.0.0.1:9999] OPENED
> [          AnonymousIoService-7] ExecutorFilter                 DEBUG
> Exiting since queue is empty for localhost/127.0.0.1:9999
> [          AnonymousIoService-6] MinaProducer                   DEBUG
> Writing body : GET / HTTP/1.1
> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
> zlib/1.2.3.3 libidn/1.8
> Host: localhost:8888
> Accept: */*
>
>
> [          AnonymousIoService-6] MinaProducer$ResponseHandler   INFO
> [localhost/127.0.0.1:9999] WRITE: GET / HTTP/1.1
> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
> zlib/1.2.3.3 libidn/1.8
> Host: localhost:8888
> Accept: */*
>
>
> Encoding message: GET / HTTP/1.1
> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
> zlib/1.2.3.3 libidn/1.8
> Host: localhost:8888
> Accept: */*
>
>
> [SocketConnectorIoProcessor-1.0] ExecutorFilter                 DEBUG
> Launching thread for localhost/127.0.0.1:9999
> [          AnonymousIoService-8] ExecutorFilter                 DEBUG
> Exiting since queue is empty for localhost/127.0.0.1:9999
> [          AnonymousIoService-6] MinaProducer                   DEBUG
> Waiting for response. Timeout: 10000
> [SocketConnectorIoProcessor-1.0] ExecutorFilter                 DEBUG
> Launching thread for localhost/127.0.0.1:9999
> [          AnonymousIoService-9] MinaProducer$ResponseHandler   INFO
> [localhost/127.0.0.1:9999] SENT: GET / HTTP/1.1
> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
> zlib/1.2.3.3 libidn/1.8
> Host: localhost:8888
> Accept: */*
>
>
> [          AnonymousIoService-9] ExecutorFilter                 DEBUG
> Exiting since queue is empty for localhost/127.0.0.1:9999
> [SocketConnectorIoProcessor-1.0] ExecutorFilter                 DEBUG
> Launching thread for localhost/127.0.0.1:9999
> [         AnonymousIoService-10] ExecutorFilter                 DEBUG
> Exiting since queue is empty for localhost/127.0.0.1:9999
> [SocketConnectorIoProcessor-1.0] ExecutorFilter                 DEBUG
> Launching thread for localhost/127.0.0.1:9999
> [         AnonymousIoService-11] MinaProducer$ResponseHandler   INFO
> [localhost/127.0.0.1:9999] CLOSED
> [         AnonymousIoService-11] MinaProducer                   DEBUG
> Session closed but no message received from address:
> localhost/127.0.0.1:9999
> [          AnonymousIoService-6] DefaultProducerServicePool     TRACE
> Release:
> Endpoint[mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000]
> service:
> Producer[mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000]
> [          AnonymousIoService-6] DefaultTypeConverter           TRACE
> Converting com.myapp.mina.HttpMessage -> org.apache.camel.StreamCache with
> value: GET / HTTP/1.1
> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
> zlib/1.2.3.3 libidn/1.8
> Host: localhost:8888
> Accept: */*
>
>
> [          AnonymousIoService-6] DefaultTypeConverter           TRACE
> Converting org.apache.camel.impl.DefaultMessage ->
> org.apache.camel.StreamCache with value: Message: GET / HTTP/1.1
> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
> zlib/1.2.3.3 libidn/1.8
> Host: localhost:8888
> Accept: */*
>
>
> [          AnonymousIoService-6] DefaultTypeConverter           TRACE
> Converting com.myapp.mina.HttpMessage -> java.lang.String with value: GET /
> HTTP/1.1
> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
> zlib/1.2.3.3 libidn/1.8
> Host: localhost:8888
> Accept: */*
>
>
> [          AnonymousIoService-6] TraceInterceptor               INFO
> ID-fc-laptop-56193-1257383273772-0-1 >>>
> from(mina://tcp://localhost:8888?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true)
> -->
> mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000,
> Pattern:InOut, BodyType:com.myapp.mina.HttpMessage, Body:GET / HTTP/1.1
> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
> zlib/1.2.3.3 libidn/1.8
> Host: localhost:8888
> Accept: */*
>
> , Exception: org.apache.camel.CamelExchangeException: No response received
> from remote server:
> mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000
> on the exchange: Exchange[Message: GET / HTTP/1.1
> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
> zlib/1.2.3.3 libidn/1.8
> Host: localhost:8888
> Accept: */*
>
> I am really stuck here, so any help would be appreciated
>
> thanks
> fabrizio
> --
> View this message in context: http://old.nabble.com/Session-closed-but-no-message-received-from-address%3A-localhost-127.0.0.1%3A9999-when-using-camel-mina-tp26207954p26207954.html
> Sent from the Camel Development mailing list archive at Nabble.com.
>
>



--
Claus Ibsen
Apache Camel Committer

Author of Camel in Action: http://www.manning.com/ibsen/
Open Source Integration: http://fusesource.com
Blog: http://davsclaus.blogspot.com/
Twitter: http://twitter.com/davsclaus

[Claus Ibsen-2]

Hi

Sorry I dont have time to do problem solving in my spare time.

Try making you example simpler and see that piece by piece works until
it breaks.


On Fri, Nov 6, 2009 at 2:51 PM, fab_can <fabrizio.cannizzo@...> wrote:

>
> Hi Claus
>
> i am attaching a simple eclipse project with code that demonstrates the
> issue.
> http://old.nabble.com/file/p26230522/mina-routing.tgz mina-routing.tgz
> there's a Server class that acts as a listener on port 9999 (connecting to
> it via wget/curl/telnet works for me). There's also a Client class that can
> send requests direct and via camel (on port 8888).
> there's also a class HttpProxyBuilder with the route and a main method to
> start the context.
>
> i haven't included the camel libs in the project, so you'll have to define
> an eclipse build variable called camel.home to point to a camel 2 distro
>
> Any help would be much appreciated
>
> regards
>
> fabrizio
>
>
>
> Claus Ibsen-2 wrote:
>>
>> Hi
>>
>> Do you have some server running and listening on port 9999 ???
>> The logs indicate that no response is received.
>>
>> If you use wget or the likes from the cmd line can you access port
>> 9999 and get a reply back?
>>
>>
>> On Thu, Nov 5, 2009 at 2:52 AM, fab_can <fabrizio.cannizzo@...> wrote:
>>>
>>> hello I am trying to build a route to proxy http traffic via camel-mina
>>> (I
>>> know of jetty and http endpoints but they are not suitable for my case).
>>> I
>>> have been trying all I can to make it work but still i haven't succeeded.
>>> The point I am at is that the request gets successfully to the to()
>>> endpoint
>>> but for whatever reason the response is never propagated back to the
>>> originating client.
>>>
>>> the route looks like
>>>
>>>
>>> from("mina:tcp://localhost:8888?codec=#httpMinaCodec&sync=true&minaLogger=true&lazySessionCreation=true")
>>>
>>> .to("mina:tcp://localhost:9999?codec=#httpMinaCodec&sync=true&minaLogger=true&lazySessionCreation=true&timeout=10000");
>>>
>>>
>>> and, with trace on the log looks like
>>>
>>> [          AnonymousIoService-6] DefaultProducerServicePool     TRACE
>>> Acquire:
>>> Endpoint[mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000]
>>> service:
>>> Producer[mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000]
>>> [          AnonymousIoService-6] MinaProducer                   DEBUG
>>> Creating connector to address: localhost/127.0.0.1:9999 using connector:
>>> org.apache.mina.transport.socket.nio.SocketConnector@c8d62f timeout:
>>> 10000
>>> millis.
>>> [SocketConnectorIoProcessor-1.0] MinaProducer$ResponseHandler   INFO
>>> [localhost/127.0.0.1:9999] CREATED
>>> [SocketConnectorIoProcessor-1.0] ExecutorFilter                 DEBUG
>>> Launching thread for localhost/127.0.0.1:9999
>>> [          AnonymousIoService-7] MinaProducer$ResponseHandler   INFO
>>> [localhost/127.0.0.1:9999] OPENED
>>> [          AnonymousIoService-7] ExecutorFilter                 DEBUG
>>> Exiting since queue is empty for localhost/127.0.0.1:9999
>>> [          AnonymousIoService-6] MinaProducer                   DEBUG
>>> Writing body : GET / HTTP/1.1
>>> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
>>> zlib/1.2.3.3 libidn/1.8
>>> Host: localhost:8888
>>> Accept: */*
>>>
>>>
>>> [          AnonymousIoService-6] MinaProducer$ResponseHandler   INFO
>>> [localhost/127.0.0.1:9999] WRITE: GET / HTTP/1.1
>>> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
>>> zlib/1.2.3.3 libidn/1.8
>>> Host: localhost:8888
>>> Accept: */*
>>>
>>>
>>> Encoding message: GET / HTTP/1.1
>>> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
>>> zlib/1.2.3.3 libidn/1.8
>>> Host: localhost:8888
>>> Accept: */*
>>>
>>>
>>> [SocketConnectorIoProcessor-1.0] ExecutorFilter                 DEBUG
>>> Launching thread for localhost/127.0.0.1:9999
>>> [          AnonymousIoService-8] ExecutorFilter                 DEBUG
>>> Exiting since queue is empty for localhost/127.0.0.1:9999
>>> [          AnonymousIoService-6] MinaProducer                   DEBUG
>>> Waiting for response. Timeout: 10000
>>> [SocketConnectorIoProcessor-1.0] ExecutorFilter                 DEBUG
>>> Launching thread for localhost/127.0.0.1:9999
>>> [          AnonymousIoService-9] MinaProducer$ResponseHandler   INFO
>>> [localhost/127.0.0.1:9999] SENT: GET / HTTP/1.1
>>> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
>>> zlib/1.2.3.3 libidn/1.8
>>> Host: localhost:8888
>>> Accept: */*
>>>
>>>
>>> [          AnonymousIoService-9] ExecutorFilter                 DEBUG
>>> Exiting since queue is empty for localhost/127.0.0.1:9999
>>> [SocketConnectorIoProcessor-1.0] ExecutorFilter                 DEBUG
>>> Launching thread for localhost/127.0.0.1:9999
>>> [         AnonymousIoService-10] ExecutorFilter                 DEBUG
>>> Exiting since queue is empty for localhost/127.0.0.1:9999
>>> [SocketConnectorIoProcessor-1.0] ExecutorFilter                 DEBUG
>>> Launching thread for localhost/127.0.0.1:9999
>>> [         AnonymousIoService-11] MinaProducer$ResponseHandler   INFO
>>> [localhost/127.0.0.1:9999] CLOSED
>>> [         AnonymousIoService-11] MinaProducer                   DEBUG
>>> Session closed but no message received from address:
>>> localhost/127.0.0.1:9999
>>> [          AnonymousIoService-6] DefaultProducerServicePool     TRACE
>>> Release:
>>> Endpoint[mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000]
>>> service:
>>> Producer[mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000]
>>> [          AnonymousIoService-6] DefaultTypeConverter           TRACE
>>> Converting com.myapp.mina.HttpMessage -> org.apache.camel.StreamCache
>>> with
>>> value: GET / HTTP/1.1
>>> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
>>> zlib/1.2.3.3 libidn/1.8
>>> Host: localhost:8888
>>> Accept: */*
>>>
>>>
>>> [          AnonymousIoService-6] DefaultTypeConverter           TRACE
>>> Converting org.apache.camel.impl.DefaultMessage ->
>>> org.apache.camel.StreamCache with value: Message: GET / HTTP/1.1
>>> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
>>> zlib/1.2.3.3 libidn/1.8
>>> Host: localhost:8888
>>> Accept: */*
>>>
>>>
>>> [          AnonymousIoService-6] DefaultTypeConverter           TRACE
>>> Converting com.myapp.mina.HttpMessage -> java.lang.String with value: GET
>>> /
>>> HTTP/1.1
>>> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
>>> zlib/1.2.3.3 libidn/1.8
>>> Host: localhost:8888
>>> Accept: */*
>>>
>>>
>>> [          AnonymousIoService-6] TraceInterceptor               INFO
>>> ID-fc-laptop-56193-1257383273772-0-1 >>>
>>> from(mina://tcp://localhost:8888?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true)
>>> -->
>>> mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000,
>>> Pattern:InOut, BodyType:com.myapp.mina.HttpMessage, Body:GET / HTTP/1.1
>>> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
>>> zlib/1.2.3.3 libidn/1.8
>>> Host: localhost:8888
>>> Accept: */*
>>>
>>> , Exception: org.apache.camel.CamelExchangeException: No response
>>> received
>>> from remote server:
>>> mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000
>>> on the exchange: Exchange[Message: GET / HTTP/1.1
>>> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
>>> zlib/1.2.3.3 libidn/1.8
>>> Host: localhost:8888
>>> Accept: */*
>>>
>>> I am really stuck here, so any help would be appreciated
>>>
>>> thanks
>>> fabrizio
>>> --
>>> View this message in context:
>>> http://old.nabble.com/Session-closed-but-no-message-received-from-address%3A-localhost-127.0.0.1%3A9999-when-using-camel-mina-tp26207954p26207954.html
>>> Sent from the Camel Development mailing list archive at Nabble.com.
>>>
>>>
>>
>>
>>
>> --
>> Claus Ibsen
>> Apache Camel Committer
>>
>> Author of Camel in Action: http://www.manning.com/ibsen/
>> Open Source Integration: http://fusesource.com
>> Blog: http://davsclaus.blogspot.com/
>> Twitter: http://twitter.com/davsclaus
>>
>>
>
> --
> View this message in context: http://old.nabble.com/Session-closed-but-no-message-received-from-address%3A-localhost-127.0.0.1%3A9999-when-using-camel-mina-tp26207954p26230522.html
> Sent from the Camel Development mailing list archive at Nabble.com.
>
>

--
Claus Ibsen
Apache Camel Committer

Author of Camel in Action: http://www.manning.com/ibsen/
Open Source Integration: http://fusesource.com
Blog: http://davsclaus.blogspot.com/
Twitter: http://twitter.com/davsclaus

[fab_can]

Yeah, sorry, the example was maybe overcomplicated. anyway i am able to reproduce the problem using textline=true.
given that the classpath is set this is the code to it's bare minimum follows.

// ---- code ----
package mina;

import org.apache.camel.builder.RouteBuilder;

public class Main  extends RouteBuilder {
        public static void main(String[] args) {
        org.apache.camel.spring.Main.main("-duration", "-1");
    }
    public void configure() {
        from("mina:tcp://localhost:8888").
                to("mina:tcp://localhost:8765");

    }

}

now, given you have an http server listening on port 8765:

2009-11-10 01:48:48.417::INFO:  jetty-6.1.5
2009-11-10 01:48:48.515::INFO:  Started SocketConnector@0.0.0.0:8765

i have used curl http://localhost:8888 and i get:

SocketAcceptorIoProcessor-0.0] ExecutorFilter                 DEBUG Launching thread for /127.0.0.1:44431
[          AnonymousIoService-1] MinaConsumer                   DEBUG Received body: GET / HTTP/1.1
[          AnonymousIoService-1] DefaultTypeConverter           TRACE Converting null -> java.lang.Boolean with value: null
[          AnonymousIoService-1] DefaultTypeConverter           TRACE Converting null -> java.lang.Boolean with value: null
[          AnonymousIoService-1] ServiceHelper                  TRACE Starting service: org.apache.camel.impl.DefaultProducerServicePool@d6b059
[          AnonymousIoService-1] DefaultProducerServicePool     TRACE No free services in pool to acquire for key: Endpoint[mina://tcp://localhost:8765?textline=true]
[          AnonymousIoService-1] MinaProducer                   DEBUG Starting producer: Producer[mina://tcp://localhost:8765?textline=true]
[          AnonymousIoService-1] ProducerCache                  DEBUG Adding to producer service pool with key: Endpoint[mina://tcp://localhost:8765?textline=true] for producer: Producer[mina://tcp://localhost:8765?textline=true]
[          AnonymousIoService-1] DefaultProducerServicePool     TRACE AddAndAcquire key: Endpoint[mina://tcp://localhost:8765?textline=true] service: Producer[mina://tcp://localhost:8765?textline=true]
[          AnonymousIoService-1] MinaProducer                   DEBUG Creating connector to address: localhost/127.0.0.1:8765 using connector: org.apache.mina.transport.socket.nio.SocketConnector@d58ce2 timeout: 30000 millis.
[SocketConnectorIoProcessor-1.0] ExecutorFilter                 DEBUG Launching thread for localhost/127.0.0.1:8765
[          AnonymousIoService-1] MinaProducer                   DEBUG Writing body : GET / HTTP/1.1
[          AnonymousIoService-1] MinaProducer                   DEBUG Waiting for response
[          AnonymousIoService-2] ExecutorFilter                 DEBUG Exiting since queue is empty for localhost/127.0.0.1:8765


then the client times out

[          AnonymousIoService-1] DefaultProducerServicePool     TRACE Release: Endpoint[mina://tcp://localhost:8765?textline=true] service: Producer[mina://tcp://localhost:8765?textline=true]
[          AnonymousIoService-1] InstrumentationProcessor       TRACE Recording duration: 30042.999155 millis for exchange: Exchange[Message: User-Agent: curl/7.16.4 (i486-pc-linux-gnu) libcurl/7.16.4 OpenSSL/0.9.8e zlib/1.2.3.3 libidn/1.0]
[          AnonymousIoService-1] InstrumentationProcessor       TRACE Recording duration: 30043.178798 millis for exchange: Exchange[Message: User-Agent: curl/7.16.4 (i486-pc-linux-gnu) libcurl/7.16.4 OpenSSL/0.9.8e zlib/1.2.3.3 libidn/1.0]
[          AnonymousIoService-1] DefaultTypeConverter           TRACE Converting null -> java.lang.Boolean with value: null
[          AnonymousIoService-1] DefaultTypeConverter           TRACE Converting null -> java.lang.Boolean with value: null
[          AnonymousIoService-1] DefaultExceptionPolicyStrategy TRACE Finding best suited exception policy for thrown exception org.apache.camel.ExchangeTimedOutException
[          AnonymousIoService-1] DefaultExceptionPolicyStrategy TRACE No candidate found to be used as exception policy
[          AnonymousIoService-1] DefaultTypeConverter           TRACE Converting null -> java.lang.Boolean with value: null
[          AnonymousIoService-1] DefaultErrorHandler            DEBUG Failed delivery for exchangeId: ID-home-laptop-33842-1257817905938-0-1. On delivery attempt: 0 caught: org.apache.camel.ExchangeTimedOutException: The OUT message was not received within: 30000 millis on the exchange: Exchange[Message: User-Agent: curl/7.16.4 (i486-pc-linux-gnu) libcurl/7.16.4 OpenSSL/0.9.8e zlib/1.2.3.3 libidn/1.0]
[          AnonymousIoService-1] DefaultTypeConverter           TRACE Converting null -> java.lang.Boolean with value: null
[          AnonymousIoService-1] DefaultTypeConverter           TRACE Converting java.lang.Boolean -> java.lang.Object with value: false
[          AnonymousIoService-1] DefaultTypeConverter           TRACE Converting java.lang.Boolean -> java.lang.Object with value: false
[          AnonymousIoService-1] DefaultErrorHandler            DEBUG This exchange is not handled so its marked as failed: Exchange[Message: User-Agent: curl/7.16.4 (i486-pc-linux-gnu) libcurl/7.16.4 OpenSSL/0.9.8e zlib/1.2.3.3 libidn/1.0]
[          AnonymousIoService-1] MinaConsumer                   DEBUG Writing body: org.apache.camel.ExchangeTimedOutException: The OUT message was not received within: 30000 millis on the exchange: Exchange[Message: User-Agent: curl/7.16.4 (i486-pc-linux-gnu) libcurl/7.16.4 OpenSSL/0.9.8e zlib/1.2.3.3 libidn/1.0]
[          AnonymousIoService-1] MinaConsumer                   DEBUG Received body: Host: localhost:8888
[          AnonymousIoService-1] DefaultTypeConverter           TRACE Converting null -> java.lang.Boolean with value: null
[          AnonymousIoService-1] DefaultTypeConverter           TRACE Converting null -> java.lang.Boolean with value: null
[          AnonymousIoService-1] DefaultProducerServicePool     TRACE Acquire: Endpoint[mina://tcp://localhost:8765?textline=true] service: Producer[mina://tcp://localhost:8765?textline=true]
[          AnonymousIoService-1] MinaProducer                   DEBUG Writing body : Host: localhost:8888
[SocketConnectorIoProcessor-1.0] ExecutorFilter                 DEBUG Launching thread for localhost/127.0.0.1:8765
[          AnonymousIoService-5] ExecutorFilter                 DEBUG Exiting since queue is empty for localhost/127.0.0.1:8765
[SocketConnectorIoProcessor-1.0] ExecutorFilter                 DEBUG Launching thread for localhost/127.0.0.1:8765
[          AnonymousIoService-6] ExecutorFilter                 DEBUG Exiting since queue is empty for localhost/127.0.0.1:8765
[          AnonymousIoService-1] MinaProducer                   DEBUG Waiting for response

Claus Ibsen-2 wrote:

Hi

Sorry I dont have time to do problem solving in my spare time.

Try making you example simpler and see that piece by piece works until
it breaks.


On Fri, Nov 6, 2009 at 2:51 PM, fab_can <[e-mail]> wrote:
>
> Hi Claus
>
> i am attaching a simple eclipse project with code that demonstrates the
> issue.
> http://old.nabble.com/file/p26230522/mina-routing.tgz mina-routing.tgz
> there's a Server class that acts as a listener on port 9999 (connecting to
> it via wget/curl/telnet works for me). There's also a Client class that can
> send requests direct and via camel (on port 8888).
> there's also a class HttpProxyBuilder with the route and a main method to
> start the context.
>
> i haven't included the camel libs in the project, so you'll have to define
> an eclipse build variable called camel.home to point to a camel 2 distro
>
> Any help would be much appreciated
>
> regards
>
> fabrizio
>
>
>
> Claus Ibsen-2 wrote:
>>
>> Hi
>>
>> Do you have some server running and listening on port 9999 ???
>> The logs indicate that no response is received.
>>
>> If you use wget or the likes from the cmd line can you access port
>> 9999 and get a reply back?
>>
>>
>> On Thu, Nov 5, 2009 at 2:52 AM, fab_can <[e-mail]> wrote:
>>>
>>> hello I am trying to build a route to proxy http traffic via camel-mina
>>> (I
>>> know of jetty and http endpoints but they are not suitable for my case).
>>> I
>>> have been trying all I can to make it work but still i haven't succeeded.
>>> The point I am at is that the request gets successfully to the to()
>>> endpoint
>>> but for whatever reason the response is never propagated back to the
>>> originating client.
>>>
>>> the route looks like
>>>
>>>
>>> from("mina:tcp://localhost:8888?codec=#httpMinaCodec&sync=true&minaLogger=true&lazySessionCreation=true")
>>>
>>> .to("mina:tcp://localhost:9999?codec=#httpMinaCodec&sync=true&minaLogger=true&lazySessionCreation=true&timeout=10000");
>>>
>>>
>>> and, with trace on the log looks like
>>>
>>> [          AnonymousIoService-6] DefaultProducerServicePool     TRACE
>>> Acquire:
>>> Endpoint[mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000]
>>> service:
>>> Producer[mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000]
>>> [          AnonymousIoService-6] MinaProducer                   DEBUG
>>> Creating connector to address: localhost/127.0.0.1:9999 using connector:
>>> org.apache.mina.transport.socket.nio.SocketConnector@c8d62f timeout:
>>> 10000
>>> millis.
>>> [SocketConnectorIoProcessor-1.0] MinaProducer$ResponseHandler   INFO
>>> [localhost/127.0.0.1:9999] CREATED
>>> [SocketConnectorIoProcessor-1.0] ExecutorFilter                 DEBUG
>>> Launching thread for localhost/127.0.0.1:9999
>>> [          AnonymousIoService-7] MinaProducer$ResponseHandler   INFO
>>> [localhost/127.0.0.1:9999] OPENED
>>> [          AnonymousIoService-7] ExecutorFilter                 DEBUG
>>> Exiting since queue is empty for localhost/127.0.0.1:9999
>>> [          AnonymousIoService-6] MinaProducer                   DEBUG
>>> Writing body : GET / HTTP/1.1
>>> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
>>> zlib/1.2.3.3 libidn/1.8
>>> Host: localhost:8888
>>> Accept: */*
>>>
>>>
>>> [          AnonymousIoService-6] MinaProducer$ResponseHandler   INFO
>>> [localhost/127.0.0.1:9999] WRITE: GET / HTTP/1.1
>>> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
>>> zlib/1.2.3.3 libidn/1.8
>>> Host: localhost:8888
>>> Accept: */*
>>>
>>>
>>> Encoding message: GET / HTTP/1.1
>>> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
>>> zlib/1.2.3.3 libidn/1.8
>>> Host: localhost:8888
>>> Accept: */*
>>>
>>>
>>> [SocketConnectorIoProcessor-1.0] ExecutorFilter                 DEBUG
>>> Launching thread for localhost/127.0.0.1:9999
>>> [          AnonymousIoService-8] ExecutorFilter                 DEBUG
>>> Exiting since queue is empty for localhost/127.0.0.1:9999
>>> [          AnonymousIoService-6] MinaProducer                   DEBUG
>>> Waiting for response. Timeout: 10000
>>> [SocketConnectorIoProcessor-1.0] ExecutorFilter                 DEBUG
>>> Launching thread for localhost/127.0.0.1:9999
>>> [          AnonymousIoService-9] MinaProducer$ResponseHandler   INFO
>>> [localhost/127.0.0.1:9999] SENT: GET / HTTP/1.1
>>> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
>>> zlib/1.2.3.3 libidn/1.8
>>> Host: localhost:8888
>>> Accept: */*
>>>
>>>
>>> [          AnonymousIoService-9] ExecutorFilter                 DEBUG
>>> Exiting since queue is empty for localhost/127.0.0.1:9999
>>> [SocketConnectorIoProcessor-1.0] ExecutorFilter                 DEBUG
>>> Launching thread for localhost/127.0.0.1:9999
>>> [         AnonymousIoService-10] ExecutorFilter                 DEBUG
>>> Exiting since queue is empty for localhost/127.0.0.1:9999
>>> [SocketConnectorIoProcessor-1.0] ExecutorFilter                 DEBUG
>>> Launching thread for localhost/127.0.0.1:9999
>>> [         AnonymousIoService-11] MinaProducer$ResponseHandler   INFO
>>> [localhost/127.0.0.1:9999] CLOSED
>>> [         AnonymousIoService-11] MinaProducer                   DEBUG
>>> Session closed but no message received from address:
>>> localhost/127.0.0.1:9999
>>> [          AnonymousIoService-6] DefaultProducerServicePool     TRACE
>>> Release:
>>> Endpoint[mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000]
>>> service:
>>> Producer[mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000]
>>> [          AnonymousIoService-6] DefaultTypeConverter           TRACE
>>> Converting com.myapp.mina.HttpMessage -> org.apache.camel.StreamCache
>>> with
>>> value: GET / HTTP/1.1
>>> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
>>> zlib/1.2.3.3 libidn/1.8
>>> Host: localhost:8888
>>> Accept: */*
>>>
>>>
>>> [          AnonymousIoService-6] DefaultTypeConverter           TRACE
>>> Converting org.apache.camel.impl.DefaultMessage ->
>>> org.apache.camel.StreamCache with value: Message: GET / HTTP/1.1
>>> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
>>> zlib/1.2.3.3 libidn/1.8
>>> Host: localhost:8888
>>> Accept: */*
>>>
>>>
>>> [          AnonymousIoService-6] DefaultTypeConverter           TRACE
>>> Converting com.myapp.mina.HttpMessage -> java.lang.String with value: GET
>>> /
>>> HTTP/1.1
>>> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
>>> zlib/1.2.3.3 libidn/1.8
>>> Host: localhost:8888
>>> Accept: */*
>>>
>>>
>>> [          AnonymousIoService-6] TraceInterceptor               INFO
>>> ID-fc-laptop-56193-1257383273772-0-1 >>>
>>> from(mina://tcp://localhost:8888?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true)
>>> -->
>>> mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000,
>>> Pattern:InOut, BodyType:com.myapp.mina.HttpMessage, Body:GET / HTTP/1.1
>>> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
>>> zlib/1.2.3.3 libidn/1.8
>>> Host: localhost:8888
>>> Accept: */*
>>>
>>> , Exception: org.apache.camel.CamelExchangeException: No response
>>> received
>>> from remote server:
>>> mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000
>>> on the exchange: Exchange[Message: GET / HTTP/1.1
>>> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g
>>> zlib/1.2.3.3 libidn/1.8
>>> Host: localhost:8888
>>> Accept: */*
>>>
>>> I am really stuck here, so any help would be appreciated
>>>
>>> thanks
>>> fabrizio
>>> --
>>> View this message in context:
>>> http://old.nabble.com/Session-closed-but-no-message-received-from-address%3A-localhost-127.0.0.1%3A9999-when-using-camel-mina-tp26207954p26207954.html
>>> Sent from the Camel Development mailing list archive at Nabble.com.
>>>
>>>
>>
>>
>>
>> --
>> Claus Ibsen
>> Apache Camel Committer
>>
>> Author of Camel in Action: http://www.manning.com/ibsen/
>> Open Source Integration: http://fusesource.com
>> Blog: http://davsclaus.blogspot.com/
>> Twitter: http://twitter.com/davsclaus
>>
>>
>
> --
> View this message in context: http://old.nabble.com/Session-closed-but-no-message-received-from-address%3A-localhost-127.0.0.1%3A9999-when-using-camel-mina-tp26207954p26230522.html
> Sent from the Camel Development mailing list archive at Nabble.com.
>
>



--
Claus Ibsen
Apache Camel Committer

Author of Camel in Action: http://www.manning.com/ibsen/
Open Source Integration: http://fusesource.com
Blog: http://davsclaus.blogspot.com/
Twitter: http://twitter.com/davsclaus

[fab_can]

in relation to my response, i realised I miscopied the code, which in fact is package mina; import org.apache.camel.builder.RouteBuilder; public class Main extends RouteBuilder { public static void main(String[] args) { org.apache.camel.spring.Main.main("-duration", "-1"); } public void configure() { from("mina:tcp://localhost:8888?textline=true"). to("mina:tcp://localhost:8765?textline=true"); } }

Claus Ibsen-2 wrote:

Hi Sorry I dont have time to do problem solving in my spare time. Try making you example simpler and see that piece by piece works until it breaks. On Fri, Nov 6, 2009 at 2:51 PM, fab_can wrote: > > Hi Claus > > i am attaching a simple eclipse project with code that demonstrates the > issue. > http://old.nabble.com/file/p26230522/mina-routing.tgz mina-routing.tgz > there's a Server class that acts as a listener on port 9999 (connecting to > it via wget/curl/telnet works for me). There's also a Client class that can > send requests direct and via camel (on port 8888). > there's also a class HttpProxyBuilder with the route and a main method to > start the context. > > i haven't included the camel libs in the project, so you'll have to define > an eclipse build variable called camel.home to point to a camel 2 distro > > Any help would be much appreciated > > regards > > fabrizio > > > > Claus Ibsen-2 wrote: >> >> Hi >> >> Do you have some server running and listening on port 9999 ??? >> The logs indicate that no response is received. >> >> If you use wget or the likes from the cmd line can you access port >> 9999 and get a reply back? >> >> >> On Thu, Nov 5, 2009 at 2:52 AM, fab_can wrote: >>> >>> hello I am trying to build a route to proxy http traffic via camel-mina >>> (I >>> know of jetty and http endpoints but they are not suitable for my case). >>> I >>> have been trying all I can to make it work but still i haven't succeeded. >>> The point I am at is that the request gets successfully to the to() >>> endpoint >>> but for whatever reason the response is never propagated back to the >>> originating client. >>> >>> the route looks like >>> >>> >>> from("mina:tcp://localhost:8888?codec=#httpMinaCodec&sync=true&minaLogger=true&lazySessionCreation=true") >>> >>> .to("mina:tcp://localhost:9999?codec=#httpMinaCodec&sync=true&minaLogger=true&lazySessionCreation=true&timeout=10000"); >>> >>> >>> and, with trace on the log looks like >>> >>> [ AnonymousIoService-6] DefaultProducerServicePool TRACE >>> Acquire: >>> Endpoint[mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000] >>> service: >>> Producer[mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000] >>> [ AnonymousIoService-6] MinaProducer DEBUG >>> Creating connector to address: localhost/127.0.0.1:9999 using connector: >>> org.apache.mina.transport.socket.nio.SocketConnector@c8d62f timeout: >>> 10000 >>> millis. >>> [SocketConnectorIoProcessor-1.0] MinaProducer$ResponseHandler INFO >>> [localhost/127.0.0.1:9999] CREATED >>> [SocketConnectorIoProcessor-1.0] ExecutorFilter DEBUG >>> Launching thread for localhost/127.0.0.1:9999 >>> [ AnonymousIoService-7] MinaProducer$ResponseHandler INFO >>> [localhost/127.0.0.1:9999] OPENED >>> [ AnonymousIoService-7] ExecutorFilter DEBUG >>> Exiting since queue is empty for localhost/127.0.0.1:9999 >>> [ AnonymousIoService-6] MinaProducer DEBUG >>> Writing body : GET / HTTP/1.1 >>> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g >>> zlib/1.2.3.3 libidn/1.8 >>> Host: localhost:8888 >>> Accept: */* >>> >>> >>> [ AnonymousIoService-6] MinaProducer$ResponseHandler INFO >>> [localhost/127.0.0.1:9999] WRITE: GET / HTTP/1.1 >>> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g >>> zlib/1.2.3.3 libidn/1.8 >>> Host: localhost:8888 >>> Accept: */* >>> >>> >>> Encoding message: GET / HTTP/1.1 >>> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g >>> zlib/1.2.3.3 libidn/1.8 >>> Host: localhost:8888 >>> Accept: */* >>> >>> >>> [SocketConnectorIoProcessor-1.0] ExecutorFilter DEBUG >>> Launching thread for localhost/127.0.0.1:9999 >>> [ AnonymousIoService-8] ExecutorFilter DEBUG >>> Exiting since queue is empty for localhost/127.0.0.1:9999 >>> [ AnonymousIoService-6] MinaProducer DEBUG >>> Waiting for response. Timeout: 10000 >>> [SocketConnectorIoProcessor-1.0] ExecutorFilter DEBUG >>> Launching thread for localhost/127.0.0.1:9999 >>> [ AnonymousIoService-9] MinaProducer$ResponseHandler INFO >>> [localhost/127.0.0.1:9999] SENT: GET / HTTP/1.1 >>> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g >>> zlib/1.2.3.3 libidn/1.8 >>> Host: localhost:8888 >>> Accept: */* >>> >>> >>> [ AnonymousIoService-9] ExecutorFilter DEBUG >>> Exiting since queue is empty for localhost/127.0.0.1:9999 >>> [SocketConnectorIoProcessor-1.0] ExecutorFilter DEBUG >>> Launching thread for localhost/127.0.0.1:9999 >>> [ AnonymousIoService-10] ExecutorFilter DEBUG >>> Exiting since queue is empty for localhost/127.0.0.1:9999 >>> [SocketConnectorIoProcessor-1.0] ExecutorFilter DEBUG >>> Launching thread for localhost/127.0.0.1:9999 >>> [ AnonymousIoService-11] MinaProducer$ResponseHandler INFO >>> [localhost/127.0.0.1:9999] CLOSED >>> [ AnonymousIoService-11] MinaProducer DEBUG >>> Session closed but no message received from address: >>> localhost/127.0.0.1:9999 >>> [ AnonymousIoService-6] DefaultProducerServicePool TRACE >>> Release: >>> Endpoint[mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000] >>> service: >>> Producer[mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000] >>> [ AnonymousIoService-6] DefaultTypeConverter TRACE >>> Converting com.myapp.mina.HttpMessage -> org.apache.camel.StreamCache >>> with >>> value: GET / HTTP/1.1 >>> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g >>> zlib/1.2.3.3 libidn/1.8 >>> Host: localhost:8888 >>> Accept: */* >>> >>> >>> [ AnonymousIoService-6] DefaultTypeConverter TRACE >>> Converting org.apache.camel.impl.DefaultMessage -> >>> org.apache.camel.StreamCache with value: Message: GET / HTTP/1.1 >>> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g >>> zlib/1.2.3.3 libidn/1.8 >>> Host: localhost:8888 >>> Accept: */* >>> >>> >>> [ AnonymousIoService-6] DefaultTypeConverter TRACE >>> Converting com.myapp.mina.HttpMessage -> java.lang.String with value: GET >>> / >>> HTTP/1.1 >>> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g >>> zlib/1.2.3.3 libidn/1.8 >>> Host: localhost:8888 >>> Accept: */* >>> >>> >>> [ AnonymousIoService-6] TraceInterceptor INFO >>> ID-fc-laptop-56193-1257383273772-0-1 >>> >>> from(mina://tcp://localhost:8888?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true) >>> --> >>> mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000, >>> Pattern:InOut, BodyType:com.myapp.mina.HttpMessage, Body:GET / HTTP/1.1 >>> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g >>> zlib/1.2.3.3 libidn/1.8 >>> Host: localhost:8888 >>> Accept: */* >>> >>> , Exception: org.apache.camel.CamelExchangeException: No response >>> received >>> from remote server: >>> mina://tcp://localhost:9999?codec=%23httpMinaCodec&lazySessionCreation=true&minaLogger=true&sync=true&timeout=10000 >>> on the exchange: Exchange[Message: GET / HTTP/1.1 >>> User-Agent: curl/7.18.2 (i486-pc-linux-gnu) libcurl/7.18.2 OpenSSL/0.9.8g >>> zlib/1.2.3.3 libidn/1.8 >>> Host: localhost:8888 >>> Accept: */* >>> >>> I am really stuck here, so any help would be appreciated >>> >>> thanks >>> fabrizio >>> -- >>> View this message in context: >>> http://old.nabble.com/Session-closed-but-no-message-received-from-address%3A-localhost-127.0.0.1%3A9999-when-using-camel-mina-tp26207954p26207954.html >>> Sent from the Camel Development mailing list archive at Nabble.com. >>> >>> >> >> >> >> -- >> Claus Ibsen >> Apache Camel Committer >> >> Author of Camel in Action: http://www.manning.com/ibsen/ >> Open Source Integration: http://fusesource.com >> Blog: http://davsclaus.blogspot.com/ >> Twitter: http://twitter.com/davsclaus >> >> > > -- > View this message in context: http://old.nabble.com/Session-closed-but-no-message-received-from-address%3A-localhost-127.0.0.1%3A9999-when-using-camel-mina-tp26207954p26230522.html > Sent from the Camel Development mailing list archive at Nabble.com. > > -- Claus Ibsen Apache Camel Committer Author of Camel in Action: http://www.manning.com/ibsen/ Open Source Integration: http://fusesource.com Blog: http://davsclaus.blogspot.com/ Twitter: http://twitter.com/davsclaus