diff --git a/message/write_message.go b/message/write_message.go
index 82c0a3d0c5..fde22ee06d 100644
--- a/message/write_message.go
+++ b/message/write_message.go
@@ -58,7 +58,7 @@ func (messages WriteMessages) InsertItems() int64 {
 	return items
 }
 
-func (messages WriteMessages) InsertMessage() WriteInserts {
+func (messages WriteMessages) GetInserts() WriteInserts {
 	inserts := []*WriteInsert{}
 	for _, msg := range messages {
 		if m, ok := msg.(*WriteInsert); ok {