diff --git a/ChangeLog.md b/ChangeLog.md
--- a/ChangeLog.md
+++ b/ChangeLog.md
@@ -1,5 +1,8 @@
 # Changelog for logstash
 
+## v0.1.0.1
+
+- Fixes a bug which caused `LogstashConnection`s from a `LogstashPool` to not get released properly in `runLogstashPool`
 ## v0.1
 
 - First release with support for connecting to `tcp` (incl. TLS) Logstash inputs and the `json_lines` codec.
diff --git a/logstash.cabal b/logstash.cabal
--- a/logstash.cabal
+++ b/logstash.cabal
@@ -4,10 +4,10 @@
 --
 -- see: https://github.com/sol/hpack
 --
--- hash: b7aa35eeee7789f4d5593a17d55eee75a1241ad7b1549bb21a1b45c6056ca022
+-- hash: dacbd9edf7d3d77751149456ac269687395f9dc7bb51f53de298d944c8b3dd7c
 
 name:           logstash
-version:        0.1.0.0
+version:        0.1.0.1
 synopsis:       Logstash client library for Haskell
 description:    Please see the README on GitHub at <https://github.com/mbg/logstash#readme>
 category:       Network
diff --git a/src/Logstash.hs b/src/Logstash.hs
--- a/src/Logstash.hs
+++ b/src/Logstash.hs
@@ -127,6 +127,9 @@
         mr <- restore (timeout time $ runInIO $ runReaderT (action s) resource) 
             `onException` destroyResource pool local resource
 
+        -- return the resource to the pool
+        putResource local resource
+
         -- raise an exception if a timeout occurred
         maybe (throw LogstashTimeout) pure mr