Custom System Consumer filling up memory

Hi,    I've created a custom System Consumer extending BlockingEnvelopeMap.    All looks good until I reach about 10m messages processed by the StreamTask. At that point I see a lot of GC going on and the heap dump shows memory is mostly used by  "IncomingMessageEnvelope" and a ConcurrentHashM

Fwd: Re: Failed to create a consumer

Thanks. You can see the errors in debug mode. Consumer implementations should not fail with runtime errors without logging them. Are you not logging exceptions in your consumer code ? -- Forwarded message -- From: "Marcelo Romaniuc" Date: 29 Dec 2015 20:23 Subject: Re: Failed to cr