|
|
|
@ -110,7 +110,7 @@ public abstract class EdgeGrpcSession implements Closeable { |
|
|
|
private static final String QUEUE_START_TS_ATTR_KEY = "queueStartTs"; |
|
|
|
private static final String QUEUE_START_SEQ_ID_ATTR_KEY = "queueStartSeqId"; |
|
|
|
|
|
|
|
private static final int MAX_DOWNLINK_ATTEMPTS = 10; |
|
|
|
private static final int MAX_DOWNLINK_ATTEMPTS = 3; |
|
|
|
private static final String RATE_LIMIT_REACHED = "Rate limit reached"; |
|
|
|
|
|
|
|
protected static final ConcurrentLinkedQueue<EdgeEvent> highPriorityQueue = new ConcurrentLinkedQueue<>(); |
|
|
|
|