Replaced erroneous magic number with constant
Project: http://git-wip-us.apache.org/repos/asf/brooklyn-library/repo Commit: http://git-wip-us.apache.org/repos/asf/brooklyn-library/commit/4c2c535b Tree: http://git-wip-us.apache.org/repos/asf/brooklyn-library/tree/4c2c535b Diff: http://git-wip-us.apache.org/repos/asf/brooklyn-library/diff/4c2c535b Branch: refs/heads/0.6.0 Commit: 4c2c535b3c05179eab74117541591c1d7de6939c Parents: 0cc146e Author: Martin Harris <[email protected]> Authored: Mon Nov 4 18:14:45 2013 +0000 Committer: Martin Harris <[email protected]> Committed: Mon Nov 4 18:14:45 2013 +0000 ---------------------------------------------------------------------- .../src/main/java/brooklyn/demo/Subscribe.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/brooklyn-library/blob/4c2c535b/examples/simple-messaging-pubsub/src/main/java/brooklyn/demo/Subscribe.java ---------------------------------------------------------------------- diff --git a/examples/simple-messaging-pubsub/src/main/java/brooklyn/demo/Subscribe.java b/examples/simple-messaging-pubsub/src/main/java/brooklyn/demo/Subscribe.java index 0a51cf2..7899f47 100644 --- a/examples/simple-messaging-pubsub/src/main/java/brooklyn/demo/Subscribe.java +++ b/examples/simple-messaging-pubsub/src/main/java/brooklyn/demo/Subscribe.java @@ -39,7 +39,7 @@ public class Subscribe { MessageConsumer messageConsumer = session.createConsumer(destination); // Try and receive 100 messages - for (int n = 0; n < 100; n++) { + for (int n = 0; n < MESSAGE_COUNT; n++) { TextMessage msg = (TextMessage) messageConsumer.receive(MESSAGE_TIMEOUT_MILLIS); if (msg == null) { System.out.printf("No message received in %s milliseconds, exiting", MESSAGE_TIMEOUT_MILLIS);
