diff --git a/ceilometer/storage/base.py b/ceilometer/storage/base.py
index a25acdb1..63e8ff92 100644
--- a/ceilometer/storage/base.py
+++ b/ceilometer/storage/base.py
@@ -153,7 +153,7 @@ class Connection(object):
         """Write the data to the backend storage system.
 
         :param data: a dictionary such as returned by
-                     ceilometer.meter.meter_message_from_counter
+                     ceilometer.publisher.utils.meter_message_from_counter
 
         All timestamps must be naive utc datetime object.
         """
diff --git a/ceilometer/storage/impl_db2.py b/ceilometer/storage/impl_db2.py
index 5f67ada6..0792ed0a 100644
--- a/ceilometer/storage/impl_db2.py
+++ b/ceilometer/storage/impl_db2.py
@@ -219,7 +219,7 @@ class Connection(pymongo_base.Connection):
         """Write the data to the backend storage system.
 
         :param data: a dictionary such as returned by
-                     ceilometer.meter.meter_message_from_counter
+                     ceilometer.publisher.utils.meter_message_from_counter
         """
         # Record the updated resource metadata
         data = copy.deepcopy(data)
diff --git a/ceilometer/storage/impl_hbase.py b/ceilometer/storage/impl_hbase.py
index 456acee8..5063ad99 100644
--- a/ceilometer/storage/impl_hbase.py
+++ b/ceilometer/storage/impl_hbase.py
@@ -144,7 +144,7 @@ class Connection(hbase_base.Connection, base.Connection):
         """Write the data to the backend storage system.
 
         :param data: a dictionary such as returned by
-          ceilometer.meter.meter_message_from_counter
+          ceilometer.publisher.utils.meter_message_from_counter
         """
         with self.conn_pool.connection() as conn:
             resource_table = conn.table(self.RESOURCE_TABLE)
diff --git a/ceilometer/storage/impl_log.py b/ceilometer/storage/impl_log.py
index 42d39d4a..ff52862e 100644
--- a/ceilometer/storage/impl_log.py
+++ b/ceilometer/storage/impl_log.py
@@ -104,7 +104,7 @@ class Connection(base.Connection):
         """Return an iterable of samples.
 
         Items are created by
-        :func:`ceilometer.meter.meter_message_from_counter`.
+        ceilometer.publisher.utils.meter_message_from_counter.
         """
         return []
 
diff --git a/ceilometer/storage/impl_mongodb.py b/ceilometer/storage/impl_mongodb.py
index 4867c141..80792c1f 100644
--- a/ceilometer/storage/impl_mongodb.py
+++ b/ceilometer/storage/impl_mongodb.py
@@ -245,7 +245,7 @@ class Connection(pymongo_base.Connection):
         """Write the data to the backend storage system.
 
         :param data: a dictionary such as returned by
-                     ceilometer.meter.meter_message_from_counter
+                     ceilometer.publisher.utils.meter_message_from_counter
         """
         # Record the updated resource metadata - we use $setOnInsert to
         # unconditionally insert sample timestamps and resource metadata
diff --git a/ceilometer/storage/impl_sqlalchemy.py b/ceilometer/storage/impl_sqlalchemy.py
index ec9f8044..cac8ba24 100644
--- a/ceilometer/storage/impl_sqlalchemy.py
+++ b/ceilometer/storage/impl_sqlalchemy.py
@@ -332,7 +332,7 @@ class Connection(base.Connection):
         """Write the data to the backend storage system.
 
         :param data: a dictionary such as returned by
-                     ceilometer.meter.meter_message_from_counter
+                     ceilometer.publisher.utils.meter_message_from_counter
         """
         engine = self._engine_facade.get_engine()
         with engine.begin() as conn: