<p>I do not know camel at all, but it looks like the Netty side is missing the bootstrap, pipeline factory, etc.</p>
<p>Just my 2 paisa :)</p>
<div class="gmail_quote">On 24-May-2011 7:43 PM, "<a href="mailto:sachin2713@gmail.com">sachin2713@gmail.com</a>" <<a href="mailto:sachin2713@gmail.com">sachin2713@gmail.com</a>> wrote:<br type="attribution">
> Hi, <br>> I am very new to camel and netty, please forgive my stupid mistakes.<br>> <br>> I am using Camel 2.6 along with netty 3.2.3 for tcp communication.<br>> I am starting an endpoint at server startup which should execute any other<br>
> business processing after receiving message.<br>> <br>> 1) As i dont want to bound clients with netty producer, i have to test<br>> sending message without netty producer , hence i am using simple java socket<br>
> client to send message to any port.But my processor is not able to pick up<br>> the message. SHouldnt it be independent of client?<br>> <br>> 2) Though when i try with netty producer , it works fine, but for only once<br>
> in one connection. second time it's not able to pick up message from netty<br>> producer also, i have to restart my server i.e camel again.<br>> <br>> Below is my code:<br>> <br>> <br>> EndPoint in camel-context:<br>
> <endpoint id="ByteStreamTransport"<br>> uri="netty:tcp://localhost:6123connectTimeout=5000&amp;sync=false" /><br>> <br>> <br>> <br>> <br>> Java Client:( not complete)<br>
> <br>> socket = new Socket();<br>> socket.connect(new InetSocketAddress("localhost", 9990));<br>> OutputStream os = socket.getOutputStream();<br>> ObjectOutputStream oos = new ObjectOutputStream(os);<br>
> // oos.writeObject(emp);<br>> <br>> socket.getOutputStream().write(bytes);<br>> socket.getOutputStream().flush();<br>> socket.shutdownOutput(<br>> )<br>> <br>> <br>> <br>
> <br>> Netty Consumer:(I can see in logs that netty consumer is bound to this port)<br>> <br>> try {<br>> NettyConsumer consumer = (NettyConsumer)<br>> tcpProfile.getEndPoint().createConsumer(new TCPProcessor(this ,tcpProfile));<br>
> consumer.start(); <br>> <br>> <br>> <br>> Netty Producer:<br>> try {<br>> <br>> context = new DefaultCamelContext(); <br>> <br>> context.start(); <br>> <br>
> Endpoint endpoint =<br>> context.getEndpoint("netty:tcp://localhost:6123?sync=false");<br>> Exchange exchange = endpoint.createExchange(ExchangePattern.InOnly);<br>> exchange.getIn().setBody("sachin1");<br>
> producer = (NettyProducer)endpoint.createProducer();<br>> producer.start(); <br>> producer.process(exchange);<br>> <br>> <br>> }<br>> catch (Exception e) {<br>> // TODO Auto-generated catch block<br>
> e.printStackTrace();<br>> } }<br>> <br>> <br>> --<br>> View this message in context: <a href="http://netty-forums-and-mailing-lists.685743.n2.nabble.com/Netty-Consumer-is-not-able-to-pick-up-messagefrom-any-port-sent-through-simple-java-socket-clinet-tp6398719p6398719.html">http://netty-forums-and-mailing-lists.685743.n2.nabble.com/Netty-Consumer-is-not-able-to-pick-up-messagefrom-any-port-sent-through-simple-java-socket-clinet-tp6398719p6398719.html</a><br>
> Sent from the Netty User Group mailing list archive at Nabble.com.<br>> _______________________________________________<br>> netty-users mailing list<br>> <a href="mailto:netty-users@lists.jboss.org">netty-users@lists.jboss.org</a><br>
> <a href="https://lists.jboss.org/mailman/listinfo/netty-users">https://lists.jboss.org/mailman/listinfo/netty-users</a><br></div>