diff --git a/files/log-gearman-client.py b/files/log-gearman-client.py
index 0f36649..a472c19 100644
--- a/files/log-gearman-client.py
+++ b/files/log-gearman-client.py
@@ -148,7 +148,13 @@ class Server(object):
             self.processors.append(processor)
 
     def main(self):
-        self.gearserver = gear.Server()
+        statsd_host = os.environ.get('STATSD_HOST')
+        statsd_port = int(os.environ.get('STATSD_PORT', 8125))
+        statsd_prefix = os.environ.get('STATSD_PREFIX', 'logstash.geard')
+        self.gearserver = gear.Server(
+            statsd_host=statsd_host,
+            statsd_port=statsd_port,
+            statsd_prefix=statsd_prefix)
 
         self.setup_processors()
         for processor in self.processors:
diff --git a/manifests/init.pp b/manifests/init.pp
index e69f9d0..661ca0e 100644
--- a/manifests/init.pp
+++ b/manifests/init.pp
@@ -40,6 +40,12 @@ class log_processor (
     require  => Class['pip'],
   }
 
+  package { 'statsd':
+    ensure   => latest,
+    provider => 'pip',
+    require  => Class['pip'],
+  }
+
   file { '/var/lib/crm114':
     ensure  => directory,
     owner   => 'logstash',