I'm using Camel AMQP Component (which uses Qpid under the hood) to connect to Artemis. Both are running locally on my mac. My routes are simply:
from("amqp:queue:incoming").process(exchange -> { System.out.println(exchange.getIn().getBody()); }); from("timer:incoming?period=500") .process(exchange -> { exchange.getIn().setBody("Boop "+new Date()); exchange.getOut().setBody("BoopOut "+new Date()); }) .to("amqp:queue:incoming"); After I terminate the client abruptly and restart it (for durability testing), I'm seeing the broker not deliver messages to the consumer. After I restart the broker (even when the client is still running), I see the consumer start back up. I'm wondering if this is an issue w/ Artemis or with Qpid. Has anyone seen something similar? John