ActiveMQ
Unit 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 22,848 units with 167,755 lines of code in units (79.0% of code).
    • 37 very long units (4,777 lines of code)
    • 194 long units (12,547 lines of code)
    • 1,210 medium size units (36,659 lines of code)
    • 2,198 small units (31,937 lines of code)
    • 19,209 very small units (81,835 lines of code)
2% | 7% | 21% | 19% | 48%
Legend:
101+
51-100
21-50
11-20
1-10
Unit Size per Extension
java2% | 7% | 21% | 19% | 48%
Legend:
101+
51-100
21-50
11-20
1-10
Unit Size per Logical Component
primary logical decomposition
activemq-broker2% | 8% | 22% | 18% | 47%
activemq-client2% | 5% | 18% | 19% | 54%
activemq-openwire-generator21% | 13% | 36% | 11% | 16%
activemq-kahadb-store3% | 9% | 25% | 21% | 39%
activemq-amqp14% | 9% | 19% | 20% | 35%
activemq-ra3% | 3% | 13% | 15% | 63%
activemq-web4% | 3% | 21% | 27% | 42%
activemq-jaas12% | 6% | 25% | 31% | 24%
activemq-console2% | 7% | 37% | 17% | 35%
activemq-shiro11% | 0% | 11% | 22% | 54%
activemq-mqtt4% | 3% | 38% | 20% | 33%
activemq-openwire-legacy0% | 4% | 15% | 15% | 63%
activemq-tooling0% | 12% | 17% | 22% | 48%
activemq-stomp0% | 17% | 34% | 14% | 33%
activemq-jdbc-store0% | 7% | 33% | 19% | 38%
assembly0% | 21% | 68% | 2% | 8%
activemq-http0% | 7% | 26% | 22% | 43%
activemq-runtime-config0% | 11% | 19% | 33% | 35%
activemq-jms-pool0% | 7% | 15% | 15% | 60%
activemq-partition0% | 19% | 13% | 15% | 51%
trash0% | 7% | 32% | 27% | 32%
activemq-karaf0% | 46% | 23% | 7% | 22%
activemq-osgi0% | 59% | 0% | 0% | 40%
activemq-web-console0% | 11% | 6% | 28% | 53%
activemq-camel0% | 0% | 13% | 25% | 60%
activemq-leveldb-store0% | 0% | 25% | 25% | 48%
activemq-spring0% | 0% | 16% | 21% | 61%
activemq-pool0% | 0% | 44% | 0% | 55%
activemq-log4j-appender0% | 0% | 23% | 24% | 52%
activemq-cf0% | 0% | 77% | 0% | 22%
Legend:
101+
51-100
21-50
11-20
1-10
Alternative Visuals
Longest Units
Top 50 longest units
Unit# linesMcCabe index# params
public EncodedMessage transform()
in activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/message/JMSMappingOutboundTransformer.java
235 68 1
protected void generateFile()
in activemq-openwire-generator/src/main/java/org/apache/activemq/openwire/tool/CSourcesGenerator.java
221 57 1
Set checkpointUpdate()
in activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java
193 60 2
public final void acknowledge()
in activemq-broker/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java
179 46 2
protected void generateFile()
in activemq-openwire-generator/src/main/java/org/apache/activemq/openwire/tool/JavaMarshallingGenerator.java
164 16 1
protected void serviceRemoteCommand()
in activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
158 44 1
public void run()
in activemq-client/src/main/java/org/apache/activemq/ActiveMQSession.java
157 34 0
final boolean doReconnect()
in activemq-client/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
143 49 0
static
in activemq-client/src/main/java/org/apache/activemq/filter/PropertyExpression.java
143 10 0
protected void generateFile()
in activemq-openwire-generator/src/main/java/org/apache/activemq/openwire/tool/CSharpMarshallingGenerator.java
141 18 1
protected void recoverIndex()
in activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java
136 29 1
static
in activemq-client/src/main/java/org/apache/activemq/command/ActiveMQMessage.java
130 18 0
protected ActiveMQEndpointWorker()
in activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQEndpointWorker.java
126 22 2
public void createSender()
in activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpSession.java
126 26 1
protected void populateMessage()
in activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/message/InboundTransformer.java
125 45 2
protected void doMessages()
in activemq-web/src/main/java/org/apache/activemq/web/MessageListenerServlet.java
122 22 3
public void send()
in activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java
121 31 2
protected boolean authenticate()
in activemq-jaas/src/main/java/org/apache/activemq/jaas/LDAPLoginModule.java
117 24 2
protected Boolean compare()
in activemq-client/src/main/java/org/apache/activemq/filter/ComparisonExpression.java
116 55 2
public void send()
in activemq-broker/src/main/java/org/apache/activemq/broker/region/Topic.java
115 29 2
public void send()
in activemq-broker/src/main/java/org/apache/activemq/plugin/StatisticsBroker.java
115 16 2
public void oneway()
in activemq-client/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
113 39 1
static
in activemq-client/src/main/java/org/apache/activemq/util/TypeConversionSupport.java
112 2 0
private Section convertBody()
in activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/message/JMSMappingOutboundTransformer.java
110 31 1
public void rollback()
in activemq-client/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java
109 24 0
protected void generateFile()
in activemq-openwire-generator/src/main/java/org/apache/activemq/openwire/tool/JavaTestsGenerator.java
107 19 1
protected void processQueue()
in activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/journal/DataFileAppender.java
107 23 0
public List healthList()
in activemq-broker/src/main/java/org/apache/activemq/broker/jmx/HealthView.java
106 37 0
void export()
in activemq-console/src/main/java/org/apache/activemq/console/command/store/StoreExporter.java
105 7 2
public boolean iterate()
in activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java
105 27 0
protected void generateFile()
in activemq-openwire-generator/src/main/java/org/apache/activemq/openwire/tool/CppHeadersGenerator.java
104 12 1
protected boolean matches()
in activemq-shiro/src/main/java/org/apache/activemq/shiro/authz/ActiveMQWildcardPermission.java
104 34 2
void onMQTTConnect()
in activemq-mqtt/src/main/java/org/apache/activemq/transport/mqtt/MQTTProtocolConverter.java
103 19 1
protected void processQueue()
in activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/journal/CallerBufferingDataFileAppender.java
103 25 0
private PendingList doPageInForDispatch()
in activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java
103 22 3
private void serviceRemoteConsumerAdvisory()
in activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
102 28 1
protected void process()
in activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/scheduler/JobSchedulerStoreImpl.java
101 6 2
public ActiveMQMessageConsumer()
in activemq-client/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java
100 23 11
public void removeSubscription()
in activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java
100 27 3
protected void generateFile()
in activemq-openwire-generator/src/main/java/org/apache/activemq/openwire/tool/CppMarshallingClassesGenerator.java
97 10 1
public SchedulerBroker()
in activemq-broker/src/main/java/org/apache/activemq/broker/scheduler/SchedulerBroker.java
97 3 3
public void handle()
in activemq-broker/src/main/java/org/apache/activemq/util/DefaultIOExceptionHandler.java
97 25 1
private void recover()
in activemq-jdbc-store/src/main/java/org/apache/activemq/store/journal/JournalPersistenceAdapter.java
95 21 0
public InputStream openInputStream()
in activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/page/Transaction.java
95 14 1
public Transport doCompositeConnect()
in activemq-broker/src/main/java/org/apache/activemq/transport/vm/VMTransportFactory.java
95 19 1
public synchronized void start()
in activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/journal/Journal.java
93 22 0
private void recover()
in activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java
92 21 0
public void stop()
in activemq-broker/src/main/java/org/apache/activemq/broker/BrokerService.java
92 18 0
protected void doPost()
in activemq-web/src/main/java/org/apache/activemq/web/MessageListenerServlet.java
91 25 2
public Map getSummary()
in activemq-tooling/activemq-perf-maven-plugin/src/main/java/org/apache/activemq/tool/reports/plugins/ThroughputReportPlugin.java
91 11 0