diff --git a/lib/carbon/instrumentation.py b/lib/carbon/instrumentation.py
index 5e4f83e4..49c9abcf 100644
--- a/lib/carbon/instrumentation.py
+++ b/lib/carbon/instrumentation.py
@@ -170,7 +170,7 @@ def cache_record(metric, value):
     else:
       fullMetric = '%s.agents.%s-%s.%s' % (prefix, HOSTNAME, settings.instance, metric)
     datapoint = (time.time(), value)
-    cache.MetricCache().store(fullMetric, datapoint)
+    state.client_manager.sendDatapoint(fullMetric, datapoint)
 
 
 def relay_record(metric, value):
diff --git a/lib/carbon/service.py b/lib/carbon/service.py
index 0c0fb894..5cd6bbb5 100644
--- a/lib/carbon/service.py
+++ b/lib/carbon/service.py
@@ -87,6 +87,7 @@ def setupPipeline(pipeline, root_service, settings):
       setupRelayProcessor(root_service, settings)
     elif processor == 'write':
       setupWriterProcessor(root_service, settings)
+      setupRelayProcessor(root_service, settings)
     else:
       raise ValueError("Invalid pipeline processor '%s'" % processor)