Implemented most of the updating mechanism

src/Artemis.Storage/Repositories/Interfaces/IQueuedActionRepository.cs

@@ -9,4 +9,6 @@ public interface IQueuedActionRepository : IRepository
     void Remove(QueuedActionEntity queuedActionEntity);
     List<QueuedActionEntity> GetAll();
     List<QueuedActionEntity> GetByType(string type);
+    bool IsTypeQueued(string type);
+    void ClearByType(string type);
 }

src/Artemis.Storage/Repositories/QueuedActionRepository.cs

@@ -41,5 +41,17 @@ public class QueuedActionRepository : IQueuedActionRepository
         return _repository.Query<QueuedActionEntity>().Where(q => q.Type == type).ToList();
     }
 
+    /// <inheritdoc />
+    public bool IsTypeQueued(string type)
+    {
+        return _repository.Query<QueuedActionEntity>().Where(q => q.Type == type).Count() > 0;
+    }
+    
+    /// <inheritdoc />
+    public void ClearByType(string type)
+    {
+        _repository.DeleteMany<QueuedActionEntity>(q => q.Type == type);
+    }
+
     #endregion
 }