Easiest way to send a reply via camel-netty4:udp socket?

moteAddress *headers containing the associated local/remote IP and port. How, from a processor within the route consuming from *SEDA_QUEUE2*, do I send the reply out the UDP socket on the input route? There was to be an easy way to do this, but I'm not seeing it. Thanks, SteveR I've

[ENHANCEMENT REQUEST]: camel-netty4 config support for specifying UDP source port

=false&disconnect=false&sendBufferSize=26214400&allowDefaultCodec=false"); Thanks, SteveR -- View this message in context: http://camel.465427.n5.nabble.com/ENHANCEMENT-REQUEST-camel-netty4-config-support-for-specifying-UDP-source-port-tp5775070.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: How to specify the UDP source port with camel-netty4 ?

I'm using *Camel-2.16* and I'm looking at the GitHub code for the NettyProducer.java , and I think the below highlighted code is what causes netty to spe

Re: How to specify the UDP source port with camel-netty4 ?

Hi Greg: Thanks for the reply. However, it's the UDP source port that I'd like control over. The *${header.CamelNettyRemoteAddress}* correctly resolves to the in-flight destination *IP:port *of the client that I need to send the UDP acknowledgement to. My problem is that *camel-netty4* is not gi

How to specify the UDP source port with camel-netty4 ?

With *Camel 2.16.0* and the *camel-netty4* component, I need to send a UDP response back to the associated client and I need control over the source IP (i.e. my local host name) *AND *the UDP source port (i.e. a port number of my choosing). Currently, it appears that *camel-netty4* uses the local

How to specify the UDP source port in dynamic To (toD)?

I'm using *Camel 2.16.0*, *camel-netty4*, and the new dynamic *toD()* feature to send UDP acknowledgements back to the associated UDP client. In my Camel route that deals with acknowledgements, I have an *AckBackProcessor* that composes the UDP response to be sent back to the UDP client. Right be

Re: Integration Pattern

Hi Ishada: Maybe checkout the Camel Mail Component <http://camel.apache.org/mail.html> . SteveR -- View this message in context: http://camel.465427.n5.nabble.com/Integration-Pattern-tp5773535p5773547.html Sent from the Camel - Users mailing list archive at Nabble.com.

Camel 2.16.0 and camel-kafka using old verion of netty?

Hi: I've recently upgraded my Linux RHEL6 java application to use *Camel 2.16.0* and *netty4*. I see that *camel-kafka* is pulling in an old version of netty3 (i.e. *netty-3.7.0.Final.jar*). Just wondering this is normal or if it's an issue that can be addressed? My pom entry for camel-kafka:

Re: NEED HELP: Exchanges remain inflight on route with recipientList to netty:udp

e. Below is my updated route that uses the new *toD()* method. Below that is the route which sends to this ack-back route. I'm really puzzled by this behavior, but I need to figure it out soon because my management is getting cranky ;-( Thanks for any help, SteveR from(uri=&qu

NEED HELP: Exchanges remain inflight on route with recipientList to netty:udp

