diff --git a/lib/active_publisher/connection.rb b/lib/active_publisher/connection.rb
index 9575a50..b3abd58 100644
--- a/lib/active_publisher/connection.rb
+++ b/lib/active_publisher/connection.rb
@@ -10,7 +10,8 @@ def self.connected?
 
     def self.connection
       CONNECTION_MUTEX.synchronize do
-        return @connection if @connection
+        # Connection must be a valid object and connected. Otherwise, reconnect.
+        return @connection if @connection && @connection.connected?
         @connection = create_connection
       end
     end