You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@camel.apache.org by Claus Ibsen <cl...@gmail.com> on 2009/11/05 06:22:21 UTC

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

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 <fa...@bt.com> 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

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

Posted by fab_can <fa...@bt.com>.
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 <fa...@bt.com> 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 <fa...@bt.com>
>>> 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
> 
> 

-- 
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-tp26207954p26277098.html
Sent from the Camel Development mailing list archive at Nabble.com.


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

Posted by fab_can <fa...@bt.com>.
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
> 
> 

-- 
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-tp26207954p26277122.html
Sent from the Camel Development mailing list archive at Nabble.com.

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

Posted by Claus Ibsen <cl...@gmail.com>.
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 <fa...@bt.com> 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 <fa...@bt.com> 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

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

Posted by fab_can <fa...@bt.com>.
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 <fa...@bt.com> 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.


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

Posted by fab_can <fa...@bt.com>.
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 <fa...@bt.com> 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-tp26207954p26229766.html
Sent from the Camel Development mailing list archive at Nabble.com.