This closes #1992
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/eec10994 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/eec10994 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/eec10994 Branch: refs/heads/master Commit: eec10994720abca9b9b19d09604924083a35d3ea Parents: 2feacd5 dae1b7d Author: Clebert Suconic <[email protected]> Authored: Wed Apr 4 19:55:14 2018 -0400 Committer: Clebert Suconic <[email protected]> Committed: Wed Apr 4 19:55:14 2018 -0400 ---------------------------------------------------------------------- .../cli/commands/messages/ConsumerThread.java | 23 +++++-- .../artemis/cli/commands/messages/Producer.java | 7 +- .../cli/commands/messages/ProducerThread.java | 35 +++++++++- .../artemis/cli/commands/messages/demo.txt | 15 +++++ .../activemq/artemis/cli/commands/util/demo.txt | 15 ----- .../apache/activemq/cli/test/ArtemisTest.java | 4 ++ .../activemq/cli/test/StreamClassPathTest.java | 69 ++++++++++---------- .../core/server/cluster/impl/BridgeImpl.java | 23 +++---- 8 files changed, 122 insertions(+), 69 deletions(-) ----------------------------------------------------------------------
