When the channel is full, the JMSSource returns "BACKOFF" to PollableSourceRunner which implements backoff logic which can be seen here:
https://github.com/apache/flume/blob/trunk/flume-ng-core/src/main/java/org/apache/flume/source/PollableSourceRunner.java#L139 On Mon, Mar 17, 2014 at 7:38 PM, Jimmy <[email protected]> wrote: > I have JMS source and file channel with HDFS sink... so far works good > > lets assume I hit channel capacity (for whatever reason e.g. HDFS down) > and channel stops accepting new messages from source.... > > JMS is going to pull a message from queue and will try to delivery to > channel, but cannot, it will rollback. Again, works... > > Now if the channel is full for a while, am I going to see JMS pulling > messages from queue like crazy monkey just to roll them back few ms later > or is there some timeout-retry window e.g. "if JMS source cannot delivery 3 > messages to channel, wait 30 seconds they retry again" > > thank you > > > >
