[QPID-6829] [Java Broker] SystemMessageSources$Consumer needs to implement flush()

• Type: Bug
• Status: Resolved
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: qpid-java-6.0
• Fix Version/s: qpid-java-6.0
• Component/s: Broker-J
• Assignee: Lorenz Quack
• Reporter: Lorenz Quack
• Created: 05/Nov/15 15:08
• Updated: 12/Nov/15 10:47
• Resolved: 12/Nov/15 10:47

Description

There are several scenarios where it is problematic that flush is not implemented.
e.g., if someone does "subscribe to source; flush; unsubscribe" all in one network read, we'd currently not get any messages