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 ConcurrentHashMap (probably from BlockingEnvelopMap). It seems the messages are hanging around, even after "processed" by the StreamTask. Do I need to do something to dispose such messages ? Thanks, Marcelo
