apache / aries-journaled-eventsUnit Size

Intro

Unit size measurements show the distribution of size of units of code (methods, functions...).
Units are classified in four categories based on their size (lines of code): 1-20 (small units), 20-50 (medium size units), 51-100 (long units), 101+ (very long units).
You should aim at keeping units small (< 20 lines). Long units may become "bloaters", code that have increased to such gargantuan proportions that they are hard to work with.

Learn more...

Unit Size Overall

There are 110 units with 631 lines of code in units (58.6% of code).

0 very long units (0 lines of code)
0 long units (0 lines of code)
1 medium size units (31 lines of code)
13 small units (176 lines of code)
96 very small units (424 lines of code)

Legend:

101+

51-100

21-50

11-20

1-10

Unit Size per Extension

101+

51-100

21-50

11-20

1-10

Unit Size per Logical Component

primary logical decomposition

101+

51-100

21-50

11-20

1-10

Alternative Visuals

3D view of all units

Longest Units

Top 50 longest units

Unit	# lines	McCabe index	# params
private void refreshBuffer() in org.apache.aries.events.mongo/src/main/java/org/apache/aries/events/mongo/MessageReceiverImpl.java	31	7	1
public void run() in org.apache.aries.events.kafka/src/main/java/org/apache/aries/events/kafka/KafkaSubscription.java	20	5	0
public Subscription subscribe() in org.apache.aries.events.kafka/src/main/java/org/apache/aries/events/kafka/KafkaMessaging.java	19	3	1
private void poll() in org.apache.aries.events.mongo/src/main/java/org/apache/aries/events/mongo/MongoSubscription.java	17	4	1
private MongoSubscription() in org.apache.aries.events.mongo/src/main/java/org/apache/aries/events/mongo/MongoSubscription.java	15	4	3
private void adaptivePause() in org.apache.aries.events.mongo/src/main/java/org/apache/aries/events/mongo/MessageReceiverImpl.java	14	4	1
private void poll() in org.apache.aries.events.memory/src/main/java/org/apache/aries/events/memory/Topic.java	12	4	0
static MongoSubscription subscription() in org.apache.aries.events.mongo/src/main/java/org/apache/aries/events/mongo/MongoSubscription.java	12	3	3
private void publish1() in org.apache.aries.events.mongo/src/main/java/org/apache/aries/events/mongo/MessageSenderImpl.java	12	3	2
private long getStartOffset() in org.apache.aries.events.memory/src/main/java/org/apache/aries/events/memory/Topic.java	11	3	2
private void handleMessage() in org.apache.aries.events.memory/src/main/java/org/apache/aries/events/memory/Topic.java	11	2	1
private KafkaConsumer buildKafkaConsumer() in org.apache.aries.events.kafka/src/main/java/org/apache/aries/events/kafka/KafkaMessaging.java	11	1	1
static long upcomingIndex() in org.apache.aries.events.mongo/src/main/java/org/apache/aries/events/mongo/Common.java	11	2	1
private void doEvict() in org.apache.aries.events.mongo/src/main/java/org/apache/aries/events/mongo/MessageSenderImpl.java	11	1	1
protected void activate() in org.apache.aries.events.mongo/src/main/java/org/apache/aries/events/mongo/MongoMessaging.java	10	1	1
private synchronized Entry waitNext() in org.apache.aries.events.memory/src/main/java/org/apache/aries/events/memory/Topic.java	9	2	1
public void activate() in org.apache.aries.events.kafka/src/main/java/org/apache/aries/events/kafka/KafkaMessaging.java	9	1	1
public void send() in org.apache.aries.events.kafka/src/main/java/org/apache/aries/events/kafka/KafkaMessaging.java	9	2	2
public long append() in org.apache.aries.events.memory/src/main/java/org/apache/aries/events/memory/Journal.java	8	2	1
private void closeQuietly() in org.apache.aries.events.kafka/src/main/java/org/apache/aries/events/kafka/KafkaMessaging.java	8	3	1
private Document createDoc() in org.apache.aries.events.mongo/src/main/java/org/apache/aries/events/mongo/MessageSenderImpl.java	8	1	2
private synchronized void evict() in org.apache.aries.events.memory/src/main/java/org/apache/aries/events/memory/Journal.java	7	2	0
public long getFirstOffset() in org.apache.aries.events.memory/src/main/java/org/apache/aries/events/memory/Journal.java	7	2	0
public long getLastOffset() in org.apache.aries.events.memory/src/main/java/org/apache/aries/events/memory/Journal.java	7	2	0
public Position positionFromString() in org.apache.aries.events.kafka/src/main/java/org/apache/aries/events/kafka/KafkaMessaging.java	7	2	1
private static void safeClose() in org.apache.aries.events.mongo/src/main/java/org/apache/aries/events/mongo/CachingFactory.java	7	2	1
public long latestIndex() in org.apache.aries.events.mongo/src/main/java/org/apache/aries/events/mongo/MessageReceiverImpl.java	7	2	0
private void fetch() in org.apache.aries.events.mongo/src/main/java/org/apache/aries/events/mongo/MessageReceiverImpl.java	7	3	1
private void evict() in org.apache.aries.events.mongo/src/main/java/org/apache/aries/events/mongo/MessageSenderImpl.java	7	2	0
public boolean equals() in org.apache.aries.events.api/src/main/java/org/apache/aries/events/api/Message.java	7	5	1
private synchronized KafkaProducer kafkaProducer() in org.apache.aries.events.kafka/src/main/java/org/apache/aries/events/kafka/KafkaMessaging.java	6	2	0
private static KafkaPosition asKafkaPosition() in org.apache.aries.events.kafka/src/main/java/org/apache/aries/events/kafka/KafkaMessaging.java	6	2	1
public int compareTo() in org.apache.aries.events.mongo/src/main/java/org/apache/aries/events/mongo/MongoPosition.java	6	3	1
static MongoSubscription subscription() in org.apache.aries.events.mongo/src/main/java/org/apache/aries/events/mongo/MongoSubscription.java	6	1	4
private static Thread startBackgroundThread() in org.apache.aries.events.mongo/src/main/java/org/apache/aries/events/mongo/MongoSubscription.java	6	1	2
public Subscription subscribe() in org.apache.aries.events.mongo/src/main/java/org/apache/aries/events/mongo/MongoMessaging.java	6	1	1
public Message receive() in org.apache.aries.events.mongo/src/main/java/org/apache/aries/events/mongo/MessageReceiverImpl.java	6	1	1
private MessageSenderImpl() in org.apache.aries.events.mongo/src/main/java/org/apache/aries/events/mongo/MessageSenderImpl.java	6	1	2
public Message() in org.apache.aries.events.api/src/main/java/org/apache/aries/events/api/Message.java	6	1	2
public Subscription subscribe() in org.apache.aries.events.memory/src/main/java/org/apache/aries/events/memory/InMemoryMessaging.java	5	1	1
public synchronized Position send() in org.apache.aries.events.memory/src/main/java/org/apache/aries/events/memory/Topic.java	5	1	1
public Subscription subscribe() in org.apache.aries.events.memory/src/main/java/org/apache/aries/events/memory/Topic.java	5	1	1
static Iterable toHeaders() in org.apache.aries.events.kafka/src/main/java/org/apache/aries/events/kafka/KafkaMessaging.java	5	1	1
public synchronized void clear() in org.apache.aries.events.mongo/src/main/java/org/apache/aries/events/mongo/CachingFactory.java	5	1	0
private MessageReceiverImpl() in org.apache.aries.events.mongo/src/main/java/org/apache/aries/events/mongo/MessageReceiverImpl.java	5	1	2
private long oldestTimeStamp() in org.apache.aries.events.mongo/src/main/java/org/apache/aries/events/mongo/MessageSenderImpl.java	5	2	0
public int hashCode() in org.apache.aries.events.api/src/main/java/org/apache/aries/events/api/Message.java	5	1	0
public void send() in org.apache.aries.events.memory/src/main/java/org/apache/aries/events/memory/InMemoryMessaging.java	4	1	2
public Position positionFromString() in org.apache.aries.events.memory/src/main/java/org/apache/aries/events/memory/InMemoryMessaging.java	4	1	1
public Topic() in org.apache.aries.events.memory/src/main/java/org/apache/aries/events/memory/Topic.java	4	1	2