diff --git a/provider/fastbin/src/main/java/org/apache/aries/rsa/provider/fastbin/tcp/TcpTransport.java b/provider/fastbin/src/main/java/org/apache/aries/rsa/provider/fastbin/tcp/TcpTransport.java
index 5d75370..3bbacb8 100644
--- a/provider/fastbin/src/main/java/org/apache/aries/rsa/provider/fastbin/tcp/TcpTransport.java
+++ b/provider/fastbin/src/main/java/org/apache/aries/rsa/provider/fastbin/tcp/TcpTransport.java
@@ -283,21 +283,21 @@
 
         if( max_read_rate!=0 || max_write_rate!=0 ) {
             rateLimitingChannel = new RateLimitingChannel();
-            schedualRateAllowanceReset();
+            scheduleRateAllowanceReset();
         }
 
         remoteAddress = channel.socket().getRemoteSocketAddress().toString();
         listener.onTransportConnected(this);
     }
 
-    private void schedualRateAllowanceReset() {
+    private void scheduleRateAllowanceReset() {
         dispatchQueue.executeAfter(1, TimeUnit.SECONDS, new Runnable(){
             public void run() {
                 if (!socketState.isConnected()) {
                     return;
                 }
                 rateLimitingChannel.resetAllowance();
-                schedualRateAllowanceReset();
+                scheduleRateAllowanceReset();
             }
         });
     }
diff --git a/provider/tcp/src/main/java/org/apache/aries/rsa/provider/tcp/TCPServer.java b/provider/tcp/src/main/java/org/apache/aries/rsa/provider/tcp/TCPServer.java
index 086d6f2..3ffb385 100644
--- a/provider/tcp/src/main/java/org/apache/aries/rsa/provider/tcp/TCPServer.java
+++ b/provider/tcp/src/main/java/org/apache/aries/rsa/provider/tcp/TCPServer.java
@@ -87,7 +87,7 @@
         String methodName = (String)ois.readObject();
         Object[] args = (Object[])ois.readObject();
         Object result = invoker.invoke(methodName, args);
-        result = resolveAsnyc(result);
+        result = resolveAsync(result);
         if (result instanceof InvocationTargetException) {
             result = ((InvocationTargetException) result).getCause();
         }
@@ -95,7 +95,7 @@
     }
 
     @SuppressWarnings("unchecked")
-    private Object resolveAsnyc(Object result) throws InterruptedException {
+    private Object resolveAsync(Object result) throws InterruptedException {
         if (result instanceof Future) {
             Future<Object> fu = (Future<Object>) result;
             try {
diff --git a/provider/tcp/src/test/java/org/apache/aries/rsa/provider/tcp/TcpProviderIntentTest.java b/provider/tcp/src/test/java/org/apache/aries/rsa/provider/tcp/TcpProviderIntentTest.java
index 1458e34..0c77597 100644
--- a/provider/tcp/src/test/java/org/apache/aries/rsa/provider/tcp/TcpProviderIntentTest.java
+++ b/provider/tcp/src/test/java/org/apache/aries/rsa/provider/tcp/TcpProviderIntentTest.java
@@ -51,7 +51,7 @@
     }
     
     @Test
-    public void basicAndAsnycIntents() {
+    public void basicAndAsyncIntents() {
         Map<String, Object> props = new HashMap<>();
         EndpointHelper.addObjectClass(props, exportedInterfaces);
         String[] standardIntents = new String[] {"osgi.basic", "osgi.async"};