+ /** The start time. */
+ private long startTime;
+
+ /** The number of bytes. */
+ private long counter;
+
+ /**
+ * Creates a new rate limiting filter.
+ *
+ * @param eventBus
+ * The event bus
+ * @param name
+ * The name of the filter
+ * @param rate
+ * The limiting rate (in bytes/second)
+ */
+ public RateLimitingFilter(EventBus eventBus, String name, int rate) {
+ this(eventBus, name, rate, 0);
+ }