@Override
		public void run() {
			while(this.running) {
				if(!this.transitionsToPersist.isEmpty()) {
					try {
						this.dbConnection.persistTransitionStoreEntry(this.transitionsToPersist.poll());
					} catch (ConnectException e) {
						System.err.println("Cannot persist TransitionStore Entry " + e.getMessage());
					}
				}
				if(!this.transitionsToDepersist.isEmpty()) {
					try {
						this.dbConnection.dePersistTransitionStoreEntry(this.transitionsToDepersist.poll());
					} catch (ConnectException e) {
						System.err.println("Cannot depersist TransitionStore Entry " + e.getMessage());
					}
				}
				try {
					Thread.sleep(500);
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
			}
		}