remove unconfigurable fields for user+pass, just use the constants
Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/630c23b9 Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/630c23b9 Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/630c23b9 Branch: refs/heads/master Commit: 630c23b94697820a390dcef812a3fe67f244fc04 Parents: 1ae5fd6 Author: Robert Gemmell <[email protected]> Authored: Tue Feb 3 11:00:31 2015 +0000 Committer: Robert Gemmell <[email protected]> Committed: Tue Feb 3 11:00:31 2015 +0000 ---------------------------------------------------------------------- .../src/main/java/org/apache/qpid/jms/example/Drain.java | 10 +++------- 1 file changed, 3 insertions(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/630c23b9/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 fd5e186..ff1f555 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 @@ -33,8 +33,8 @@ import org.apache.qpid.jms.JmsConnectionFactory; public class Drain { - private static final String DEFAULT_USER = "guest"; - private static final String DEFAULT_PASSWORD = "guest"; + private static final String USER = "guest"; + private static final String PASSWORD = "guest"; private static final int DEFAULT_PORT = 5672; private static final String DEFAULT_HOST = "localhost"; private static final int DEFAULT_COUNT = 10000; @@ -42,16 +42,12 @@ public class Drain private String _hostname; private int _port; private int _count; - private String _username; - private String _password; public Drain(int count, String hostname, int port) { _count = count; _hostname = hostname; _port = port; - _username = DEFAULT_USER; - _password = DEFAULT_PASSWORD; } public void runExample() @@ -61,7 +57,7 @@ public class Drain //TODO: use JNDI lookup rather than direct instantiation JmsConnectionFactory factory = new JmsConnectionFactory("amqp://" + _hostname + ":" + _port); - Connection connection = factory.createConnection(_username,_password); + Connection connection = factory.createConnection(USER, PASSWORD); connection.start(); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