ork dynamically. You would think that if there is a *NettyConstants.NETTY_REMOTE_ADDRESS* header on the exchange that there would be a way to tell *camel-netty* to just use that remote address. Thanks, SteveR from(uri="seda:SEDA_ACK_QUEUE?size=20&concurrentConsumers=10&am

Re: NEED HELP: Exchanges remain inflight on route with recipientList() or toD()

that is causing issues. I would hate to give up now over an issue like this, but I'm running out of ideas and my management is getting impatient and a jaded view of Apache Camel. It was my idea to use Camel, so I'm trying real hard to make it work successfully. Thanks, SteveR [2

Re: NEED HELP: Exchanges remain inflight on route with recipientList() or toD()

By the way, on the ack-back route in question that sends the UDP acknowledgement via *netty:udp*, I've tried with and without the *udpConnectionlessSending *option and neither way works. -- View this message in context: http://camel.465427.n5.nabble.com/NEED-HELP-Exchanges-remain-inflight-on-ro

Re: Camel netty: How to send UDP reply based on NETTY_REMOTE_ADDRESS?

show as CompletedExchanges). Any thoughts on how to debug this issue? Thanks, SteveR // I extract the remote address in my processor, get the remote host and remote port, // and set them as input headers on the exchange. Message inMsg = exchange.getIn(); S

Camel netty: How to send UDP reply based on NETTY_REMOTE_ADDRESS?

way to parameterize the sending of the UDP replies back using the *host:port* combo that is specified in the *CamelNettyRemoteAddress* header of the Exchange. Any thoughts greatly appreciated. Below are my routes. Thanks, SteveR from("netty:udp://dloco.m.mission.net:11

Camel 2.15.3: multicast (default is take the latest reply?)

what is the easiest way to configure a multicast with respect to aggregation? I'm hoping, in thissimple case of multicasting to only two SEDA queues that I can find a way that doesn't require a custom aggregationStrategy. Thanks, SteveR Maybe something l

Camel 2.15.3: multicast with aggregationStrategy() not working ...

g the *Exchange.AGGREGATION_COMPLETE_CURRENT_GROUP* property on the returned exchange does not stop the aggregation. Am I doing something wrong, or do we know of any bugs in the area? Thanks, SteveR @Override public Exchange aggregate(Exchange oldExchange, Exchange newExc

camel-netty4: MessageToMessageDecoder gives only first 2048 octets

I'm using *Camel 2.15.3* and *camel-netty4*, and since upgrading from *camel-netty3*, I'm having problems receiving full JSON messages via UDP. Each JSON message is about 3 to 5 kbytes, but my *MessageToMessageDecoder* implementation is only giving me the first 2048 (i.e. 2k bytes). From a test p

Upgrading to camel-netty4: How to migrate my UdpPacketDecoder?

lse invoke *ctx.sendUpstream(ce)*. Any thoughts on how to finish this *UdpPacketDecoder* migration to *camel-netty4* is much appreciated. Thanks, SteveR *camel-netty3 version:* package com.mission.mplr.multiprotocollistenerrouter; import org.jboss.netty.buffe

Re: camel-netty: How to set the netty closeChannelTimeMillis option?

gging this issue. So the wireTap portion of the route seems to mostly be failing. However, some UDP packets do get through to the remote host. Any thoughts are greatly appreciated. Thanks, SteveR http://camel.apache.org/schema/s

Re: camel-netty: How to set the netty closeChannelTimeMillis option?

2 and 3, as shown in the JIRA issue) and were hoping for a resolution to this similar issue. Any thoughts on this are appreciated. Thanks, SteveR -- View this message in context: http://camel.465427.n5.nabble.com/camel-netty-How-to-set-the-netty-closeChannelTimeMillis-option-tp5772342p57723

camel-netty: How to set the netty closeChannelTimeMillis option?

might be an undocumented or back-door way to set it. Thanks, SteveR -- View this message in context: http://camel.465427.n5.nabble.com/camel-netty-How-to-set-the-netty-closeChannelTimeMillis-option-tp5772342.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Camel Load Balancer EIP with TCP Endpoints

host. Thanks, SteveR -- View this message in context: http://camel.465427.n5.nabble.com/Camel-Load-Balancer-EIP-with-TCP-Endpoints-tp5772104p5772314.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Cannot Auto Create Component - Netty4

Roger: Yes, I do see camel-netty4-2.15.2.jar in my Java classpath. My Maven *pom.xml* dependency looks like this, where *camelCoreVersion *is 2.15.2: org.apache.camel camel-netty4 ${camelCoreVersion} SteveR -- View this message

Re: Cannot Auto Create Component - Netty4

x27;t work, within Spring MVC*? It looks like an issue similar to yours. SteveR -- View this message in context: http://camel.465427.n5.nabble.com/Cannot-Auto-Create-Component-Netty4-tp5772149p5772252.html Sent from the Camel - Users mailing list archive at Nabble.com.

camel:netty4: How to control the number of outgoing TCP connections

what controls how many TCP connections that *camel-netty4 *attempts to establish to the remote host. I wonder if the remote host's *backlog *parameter is what limits it to 50? But I'm more interested in the *camel-netty4* behavior, since it's initiating the TCP connection attempts. Th

How to stop ERROR logging of ClosedChannelException

Java 1.8? Any thoughts on how I can prevent logging of these exceptions? Below is a sample entry from my Camel *rootLog.txt*? Thanks, SteveR [2015-09-29 00:03:51,869] ERROR [New I/O worker #15] Failed delivery for (MessageId: ID-es-edge-01-klga1-s-mission-net-49458-1443469983294-0-23

Camel Load Balancer EIP with TCP Endpoints

ider and I want to be sure I'm not missing any important ones. Also any ideas for making this application more robust, fault tolerant, and better-performing would be great! Thanks, SteveR from("netty4:tcp://host:port?serverInitializerFactory=#TCP_SERVER_PIPELINE_FACTORY&qu

Re: CamelCamel 2.15.2: ExchangeException - Cannot write response

I've seen several stackoverflow posts about *java.net.SocketException: Invalid argument* being related to and/or fixed by executing the JVM with the *-Djava.net.preferIPv4Stack=true* option. I'm currently testing with this to see if it helps. I wonder if this is a known issue that would be fixed i

CamelCamel 2.15.2: ExchangeException - Cannot write response

Hi: I have a Camel route that consumes from *netty:udp*, optionally sends a UDP response back to client (if requested), and produces to a Kafka topic. I'm getting the following exception which is causing netty to stop listening on the configured UDP port. Any thoughts greatly appreciated!!! T

camel:netty udpConnectionlessSending option and "Too many open files"

I'm using Camel 2.15.2 and the *camel-netty* component and I have a Camel route that mirrors UDP datagrams to a remote server via *netty:udp*. I saw that *camel-netty *supports the *udpConnectionlessSending *option, and I thought it would be a good idea as it will not result in failures when the

Camel multicast() with aggregationStrategy() ...

I have a Camel route that consumes from *netty:udp* and uses the *multicast() *DSL method to multicast to several different destinations (i.e. Camel throughput logger, local backup file, a SEDA queue that produces to Kafka, and another SEDA queue on a route that contains a UdpAckBack processor that

Please help critique my route ...

I want to get better at Camel route design and would welcome any thoughts on the below. Thanks, Steve Here's what I need to implement: - *FROM:* receive UDP datagrams in ISO-8859-1 format. For this I use the camel-netty component. - *ACK:* Each received UDP datagram must be acknowledged by e

Re: Conditionally omitting a portion of a route ...

Thanks so much Claus!!! Just a few questions: - I assume the last piece is: // continue routing here part = part.xxx And that there is nothing to do to finalize the ProcessorDefinition object, just set it as you show? Anyways, here's what I ended up with, based on your directoins:

Re: Conditionally omitting a portion of a route ...

I also tried using the PredicateBuilder.constant() method to create a predicate that resolves to true/false, based on my Java configuration boolean: *private static Boolean mirrorEnabled = null; // Set based on the "enabled" MIRROR configuration value. Predicate mirrorWireTap = PredicateB

Re: Conditionally omitting a portion of a route ...

So far, I have this solution which uses Camel Bean Language/Message Filter. I always want the route to send to the *firstToURIs*, but only send to the mirror wiretap if the *mirrorEnabled* configuration value is set to true. * // // This

Conditionally omitting a portion of a route ...

mirrorEnabled= false? I'm hoping it's doable with the simple language, but haven't yet figured out how to cleanly do it. The most brute-force way, would be to wrap two sets of the below route in a Java if-else block, but that's just silly ;-) Thanks, SteveR

Re: Conditionally omitting a portion of a route ...

I dumped the route as XML from within VisualVM and it appears that my *filter() * is encompassing the remainder of the route, instead of just the *wireTap()* portion. So when I set *mirrorEnabled = false*, nothing gets routed to the intended destinations. http://camel.apache.org/s

Re: Conditionally omitting a portion of a route ...

Looks like I spoke too soon, it doesn't look like it works when *mirrorEnabled = false*. I get: org.apache.camel.FailedToCreateRouteException: Failed to create route MIRROR_ROUTE_ID at: >>> Threads[[Filter[bean{com.mission.RouteManager$MirrorBean, method=isMirrorEnabled} -> [WireTap[no uri or ref

How to name an EventNotifier so it shows up in JConsole ...

I'm using Camel 2.14 and I have an AuditEventNotifier to notify about slow exchanges: // -- // Add the custom AuditEventNotifier to the CamelContext // See http://cam

Camel Exchange Properties when using Dead Letter Channel

I have a Linux Java7 stand-alone application using Camel 2.14. I'm using the DLC pattern to capture exchanges to a local file when re-delivery attempts have been exhausted, based on my *delayPattern*. I'm also specifying the *useOriginalMessage *option. My goal is to compose another route that I

Camel 2.14/Netty: Separate Exchange for each UDP packet?

I have a Linux Java7 stand-alone application using Camel 2.14 and the *camel-netty* component. I have several routes that each receive a UDP feed via netty:udp. I've already implemented a few routes that do this, but have used either a *DelimiterBasedFrameDecoder* or a *LengthFieldBasedFrameDecode

Re: Logging Camel route info ...

Thanks Claus, that worked great!!! Here's what I ended up with, the latter method lifted from */camel-core/src/main/java/org/apache/camel/management/mbean/ManagedCamelContext.java*. Thanks, Steve /** * Dump all Camel routes for the specified CamelContext as a string. * * @p

Re: Wrong charset when using FTP2 component, locale issue?

Hi Gustav: I'm sure you already know this, but *0xefbfbd* is the Unicode replacement character" � (U+FFFD) which a program may decide to insert for any character it couldn't decode correctly when trying to handle Unicode. So it look

Logging Camel route info ...

HORIZED_LOGGER?level=ERROR], Stop]* Thanks, SteveR -- View this message in context: http://camel.465427.n5.nabble.com/Logging-Camel-route-info-tp5768807.html Sent from the Camel - Users mailing list archive at Nabble.com.

Logging Camel Exchanges in Hexadecimal?

gt;^@^@^YPÃ?^A^@*OQ.Pc3qS729PK22EHvEMl5jeaQxxSIY.1431463279Ã?^B^@c+17926775404<<< snip >>>^@^@^@^@^@^@^@^@^@^@^@]* Thanks, SteveR -- View this message in context: http://camel.465427.n5.nabble.com/Logging-Camel-Exchanges-in-Hexadecimal-tp5768750.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Camel 2.14/Netty: How to add ByteArrayDecoder to ServerChannelPipeline?

Hi Willem: Actually, I'm currently using Camel 2.14 and Netty 3.x (org.jboss.netty). I'm wondering if there is a sensible way to migrate from netty3 to netty4 (i.e. other than just brute-force trying it) and what it would do with respect to my existing pipeline factory code, etc? Here's what I c

Camel 2.14/Netty: How to add ByteArrayDecoder to ServerChannelPipeline?

ass which I'd like to switch the StringDecoder/StringEncoder for ByteArrayDecoder/ByteArrayEncoder. Any help is greatly appreciated! Thanks, SteveR package multiprotocollistenerrouter; //import io.netty.handler.codec.bytes.ByteArrayDecoder; //import io.netty.handler.codec.bytes.ByteArra

How to Setup/Locate Camel Core Log?

dle-log-file-via-to-quot-log-quot-td5738205.html> * Thanks in advance for any help, SteveR -- View this message in context: http://camel.465427.n5.nabble.com/How-to-Setup-Locate-Camel-Core-Log-tp5762150.html Sent from the Camel - Users mailing list archive at Nabble.com.