exchange broke after 200000 pubulished msg.

[sl624]

Setting the queue with 'x-recent-history-length: 1000000'

args={'x-recent-history-length':1000000}
channel.exchange_declare(exchange='buffer', exchange_type='x-recent-history', arguments =args)

for i in range(1000000):
    message = datetime.now().strftime("%H:%M:%S") + '.' + str(i)
    channel.basic_publish(exchange='buffer',
                          routing_key='',
                          body=message)

At first it publish 10000 per second. after 100000 msgs , it starts to slow down , and then after 200000, it broke.

[lukebakken]

Closing due to inactivity.