Re: Camel Mina or Netty to read NMEA 0183 buffer
Can you share the camel route with us? I didn’t find anything wrong by going through the log you pasted. -- Willem Jiang Red Hat, Inc. Web: http://www.redhat.com Blog: http://willemjiang.blogspot.com (English) http://jnn.iteye.com (Chinese) Twitter: willemjiang Weibo: 姜宁willem On November 5, 2014 at 4:22:22 PM, Morgan Hautman (morgan.haut...@gmail.com) wrote: Hello all, I'm trying to implement a endpoint who can read an NMEA 0183 buffer using TCP. I already tried to implement it using a codec ( https://code.google.com/p/cellengine/source/browse/trunk/engine_java/002_Engine_Server/mina/com/net/minaimpl/server/telnet/TelnetCodec.java?r=1198) but it requires a Charset and non of them fullfit my needs. I also tried with the option textline=true but my route stops: 09:07:49,767 | INFO | rint Extender: 2 | troller.internal.JobLauncherImpl 119 | 421 - org.talend.esb.job.controller - 5.2.3 | Adding route TCP_CONNECTION. 09:07:49,770 | INFO | ool-13-thread-44 | controller.internal.RouteAdapter 66 | 421 - org.talend.esb.job.controller - 5.2.3 | Starting route TCP_CONNECTION 09:07:49,773 | INFO | ool-13-thread-44 | rg.apache.camel.main.MainSupport 307 | 400 - org.apache.camel.camel-core - 2.10.2 | Apache Camel starting 09:07:49,775 | INFO | ool-13-thread-44 | gement.ManagementStrategyFactory 43 | 400 - org.apache.camel.camel-core - 2.10.2 | JMX enabled. 09:07:49,776 | INFO | ool-13-thread-44 | e.camel.impl.DefaultCamelContext 1398 | 400 - org.apache.camel.camel-core - 2.10.2 | Apache Camel 2.10.2 (CamelContext: TCP_CONNECTION-ctx) is starting 09:07:49,812 | INFO | ool-13-thread-44 | BundleTypeConverterLoader$Loader 353 | 400 - org.apache.camel.camel-core - 2.10.2 | Found 2 @Converter classes to load 09:07:49,813 | INFO | ool-13-thread-44 | BundleTypeConverterLoader$Loader 353 | 400 - org.apache.camel.camel-core - 2.10.2 | Found 2 @Converter classes to load 09:07:49,813 | INFO | ool-13-thread-44 | BundleTypeConverterLoader$Loader 353 | 400 - org.apache.camel.camel-core - 2.10.2 | Found 1 @Converter classes to load 09:07:49,814 | INFO | ool-13-thread-44 | BundleTypeConverterLoader$Loader 353 | 400 - org.apache.camel.camel-core - 2.10.2 | Found 1 @Converter classes to load 09:07:49,814 | INFO | ool-13-thread-44 | BundleTypeConverterLoader$Loader 353 | 400 - org.apache.camel.camel-core - 2.10.2 | Found 1 @Converter classes to load 09:07:49,814 | INFO | ool-13-thread-44 | BundleTypeConverterLoader$Loader 353 | 400 - org.apache.camel.camel-core - 2.10.2 | Found 1 @Converter classes to load 09:07:49,841 | INFO | ool-13-thread-44 | amel.component.mina.MinaConsumer 59 | 750 - org.apache.camel.camel-mina - 2.10.2 | Binding to server address: /192.168.100.109:1212 using acceptor: org.apache.mina.transport.socket.n io.SocketAcceptor@6334ef33 09:07:49,842 | INFO | ool-13-thread-44 | amel.component.mina.MinaConsumer 67 | 750 - org.apache.camel.camel-mina - 2.10.2 | Unbinding from server address: /192.168.100.109:1212 using acceptor: org.apache.mina.transport.sock et.nio.SocketAcceptor@6334ef33 09:07:49,844 | INFO | ool-13-thread-44 | e.camel.impl.DefaultCamelContext 1590 | 400 - org.apache.camel.camel-core - 2.10.2 | Apache Camel 2.10.2 (CamelContext: TCP_CONNECTION-ctx) is shutting down 09:07:49,845 | INFO | ool-13-thread-44 | verter.BaseTypeConverterRegistry 522 | 400 - org.apache.camel.camel-core - 2.10.2 | TypeConverterRegistry utilization[attempts=3, hits=3, misses=0, failures=0] mappings[total=211, mis ses=0] 09:07:49,846 | INFO | ool-13-thread-44 | e.camel.impl.DefaultCamelContext 1656 | 400 - org.apache.camel.camel-core - 2.10.2 | Apache Camel 2.10.2 (CamelContext: TCP_CONNECTION-ctx) is shutdown in 0.002 seconds. Uptime 0.071 s econds. 09:07:49,846 | INFO | ool-13-thread-44 | rg.apache.camel.main.MainSupport 301 | 400 - org.apache.camel.camel-core - 2.10.2 | Apache Camel stopping 09:07:49,847 | INFO | ool-13-thread-44 | controller.internal.RouteAdapter 79 | 421 - org.talend.esb.job.controller - 5.2.3 | Route TCP_CONNECTION finished, return code is 1 I understand that there should be something wrong but why does it tell me attempts=3, hits=3 and don't keep processing? Hope someone can help. Morgan
Re: Camel Mina or Netty to read NMEA 0183 buffer
from(mina:tcp://192.168.100.109:1212?sync=truetextline=true).routeId(TCP_CONNECTION).setExchangePattern(org.apache.camel.ExchangePattern.InOnly).id(ExchangePattern).to(log:cLog_1?level=INFO).id(cJMSConnectionFactory1 + :queue:netty)).id(jms); javax.jms.ConnectionFactory jmsConnectionFactory = new org.apache.activemq.ActiveMQConnectionFactory(tcp://localhost:7043); camelContext.addComponent(cJMSConnectionFactory1, org.apache.camel.component.jms.JmsComponent.jmsComponent(jmsConnectionFactory)); 2014-11-05 10:32 GMT+01:00 Willem Jiang willem.ji...@gmail.com: Can you share the camel route with us? I didn’t find anything wrong by going through the log you pasted. -- Willem Jiang Red Hat, Inc. Web: http://www.redhat.com Blog: http://willemjiang.blogspot.com (English) http://jnn.iteye.com (Chinese) Twitter: willemjiang Weibo: 姜宁willem On November 5, 2014 at 4:22:22 PM, Morgan Hautman ( morgan.haut...@gmail.com) wrote: Hello all, I'm trying to implement a endpoint who can read an NMEA 0183 buffer using TCP. I already tried to implement it using a codec ( https://code.google.com/p/cellengine/source/browse/trunk/engine_java/002_Engine_Server/mina/com/net/minaimpl/server/telnet/TelnetCodec.java?r=1198 ) but it requires a Charset and non of them fullfit my needs. I also tried with the option textline=true but my route stops: 09:07:49,767 | INFO | rint Extender: 2 | troller.internal.JobLauncherImpl 119 | 421 - org.talend.esb.job.controller - 5.2.3 | Adding route TCP_CONNECTION. 09:07:49,770 | INFO | ool-13-thread-44 | controller.internal.RouteAdapter 66 | 421 - org.talend.esb.job.controller - 5.2.3 | Starting route TCP_CONNECTION 09:07:49,773 | INFO | ool-13-thread-44 | rg.apache.camel.main.MainSupport 307 | 400 - org.apache.camel.camel-core - 2.10.2 | Apache Camel starting 09:07:49,775 | INFO | ool-13-thread-44 | gement.ManagementStrategyFactory 43 | 400 - org.apache.camel.camel-core - 2.10.2 | JMX enabled. 09:07:49,776 | INFO | ool-13-thread-44 | e.camel.impl.DefaultCamelContext 1398 | 400 - org.apache.camel.camel-core - 2.10.2 | Apache Camel 2.10.2 (CamelContext: TCP_CONNECTION-ctx) is starting 09:07:49,812 | INFO | ool-13-thread-44 | BundleTypeConverterLoader$Loader 353 | 400 - org.apache.camel.camel-core - 2.10.2 | Found 2 @Converter classes to load 09:07:49,813 | INFO | ool-13-thread-44 | BundleTypeConverterLoader$Loader 353 | 400 - org.apache.camel.camel-core - 2.10.2 | Found 2 @Converter classes to load 09:07:49,813 | INFO | ool-13-thread-44 | BundleTypeConverterLoader$Loader 353 | 400 - org.apache.camel.camel-core - 2.10.2 | Found 1 @Converter classes to load 09:07:49,814 | INFO | ool-13-thread-44 | BundleTypeConverterLoader$Loader 353 | 400 - org.apache.camel.camel-core - 2.10.2 | Found 1 @Converter classes to load 09:07:49,814 | INFO | ool-13-thread-44 | BundleTypeConverterLoader$Loader 353 | 400 - org.apache.camel.camel-core - 2.10.2 | Found 1 @Converter classes to load 09:07:49,814 | INFO | ool-13-thread-44 | BundleTypeConverterLoader$Loader 353 | 400 - org.apache.camel.camel-core - 2.10.2 | Found 1 @Converter classes to load 09:07:49,841 | INFO | ool-13-thread-44 | amel.component.mina.MinaConsumer 59 | 750 - org.apache.camel.camel-mina - 2.10.2 | Binding to server address: /192.168.100.109:1212 using acceptor: org.apache.mina.transport.socket.n io.SocketAcceptor@6334ef33 09:07:49,842 | INFO | ool-13-thread-44 | amel.component.mina.MinaConsumer 67 | 750 - org.apache.camel.camel-mina - 2.10.2 | Unbinding from server address: /192.168.100.109:1212 using acceptor: org.apache.mina.transport.sock et.nio.SocketAcceptor@6334ef33 09:07:49,844 | INFO | ool-13-thread-44 | e.camel.impl.DefaultCamelContext 1590 | 400 - org.apache.camel.camel-core - 2.10.2 | Apache Camel 2.10.2 (CamelContext: TCP_CONNECTION-ctx) is shutting down 09:07:49,845 | INFO | ool-13-thread-44 | verter.BaseTypeConverterRegistry 522 | 400 - org.apache.camel.camel-core - 2.10.2 | TypeConverterRegistry utilization[attempts=3, hits=3, misses=0, failures=0] mappings[total=211, mis ses=0] 09:07:49,846 | INFO | ool-13-thread-44 | e.camel.impl.DefaultCamelContext 1656 | 400 - org.apache.camel.camel-core - 2.10.2 | Apache Camel 2.10.2 (CamelContext: TCP_CONNECTION-ctx) is shutdown in 0.002 seconds. Uptime 0.071 s econds. 09:07:49,846 | INFO | ool-13-thread-44 | rg.apache.camel.main.MainSupport 301 | 400 - org.apache.camel.camel-core - 2.10.2 | Apache Camel stopping 09:07:49,847 | INFO | ool-13-thread-44 | controller.internal.RouteAdapter 79 | 421 - org.talend.esb.job.controller - 5.2.3 | Route TCP_CONNECTION finished, return code is 1 I understand that there should be something wrong but why does it tell me attempts=3, hits=3 and don't keep processing? Hope someone can help. Morgan
Re: Camel Mina or Netty to read NMEA 0183 buffer
Can you try with mina2 instead of mina ? mina2:tcp://0.0.0.0:1212?sync=truetextline=truetextlineDelimiter=AUTO Try to put a bean or processor after the mina endpoint to see what you receive (before going to a JMS queue). You can find details here: http://camel.apache.org/mina2.html Regards JB On 11/05/2014 10:49 AM, Morgan Hautman wrote: from(mina:tcp://192.168.100.109:1212?sync=truetextline=true).routeId(TCP_CONNECTION).setExchangePattern(org.apache.camel.ExchangePattern.InOnly).id(ExchangePattern).to(log:cLog_1?level=INFO).id(cJMSConnectionFactory1 + :queue:netty)).id(jms); javax.jms.ConnectionFactory jmsConnectionFactory = new org.apache.activemq.ActiveMQConnectionFactory(tcp://localhost:7043); camelContext.addComponent(cJMSConnectionFactory1, org.apache.camel.component.jms.JmsComponent.jmsComponent(jmsConnectionFactory)); 2014-11-05 10:32 GMT+01:00 Willem Jiang willem.ji...@gmail.com: Can you share the camel route with us? I didn’t find anything wrong by going through the log you pasted. -- Willem Jiang Red Hat, Inc. Web: http://www.redhat.com Blog: http://willemjiang.blogspot.com (English) http://jnn.iteye.com (Chinese) Twitter: willemjiang Weibo: 姜宁willem On November 5, 2014 at 4:22:22 PM, Morgan Hautman ( morgan.haut...@gmail.com) wrote: Hello all, I'm trying to implement a endpoint who can read an NMEA 0183 buffer using TCP. I already tried to implement it using a codec ( https://code.google.com/p/cellengine/source/browse/trunk/engine_java/002_Engine_Server/mina/com/net/minaimpl/server/telnet/TelnetCodec.java?r=1198 ) but it requires a Charset and non of them fullfit my needs. I also tried with the option textline=true but my route stops: 09:07:49,767 | INFO | rint Extender: 2 | troller.internal.JobLauncherImpl 119 | 421 - org.talend.esb.job.controller - 5.2.3 | Adding route TCP_CONNECTION. 09:07:49,770 | INFO | ool-13-thread-44 | controller.internal.RouteAdapter 66 | 421 - org.talend.esb.job.controller - 5.2.3 | Starting route TCP_CONNECTION 09:07:49,773 | INFO | ool-13-thread-44 | rg.apache.camel.main.MainSupport 307 | 400 - org.apache.camel.camel-core - 2.10.2 | Apache Camel starting 09:07:49,775 | INFO | ool-13-thread-44 | gement.ManagementStrategyFactory 43 | 400 - org.apache.camel.camel-core - 2.10.2 | JMX enabled. 09:07:49,776 | INFO | ool-13-thread-44 | e.camel.impl.DefaultCamelContext 1398 | 400 - org.apache.camel.camel-core - 2.10.2 | Apache Camel 2.10.2 (CamelContext: TCP_CONNECTION-ctx) is starting 09:07:49,812 | INFO | ool-13-thread-44 | BundleTypeConverterLoader$Loader 353 | 400 - org.apache.camel.camel-core - 2.10.2 | Found 2 @Converter classes to load 09:07:49,813 | INFO | ool-13-thread-44 | BundleTypeConverterLoader$Loader 353 | 400 - org.apache.camel.camel-core - 2.10.2 | Found 2 @Converter classes to load 09:07:49,813 | INFO | ool-13-thread-44 | BundleTypeConverterLoader$Loader 353 | 400 - org.apache.camel.camel-core - 2.10.2 | Found 1 @Converter classes to load 09:07:49,814 | INFO | ool-13-thread-44 | BundleTypeConverterLoader$Loader 353 | 400 - org.apache.camel.camel-core - 2.10.2 | Found 1 @Converter classes to load 09:07:49,814 | INFO | ool-13-thread-44 | BundleTypeConverterLoader$Loader 353 | 400 - org.apache.camel.camel-core - 2.10.2 | Found 1 @Converter classes to load 09:07:49,814 | INFO | ool-13-thread-44 | BundleTypeConverterLoader$Loader 353 | 400 - org.apache.camel.camel-core - 2.10.2 | Found 1 @Converter classes to load 09:07:49,841 | INFO | ool-13-thread-44 | amel.component.mina.MinaConsumer 59 | 750 - org.apache.camel.camel-mina - 2.10.2 | Binding to server address: /192.168.100.109:1212 using acceptor: org.apache.mina.transport.socket.n io.SocketAcceptor@6334ef33 09:07:49,842 | INFO | ool-13-thread-44 | amel.component.mina.MinaConsumer 67 | 750 - org.apache.camel.camel-mina - 2.10.2 | Unbinding from server address: /192.168.100.109:1212 using acceptor: org.apache.mina.transport.sock et.nio.SocketAcceptor@6334ef33 09:07:49,844 | INFO | ool-13-thread-44 | e.camel.impl.DefaultCamelContext 1590 | 400 - org.apache.camel.camel-core - 2.10.2 | Apache Camel 2.10.2 (CamelContext: TCP_CONNECTION-ctx) is shutting down 09:07:49,845 | INFO | ool-13-thread-44 | verter.BaseTypeConverterRegistry 522 | 400 - org.apache.camel.camel-core - 2.10.2 | TypeConverterRegistry utilization[attempts=3, hits=3, misses=0, failures=0] mappings[total=211, mis ses=0] 09:07:49,846 | INFO | ool-13-thread-44 | e.camel.impl.DefaultCamelContext 1656 | 400 - org.apache.camel.camel-core - 2.10.2 | Apache Camel 2.10.2 (CamelContext: TCP_CONNECTION-ctx) is shutdown in 0.002 seconds. Uptime 0.071 s econds. 09:07:49,846 | INFO | ool-13-thread-44 | rg.apache.camel.main.MainSupport 301 | 400 - org.apache.camel.camel-core - 2.10.2 | Apache Camel stopping 09:07:49,847 | INFO | ool-13-thread-44 | controller.internal.RouteAdapter 79 | 421 - org.talend.esb.job.controller - 5.2.3 | Route TCP_CONNECTION finished, return code is 1 I understand that there should be something wrong but why
Re: Camel Mina or Netty to read NMEA 0183 buffer
By the way, are you sure the 192.168.100.109 is a valid interface for the local machine ? Regards JB On 11/05/2014 10:49 AM, Morgan Hautman wrote: from(mina:tcp://192.168.100.109:1212?sync=truetextline=true).routeId(TCP_CONNECTION).setExchangePattern(org.apache.camel.ExchangePattern.InOnly).id(ExchangePattern).to(log:cLog_1?level=INFO).id(cJMSConnectionFactory1 + :queue:netty)).id(jms); javax.jms.ConnectionFactory jmsConnectionFactory = new org.apache.activemq.ActiveMQConnectionFactory(tcp://localhost:7043); camelContext.addComponent(cJMSConnectionFactory1, org.apache.camel.component.jms.JmsComponent.jmsComponent(jmsConnectionFactory)); 2014-11-05 10:32 GMT+01:00 Willem Jiang willem.ji...@gmail.com: Can you share the camel route with us? I didn’t find anything wrong by going through the log you pasted. -- Willem Jiang Red Hat, Inc. Web: http://www.redhat.com Blog: http://willemjiang.blogspot.com (English) http://jnn.iteye.com (Chinese) Twitter: willemjiang Weibo: 姜宁willem On November 5, 2014 at 4:22:22 PM, Morgan Hautman ( morgan.haut...@gmail.com) wrote: Hello all, I'm trying to implement a endpoint who can read an NMEA 0183 buffer using TCP. I already tried to implement it using a codec ( https://code.google.com/p/cellengine/source/browse/trunk/engine_java/002_Engine_Server/mina/com/net/minaimpl/server/telnet/TelnetCodec.java?r=1198 ) but it requires a Charset and non of them fullfit my needs. I also tried with the option textline=true but my route stops: 09:07:49,767 | INFO | rint Extender: 2 | troller.internal.JobLauncherImpl 119 | 421 - org.talend.esb.job.controller - 5.2.3 | Adding route TCP_CONNECTION. 09:07:49,770 | INFO | ool-13-thread-44 | controller.internal.RouteAdapter 66 | 421 - org.talend.esb.job.controller - 5.2.3 | Starting route TCP_CONNECTION 09:07:49,773 | INFO | ool-13-thread-44 | rg.apache.camel.main.MainSupport 307 | 400 - org.apache.camel.camel-core - 2.10.2 | Apache Camel starting 09:07:49,775 | INFO | ool-13-thread-44 | gement.ManagementStrategyFactory 43 | 400 - org.apache.camel.camel-core - 2.10.2 | JMX enabled. 09:07:49,776 | INFO | ool-13-thread-44 | e.camel.impl.DefaultCamelContext 1398 | 400 - org.apache.camel.camel-core - 2.10.2 | Apache Camel 2.10.2 (CamelContext: TCP_CONNECTION-ctx) is starting 09:07:49,812 | INFO | ool-13-thread-44 | BundleTypeConverterLoader$Loader 353 | 400 - org.apache.camel.camel-core - 2.10.2 | Found 2 @Converter classes to load 09:07:49,813 | INFO | ool-13-thread-44 | BundleTypeConverterLoader$Loader 353 | 400 - org.apache.camel.camel-core - 2.10.2 | Found 2 @Converter classes to load 09:07:49,813 | INFO | ool-13-thread-44 | BundleTypeConverterLoader$Loader 353 | 400 - org.apache.camel.camel-core - 2.10.2 | Found 1 @Converter classes to load 09:07:49,814 | INFO | ool-13-thread-44 | BundleTypeConverterLoader$Loader 353 | 400 - org.apache.camel.camel-core - 2.10.2 | Found 1 @Converter classes to load 09:07:49,814 | INFO | ool-13-thread-44 | BundleTypeConverterLoader$Loader 353 | 400 - org.apache.camel.camel-core - 2.10.2 | Found 1 @Converter classes to load 09:07:49,814 | INFO | ool-13-thread-44 | BundleTypeConverterLoader$Loader 353 | 400 - org.apache.camel.camel-core - 2.10.2 | Found 1 @Converter classes to load 09:07:49,841 | INFO | ool-13-thread-44 | amel.component.mina.MinaConsumer 59 | 750 - org.apache.camel.camel-mina - 2.10.2 | Binding to server address: /192.168.100.109:1212 using acceptor: org.apache.mina.transport.socket.n io.SocketAcceptor@6334ef33 09:07:49,842 | INFO | ool-13-thread-44 | amel.component.mina.MinaConsumer 67 | 750 - org.apache.camel.camel-mina - 2.10.2 | Unbinding from server address: /192.168.100.109:1212 using acceptor: org.apache.mina.transport.sock et.nio.SocketAcceptor@6334ef33 09:07:49,844 | INFO | ool-13-thread-44 | e.camel.impl.DefaultCamelContext 1590 | 400 - org.apache.camel.camel-core - 2.10.2 | Apache Camel 2.10.2 (CamelContext: TCP_CONNECTION-ctx) is shutting down 09:07:49,845 | INFO | ool-13-thread-44 | verter.BaseTypeConverterRegistry 522 | 400 - org.apache.camel.camel-core - 2.10.2 | TypeConverterRegistry utilization[attempts=3, hits=3, misses=0, failures=0] mappings[total=211, mis ses=0] 09:07:49,846 | INFO | ool-13-thread-44 | e.camel.impl.DefaultCamelContext 1656 | 400 - org.apache.camel.camel-core - 2.10.2 | Apache Camel 2.10.2 (CamelContext: TCP_CONNECTION-ctx) is shutdown in 0.002 seconds. Uptime 0.071 s econds. 09:07:49,846 | INFO | ool-13-thread-44 | rg.apache.camel.main.MainSupport 301 | 400 - org.apache.camel.camel-core - 2.10.2 | Apache Camel stopping 09:07:49,847 | INFO | ool-13-thread-44 | controller.internal.RouteAdapter 79 | 421 - org.talend.esb.job.controller - 5.2.3 | Route TCP_CONNECTION finished, return code is 1 I understand that there should be something wrong but why does it tell me attempts=3, hits=3 and don't keep processing? Hope someone can help. Morgan -- Jean-Baptiste Onofré jbono...@apache.org http://blog.nanthrax.net Talend -
