diff --git a/assembly/src/release/example/ruby/catstomp.rb b/assembly/src/release/example/ruby/catstomp.rb
index 629d7b2b06..96c6c495f5 100755
--- a/assembly/src/release/example/ruby/catstomp.rb
+++ b/assembly/src/release/example/ruby/catstomp.rb
@@ -42,6 +42,7 @@ begin
     STDIN.each_line { |line| 
         @conn.send @destination, line, @headers
     }
+    @conn.disconnect
 
 rescue 
 end
diff --git a/assembly/src/release/example/ruby/listener.rb b/assembly/src/release/example/ruby/listener.rb
index 6f948e9456..c11efc3b92 100755
--- a/assembly/src/release/example/ruby/listener.rb
+++ b/assembly/src/release/example/ruby/listener.rb
@@ -48,3 +48,4 @@ while true
  		$stdout.print "#{@msg.command}: #{@msg.body}\n"
 	end
 end
+@conn.disconnect
\ No newline at end of file
diff --git a/assembly/src/release/example/ruby/publisher.rb b/assembly/src/release/example/ruby/publisher.rb
index f1ea6b9f65..ed647bae34 100755
--- a/assembly/src/release/example/ruby/publisher.rb
+++ b/assembly/src/release/example/ruby/publisher.rb
@@ -63,3 +63,5 @@ for i in 1..(@batches)
 end
 
 @conn.send '/topic/event', "SHUTDOWN", {'persistent'=>'false'}
+
+@conn.disconnect
\ No newline at end of file
diff --git a/assembly/src/release/example/ruby/stompcat.rb b/assembly/src/release/example/ruby/stompcat.rb
index 4aaa2e434a..a77b77e42b 100755
--- a/assembly/src/release/example/ruby/stompcat.rb
+++ b/assembly/src/release/example/ruby/stompcat.rb
@@ -43,7 +43,8 @@ begin
         $stdout.flush
         @conn.ack @msg.headers["message-id"]
     end
-
+    @conn.disconnect
+  
 rescue 
 end