Repository: qpid-jms Updated Branches: refs/heads/master feb6792ae -> 9d88cf840
NO-JIRA: Clean up a few spelling errors in API docs etc. Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/9d88cf84 Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/9d88cf84 Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/9d88cf84 Branch: refs/heads/master Commit: 9d88cf840ba39bc9ce20d661090622939f78ca4f Parents: feb6792 Author: Timothy Bish <[email protected]> Authored: Thu Aug 27 13:38:30 2015 -0400 Committer: Timothy Bish <[email protected]> Committed: Thu Aug 27 13:38:30 2015 -0400 ---------------------------------------------------------------------- .../main/java/org/apache/qpid/jms/JmsConnectionFactory.java | 6 +++--- .../src/main/java/org/apache/qpid/jms/JmsMessageProducer.java | 2 +- .../src/main/java/org/apache/qpid/jms/provider/Provider.java | 2 +- .../apache/qpid/jms/provider/amqp/AmqpAbstractResource.java | 4 ++-- .../java/org/apache/qpid/jms/provider/amqp/AmqpProvider.java | 4 ++-- .../java/org/apache/qpid/jms/provider/amqp/AmqpSession.java | 3 +-- .../java/org/apache/qpid/jms/provider/amqp/AmqpSupport.java | 1 + .../qpid/jms/provider/failover/FailoverProviderFactory.java | 2 +- .../apache/qpid/jms/integration/ConsumerIntegrationTest.java | 2 +- 9 files changed, 13 insertions(+), 13 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/9d88cf84/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsConnectionFactory.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsConnectionFactory.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsConnectionFactory.java index 983545e..503d7bf 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsConnectionFactory.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsConnectionFactory.java @@ -347,7 +347,7 @@ public class JmsConnectionFactory extends JNDIStorable implements ConnectionFact } /** - * @return the username + * @return the user name used for connection authentication. */ public String getUsername() { return this.username; @@ -355,14 +355,14 @@ public class JmsConnectionFactory extends JNDIStorable implements ConnectionFact /** * @param username - * the username to set + * the user name to set */ public void setUsername(String username) { this.username = username; } /** - * @return the password + * @return the password set for connection authentication. */ public String getPassword() { return this.password; http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/9d88cf84/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsMessageProducer.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsMessageProducer.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsMessageProducer.java index 1302d24..3c4dde2 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsMessageProducer.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsMessageProducer.java @@ -33,7 +33,7 @@ import org.apache.qpid.jms.provider.Provider; import org.apache.qpid.jms.provider.ProviderFuture; /** - * Implementation of a Jms MessageProducer + * Implementation of a JMS MessageProducer */ public class JmsMessageProducer implements MessageProducer { http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/9d88cf84/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/Provider.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/Provider.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/Provider.java index 0c1f85c..ea82390 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/Provider.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/Provider.java @@ -128,7 +128,7 @@ public interface Provider { * need to be started again via a call to <code>start()</code> * * For some JMS Resources it is necessary or advantageous to have a stopped state that - * cam be triggered to stop the resource generating new events or messages. + * can be triggered to stop the resource generating new events or messages. * * An example of this would be a JMS Session which should not receive any incoming messages * for any consumers until the JMS layer is in a state to handle them. One such time would be http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/9d88cf84/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpAbstractResource.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpAbstractResource.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpAbstractResource.java index e312b85..fbf9453 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpAbstractResource.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpAbstractResource.java @@ -374,9 +374,9 @@ public abstract class AmqpAbstractResource<R extends JmsResource, E extends Endp } /** - * When aborting the open operation, and there isnt an error condition, + * When aborting the open operation, and there isn't an error condition, * provided by the peer, the returned exception will be used instead. - * A subclass may override this method to provide alternative behaviour. + * A subclass may override this method to provide alternative behavior. */ protected Exception getOpenAbortException() { return new IOException("Open failed unexpectedly."); http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/9d88cf84/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpProvider.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpProvider.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpProvider.java index e3e705a..bce9282 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpProvider.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpProvider.java @@ -280,7 +280,7 @@ public class AmqpProvider implements Provider, TransportListener { Connection protonConnection = Connection.Factory.create(); - if(getMaxFrameSize() > 0) { + if (getMaxFrameSize() > 0) { protonTransport.setMaxFrameSize(getMaxFrameSize()); } protonTransport.setChannelMax(getChannelMax()); @@ -874,7 +874,7 @@ public class AmqpProvider implements Provider, TransportListener { } void fireProviderException(Throwable ex) { - if(connectionOpenRequest != null) { + if (connectionOpenRequest != null) { connectionOpenRequest.onFailure(ex); connectionOpenRequest = null; } http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/9d88cf84/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpSession.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpSession.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpSession.java index 46ff1bd..27186c4 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpSession.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpSession.java @@ -71,7 +71,7 @@ public class AmqpSession extends AmqpAbstractResource<JmsSessionInfo, Session> { Session session = this.getEndpoint(); session.setIncomingCapacity(Integer.MAX_VALUE); - if(outgoingWindow >= 0) { + if (outgoingWindow >= 0) { session.setOutgoingWindow(outgoingWindow); } @@ -261,7 +261,6 @@ public class AmqpSession extends AmqpAbstractResource<JmsSessionInfo, Session> { return false; } - //TODO: unused? /** * Call to send an error that occurs outside of the normal asynchronous processing * of a session resource such as a remote close etc. http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/9d88cf84/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpSupport.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpSupport.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpSupport.java index 29d94ab..2c01771 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpSupport.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpSupport.java @@ -19,6 +19,7 @@ package org.apache.qpid.jms.provider.amqp; import org.apache.qpid.proton.amqp.Symbol; public class AmqpSupport { + // Symbols used for connection capabilities public static final Symbol SOLE_CONNECTION_CAPABILITY = Symbol.valueOf("sole-connection-for-container"); public static final Symbol ANONYMOUS_RELAY = Symbol.valueOf("ANONYMOUS-RELAY"); http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/9d88cf84/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/failover/FailoverProviderFactory.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/failover/FailoverProviderFactory.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/failover/FailoverProviderFactory.java index 4f48625..f2128cf 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/failover/FailoverProviderFactory.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/failover/FailoverProviderFactory.java @@ -36,7 +36,7 @@ public class FailoverProviderFactory extends ProviderFactory { public static final String FAILOVER_OPTION_PREFIX = "failover."; /** - * Prefix addion used for all nested properties that should be applied to any remote URIs. + * Prefix addition used for all nested properties that should be applied to any remote URIs. */ public static final String FAILOVER_NESTED_OPTION_PREFIX_ADDON = "nested."; http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/9d88cf84/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/ConsumerIntegrationTest.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/ConsumerIntegrationTest.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/ConsumerIntegrationTest.java index a84c3de..b870534 100644 --- a/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/ConsumerIntegrationTest.java +++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/ConsumerIntegrationTest.java @@ -108,7 +108,7 @@ public class ConsumerIntegrationTest extends QpidJmsTestCase { } /** - * Test that a message is received when calling recieve with a timeout + * Test that a message is received when calling receive with a timeout * of 0, which means wait indefinitely. */ @Test(timeout = 20000) --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
