Federated queue messages are not acknowledged in the upstream broker.

Run 2 brokers and set this federation configuration on broker2 <connectors> <connector name= "broker1" >tcp: //localhost:61616</connector> <connector name= "broker2" >tcp: //localhost:61617</connector> </connectors> <federations> <federation name= "fed" > <upstream name= "fed-upstream" > <circuit-breaker-timeout>1000</circuit-breaker-timeout> < static -connectors> <connector-ref>broker1</connector-ref> </ static -connectors> <policy ref= "policySetA" /> </upstream> <policy-set name= "policySetA" > <policy ref= "queue-federation" /> </policy-set> <queue-policy name= "queue-federation" > <include queue-match= "exampleQueue" address-match= "#" /> </queue-policy> </federation> </federations> Now consume from broker2 and produce to broker1 Let all the messages get consumed and check the stats on broker1: |NAME|CONSUMER_COUNT |MESSAGE_COUNT |MESSAGES_ADDED|DELIVERING_COUNT |ACK |exampleQueue |1 |1 |15 |1 |14  Producer public static void main( String [] args) throws Exception{ JmsConnectionFactory connectionFactory = new JmsConnectionFactory( "amqp: //localhost:61616" ); Connection connection = connectionFactory.createConnection(); Session session = connection.createSession( false ,Session.AUTO_ACKNOWLEDGE); Destination queue = session.createQueue( "exampleQueue" ); MessageProducer messageProducer = session.createProducer(queue); for ( int i = 0; i<1802; i++) { Message message = session.createTextMessage( "Hello" +i); messageProducer.send(message); } connection.close(); } Consumer (please note that the prefetch is irrelevant here as changing it doesn't affect the outcome) public static void main( String [] args) throws Exception{ JmsConnectionFactory connectionFactory = new JmsConnectionFactory( "amqp: //localhost:61617?jms.prefetchPolicy.queuePrefetch=1" );; Connection connection = connectionFactory.createConnection(); connection.start(); Session session = connection.createSession( false ,Session.AUTO_ACKNOWLEDGE); Destination queue = session.createQueue( "exampleQueue" ); session.createConsumer(queue).setMessageListener(message -> { TextMessage textMessage = (TextMessage)message; try { System .out.println( ">> A new message " +textMessage.getText()); } catch (JMSException e) { e.printStackTrace(); } }); } A strange thing I noticed is that if I send 1801 messages, all of them are acked but if I send 1802, it shows 1 message in the delivering state.