remove programmatic use of queuePrefix, it can be set via URL if needed
Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/1ae5fd60 Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/1ae5fd60 Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/1ae5fd60 Branch: refs/heads/master Commit: 1ae5fd609e09f50e4002a7fe31f83deb801ca9b0 Parents: c297b58 Author: Robert Gemmell <[email protected]> Authored: Tue Feb 3 10:57:11 2015 +0000 Committer: Robert Gemmell <[email protected]> Committed: Tue Feb 3 10:57:11 2015 +0000 ---------------------------------------------------------------------- .../main/java/org/apache/qpid/jms/example/Drain.java | 12 ++---------- 1 file changed, 2 insertions(+), 10 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/1ae5fd60/qpid-jms-examples/src/main/java/org/apache/qpid/jms/example/Drain.java ---------------------------------------------------------------------- diff --git a/qpid-jms-examples/src/main/java/org/apache/qpid/jms/example/Drain.java b/qpid-jms-examples/src/main/java/org/apache/qpid/jms/example/Drain.java index 9e8ffa5..fd5e186 100644 --- a/qpid-jms-examples/src/main/java/org/apache/qpid/jms/example/Drain.java +++ b/qpid-jms-examples/src/main/java/org/apache/qpid/jms/example/Drain.java @@ -44,16 +44,14 @@ public class Drain private int _count; private String _username; private String _password; - private String _queuePrefix; - public Drain(int count, String hostname, int port, String queuePrefix) + public Drain(int count, String hostname, int port) { _count = count; _hostname = hostname; _port = port; _username = DEFAULT_USER; _password = DEFAULT_PASSWORD; - _queuePrefix = queuePrefix; } public void runExample() @@ -62,11 +60,6 @@ public class Drain { //TODO: use JNDI lookup rather than direct instantiation JmsConnectionFactory factory = new JmsConnectionFactory("amqp://" + _hostname + ":" + _port); - if(_queuePrefix != null) - { - //TODO: use URL options? - factory.setQueuePrefix(_queuePrefix); - } Connection connection = factory.createConnection(_username,_password); connection.start(); @@ -132,8 +125,7 @@ public class Drain int count = args.isEmpty() ? DEFAULT_COUNT : Integer.parseInt(args.remove(0)); String hostname = args.isEmpty() ? DEFAULT_HOST : args.remove(0); int port = args.isEmpty() ? DEFAULT_PORT : Integer.parseInt(args.remove(0)); - String queuePrefix = args.isEmpty() ? null : args.remove(0); - new Drain(count, hostname, port, queuePrefix).runExample(); + new Drain(count, hostname, port).runExample(); } } \ No newline at end of file --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
