@Override
  public void remove(String queueName, String messageId) {
    if (!queues.containsKey(queueName)) {
      queues.put(queueName, new ConcurrentLinkedDeque<>());
    }
    queues.get(queueName).remove(messageId);
  }
@Test
  public void testRemove() {
    String queueName = "test-queue";
    String id = "abcd-1234-defg-5678";
    assertEquals(0, queueDao.getSize(queueName));
    queueDao.pushIfNotExists(queueName, id, 123);
    assertEquals(1, queueDao.getSize(queueName));
    queueDao.remove(queueName, id);
    assertEquals(0, queueDao.getSize(queueName));
  }