RedisDynoQueue implements DynoQueue { @Override public int getUnackTime() { return unackTime; } RedisDynoQueue(String redisKeyPrefix, String queueName, Set<String> allShards, String shardName, ShardingStrategy shardingStrategy, boolean singleRingTopology);  RedisDynoQueue(String redisKeyPrefix, String queueName, Set<String> allShards, String shardName, int unackScheduleInMS, ShardingStrategy shardingStrategy, boolean singleRingTopology);  RedisDynoQueue(Clock clock, String redisKeyPrefix, String queueName, Set<String> allShards, String shardName, int unackScheduleInMS, ShardingStrategy shardingStrategy, boolean singleRingTopology); RedisDynoQueue withQuorumConn(JedisCommands quorumConn); RedisDynoQueue withNonQuorumConn(JedisCommands nonQuorumConn); RedisDynoQueue withUnackTime(int unackTime); @Override String getName(); @Override int getUnackTime(); @Override List<String> push(final List<Message> messages); @Override List<Message> peek(final int messageCount); @Override List<Message> unsafePeekAllShards(final int messageCount); @Override List<Message> pop(int messageCount, int wait, TimeUnit unit); @Override Message popWithMsgId(String messageId); @Override Message unsafePopWithMsgIdAllShards(String messageId); Message popWithMsgIdHelper(String messageId, String targetShard, boolean warnIfNotExists); List<Message> unsafePopAllShards(int messageCount, int wait, TimeUnit unit); @Override boolean ack(String messageId); @Override void ack(List<Message> messages); @Override boolean setUnackTimeout(String messageId, long timeout); @Override boolean setTimeout(String messageId, long timeout); @Override boolean remove(String messageId); @Override boolean atomicRemove(String messageId); @Override boolean ensure(Message message); @Override boolean containsPredicate(String predicate); @Override String getMsgWithPredicate(String predicate); @Override boolean containsPredicate(String predicate, boolean localShardOnly); @Override String getMsgWithPredicate(String predicate, boolean localShardOnly); @Override Message popMsgWithPredicate(String predicate, boolean localShardOnly); @Override List<Message> bulkPop(int messageCount, int wait, TimeUnit unit); @Override List<Message> unsafeBulkPop(int messageCount, int wait, TimeUnit unit); @Override Message get(String messageId); @Override List<Message> getAllMessages(); @Override Message localGet(String messageId); @Override long size(); @Override Map<String, Map<String, Long>> shardSizes(); @Override void clear(); @Override void processUnacks(); @Override List<Message> findStaleMessages(); @Override void atomicProcessUnacks(); @Override void close();  }
@Test public void testGetUnackTime() { assertEquals(1_000, rdq.getUnackTime()); }