RE: Netty4 HL7 - reject messages larger than a specified size

2017-02-20 Thread slew77
Hi, The motivation is to protect the system from dealing with a message that larger than anticipated. Ideally I want to do this as the message is streamed to us, rather than doing any type of conversion to string after it's already been fully received. I also don't want to wait for the codec to f

Re: Netty4 HL7 - reject messages larger than a specified size

2017-02-13 Thread slew77
Hi, Please can someone help with this? Thanks, Steve. -- View this message in context: http://camel.465427.n5.nabble.com/Netty4-HL7-reject-messages-larger-than-a-specified-size-tp5793695p5793826.html Sent from the Camel - Users mailing list archive at Nabble.com.

Netty4 HL7 - reject messages larger than a specified size

2017-02-08 Thread slew77
Hi, We are using netty4 and the camel hl7 codecs to read in hl7 messages. I would like to reject messages larger than a certain size, but I can't find an obvious way to do so. I was going to enable stream caching and add a processor to the route to check the size, but the codec produces a string

Re: ActiveMQ concurrentConsumers vs multiple connections

2016-02-18 Thread slew77
Needs more testing, but I think this is the culprit: Should be Or take the default value CACHE_AUTO. It says this here: http://camel.apache.org/jms.html#JMS-transactionCacheLevels -- View this message in context: http://camel.465427.n5.nabble.com/ActiveMQ-concurrentCon

Re: ActiveMQ concurrentConsumers vs multiple connections

2016-02-18 Thread slew77
Hi, Sjms works well without local transactions, but as soon as they are turned on it seems even slower than using the activemq component. In all these cases, one thing I've spotted that seems odd is, if I monitor the In flight count, I only ever see it as 0 or 1, no matter how busy the system is.

Re: ActiveMQ concurrentConsumers vs multiple connections

2016-02-18 Thread slew77
Hi, Thanks for the ideas. >From what I can see, the consumer only uses a single connection and is allowed up to 500 (default) sessions and it's these sessions that the concurrent consumers use. I can see this is the case if I use the activemq web console and inspect the active connections. I can

ActiveMQ concurrentConsumers vs multiple connections

2016-02-18 Thread slew77
We are finding that under load that a single activemq endpoint with many concurrent consumers can't keep up with the volume of traffic. However, if we split the concurrent consumers between several identical routes it performs much better. E.g. if we configure this:

Referencing properties from another property file

2015-09-04 Thread slew77
Hi, We have many Camel Blueprint bundles deployed to Karaf. We're using blueprint property placeholders for configuration. For the properties that are environment specific, we want them to be in a property file and reference them from within the blueprint property placeholder files. Previously w

HBase scan - range of rowkeys

2014-11-21 Thread slew77
Hi, I'd like to retrieve a range of rows matching a partial rowkey. The equivalent in the hbase shell would be something like this: > scan 'mytable', {STARTROW => 'abc', ENDROW => 'abd'} to search for all entries in my table starting with the string "abc". Is this possible with the camel hbase

Re: Message blocks route until all redelivery attempts are exhausted

2010-05-25 Thread slew77
I have exactly the same problem. I have many thousands of endpoints any number of which could be down. I need to be able to handle redelivery without blocking good messages. Wondering if you came up with a workaround for this? Thanks, Steve. Claus Ibsen-2 wrote: > > Hi > > It depends on th