Merge pull request #443 from jsoref/spelling

Spelling

Author: michaelklishin

RUNNING_TESTS.md

@@ -21,7 +21,7 @@ can control the running node.
 
 `./mvnw verify` will start those nodes with the appropriate configuration.
 
-To easily fullfil all those requirements, you should use `make deps` to
+To easily fulfill all those requirements, you should use `make deps` to
 fetch the dependencies in the `deps` directory.
 
 You then run Maven with the `deps.dir` property set like this:

src/main/java/com/rabbitmq/client/ConnectionFactory.java

@@ -307,7 +307,7 @@ public void setVirtualHost(String virtualHost) {
     /**
      * Convenience method for setting the fields in an AMQP URI: host,
      * port, username, password and virtual host.  If any part of the
-     * URI is ommited, the ConnectionFactory's corresponding variable
+     * URI is omitted, the ConnectionFactory's corresponding variable
      * is left unchanged.
      * @param uri is the AMQP URI containing the data
      */
@@ -366,7 +366,7 @@ public void setUri(URI uri)
     /**
      * Convenience method for setting the fields in an AMQP URI: host,
      * port, username, password and virtual host.  If any part of the
-     * URI is ommited, the ConnectionFactory's corresponding variable
+     * URI is omitted, the ConnectionFactory's corresponding variable
      * is left unchanged.  Note that not all valid AMQP URIs are
      * accepted; in particular, the hostname must be given if the
      * port, username or password are given, and escapes in the
@@ -674,7 +674,7 @@ public boolean isSSL(){
     public void useSslProtocol()
         throws NoSuchAlgorithmException, KeyManagementException
     {
-        useSslProtocol(computeDefaultTlsProcotol(SSLContext.getDefault().getSupportedSSLParameters().getProtocols()));
+        useSslProtocol(computeDefaultTlsProtocol(SSLContext.getDefault().getSupportedSSLParameters().getProtocols()));
     }
 
     /**
@@ -777,7 +777,7 @@ protected void enableHostnameVerificationForBlockingIo() {
         }
     }
 
-    public static String computeDefaultTlsProcotol(String[] supportedProtocols) {
+    public static String computeDefaultTlsProtocol(String[] supportedProtocols) {
         if(supportedProtocols != null) {
             for (String supportedProtocol : supportedProtocols) {
                 if(PREFERRED_TLS_PROTOCOL.equalsIgnoreCase(supportedProtocol)) {

src/main/java/com/rabbitmq/client/impl/AMQConnection.java

@@ -851,7 +851,7 @@ public void handleConnectionClose(Command closeCommand) {
         SocketCloseWait scw = new SocketCloseWait(sse);
 
         // if shutdown executor is configured, use it. Otherwise
-        // execut socket close monitor the old fashioned way.
+        // execute socket close monitor the old fashioned way.
         // see rabbitmq/rabbitmq-java-client#91
         if(shutdownExecutor != null) {
             shutdownExecutor.execute(scw);

src/main/java/com/rabbitmq/client/impl/ChannelN.java

@@ -602,7 +602,7 @@ public AMQCommand transformReply(AMQCommand command) {
         boolean notify = false;
         try {
             // Synchronize the block below to avoid race conditions in case
-            // connnection wants to send Connection-CloseOK
+            // connection wants to send Connection-CloseOK
             synchronized (_channelMutex) {
                 startProcessShutdownSignal(signal, !initiatedByApplication, true);
                 quiescingRpc(reason, k);

src/main/java/com/rabbitmq/client/impl/MethodArgumentWriter.java

@@ -38,7 +38,7 @@ public class MethodArgumentWriter
     private int bitMask;
 
     /**
-     * Constructs a MethodArgumentWriter targetting the given DataOutputStream.
+     * Constructs a MethodArgumentWriter targeting the given DataOutputStream.
      */
     public MethodArgumentWriter(ValueWriter out)
     {

src/main/java/com/rabbitmq/client/impl/recovery/AutorecoveringConnection.java

@@ -681,7 +681,7 @@ private void recoverTopology(final ExecutorService executor) {
                 recoverEntitiesAsynchronously(executor, Utility.copy(recordedBindings));
                 recoverEntitiesAsynchronously(executor, Utility.copy(consumers).values());
             } catch (final Exception cause) {
-                final String message = "Caught an exception while recovering toplogy: " + cause.getMessage();
+                final String message = "Caught an exception while recovering topology: " + cause.getMessage();
                 final TopologyRecoveryException e = new TopologyRecoveryException(message, cause);
                 getExceptionHandler().handleTopologyRecoveryException(delegate, null, e);
             }

src/main/java/com/rabbitmq/utility/IntAllocator.java

@@ -23,7 +23,7 @@
  * {@link BitSet} representation of the free integers.
  * </p>
  *
- * <h2>Concurrecy Semantics:</h2>
+ * <h2>Concurrency Semantics:</h2>
  * This class is <b><i>not</i></b> thread safe.
  *
  * <h2>Implementation notes:</h2>

src/test/java/com/rabbitmq/client/test/SslContextFactoryTest.java

@@ -129,7 +129,7 @@ private SslContextFactory sslContextFactory() throws Exception {
     }
 
     private String tlsProtocol() throws NoSuchAlgorithmException {
-        return ConnectionFactory.computeDefaultTlsProcotol(SSLContext.getDefault().getSupportedSSLParameters().getProtocols());
+        return ConnectionFactory.computeDefaultTlsProtocol(SSLContext.getDefault().getSupportedSSLParameters().getProtocols());
     }
 
     private static class TrustNothingTrustManager implements X509TrustManager {

src/test/java/com/rabbitmq/client/test/functional/AlternateExchange.java

@@ -96,7 +96,7 @@ public void handleReturn(int replyCode,
      *
      * @param name the name of the exchange to be created, and queue
      *        to be bound
-     * @param ae the name of the alternate-exchage
+     * @param ae the name of the alternate-exchange
      */
     protected void setupRouting(String name, String ae) throws IOException {
         Map<String, Object> args = new HashMap<String, Object>();

src/test/java/com/rabbitmq/client/test/functional/BindingLifecycle.java

@@ -49,7 +49,7 @@ public class BindingLifecycle extends BindingLifecycleBase {
         Binding binding = setupExchangeBindings(false);
         channel.basicPublish(binding.x, binding.k, null, payload);
 
-        // Purge the queue, and test that we don't recieve a message
+        // Purge the queue, and test that we don't receive a message
         channel.queuePurge(binding.q);
 
         GetResponse response = channel.basicGet(binding.q, true);
@@ -153,7 +153,7 @@ public class BindingLifecycle extends BindingLifecycleBase {
      * The unsubscribe should cause the queue to auto_delete, which in
      * turn should cause the exchange to auto_delete.
      *
-     * Then re-declare the queue again and try to rebind it to the same exhange.
+     * Then re-declare the queue again and try to rebind it to the same exchange.
      *
      * Because the exchange has been auto-deleted, the bind operation
      * should fail.