diff --git a/holder.go b/holder.go
index 6292d9c59..c2e8f5a6e 100644
--- a/holder.go
+++ b/holder.go
@@ -248,8 +248,7 @@ func (h *Holder) limitedSchema() []*IndexInfo {
 func (h *Holder) applySchema(schema *Schema) error {
 	// Create indexes that don't exist.
 	for _, index := range schema.Indexes {
-		opt := IndexOptions{}
-		idx, err := h.CreateIndexIfNotExists(index.Name, opt)
+		idx, err := h.CreateIndexIfNotExists(index.Name, index.Options)
 		if err != nil {
 			return errors.Wrap(err, "creating index")
 		}
diff --git a/server.go b/server.go
index db577fb86..8d4ecdde3 100644
--- a/server.go
+++ b/server.go
@@ -457,8 +457,8 @@ func (s *Server) receiveMessage(m Message) error {
 		}
 		idx.setRemoteMaxShard(obj.Shard)
 	case *CreateIndexMessage:
-		opt := IndexOptions{}
-		_, err := s.holder.CreateIndex(obj.Index, opt)
+		opt := obj.Meta
+		_, err := s.holder.CreateIndex(obj.Index, *opt)
 		if err != nil {
 			return err
 		}