ActiveMQFile Size
| File | # lines | # units |
|---|---|---|
| MessageDatabase.java in activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb |
3354 | 256 |
| BrokerService.java in activemq-broker/src/main/java/org/apache/activemq/broker |
2358 | 280 |
| Queue.java in activemq-broker/src/main/java/org/apache/activemq/broker/region |
1988 | 120 |
| DemandForwardingBridgeSupport.java in activemq-broker/src/main/java/org/apache/activemq/network |
1612 | 89 |
| KahaDBStore.java in activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb |
1487 | 116 |
| TransportConnection.java in activemq-broker/src/main/java/org/apache/activemq/broker |
1420 | 110 |
| ActiveMQConnection.java in activemq-client/src/main/java/org/apache/activemq |
1402 | 187 |
| ActiveMQMessageConsumer.java in activemq-client/src/main/java/org/apache/activemq |
1223 | 77 |
| FailoverTransport.java in activemq-client/src/main/java/org/apache/activemq/transport/failover |
1186 | 97 |
| DefaultJDBCAdapter.java in activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/adapter |
1031 | 51 |
| Journal.java in activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/journal |
995 | 83 |
| ActiveMQSession.java in activemq-client/src/main/java/org/apache/activemq |
986 | 104 |
| PageFile.java in activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/page |
935 | 96 |
| ProtocolConverter.java in activemq-stomp/src/main/java/org/apache/activemq/transport/stomp |
818 | 37 |
| AdvisoryBroker.java in activemq-broker/src/main/java/org/apache/activemq/advisory |
800 | 46 |
| RegionBroker.java in activemq-broker/src/main/java/org/apache/activemq/broker/region |
788 | 79 |
| ActiveMQConnectionFactory.java in activemq-client/src/main/java/org/apache/activemq |
771 | 131 |
| Statements.java in activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc |
754 | 127 |
| SimpleCachedLDAPAuthorizationMap.java in activemq-broker/src/main/java/org/apache/activemq/security |
746 | 76 |
| ActiveMQStreamMessage.java in activemq-client/src/main/java/org/apache/activemq/command |
741 | 37 |
| PolicyEntry.java in activemq-broker/src/main/java/org/apache/activemq/broker/region/policy |
739 | 138 |
| MQTTProtocolConverter.java in activemq-mqtt/src/main/java/org/apache/activemq/transport/mqtt |
733 | 40 |
| ManagedRegionBroker.java in activemq-broker/src/main/java/org/apache/activemq/broker/jmx |
730 | 42 |
| Topic.java in activemq-broker/src/main/java/org/apache/activemq/broker/region |
722 | 40 |
| JobSchedulerStoreImpl.java in activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/scheduler |
697 | 32 |
| JDBCPersistenceAdapter.java in activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc |
692 | 82 |
| AmqpConnection.java in activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol |
664 | 42 |
| PrefetchSubscription.java in activemq-broker/src/main/java/org/apache/activemq/broker/region |
662 | 42 |
| ActiveMQMessage.java in activemq-client/src/main/java/org/apache/activemq/command |
649 | 68 |
| JobSchedulerImpl.java in activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/scheduler |
642 | 48 |
| JavaMarshallingGenerator.java in activemq-openwire-generator/src/main/java/org/apache/activemq/openwire/tool |
635 | 29 |
| BTreeNode.java in activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/index |
627 | 43 |
| TopicSubscription.java in activemq-broker/src/main/java/org/apache/activemq/broker/region |
617 | 54 |
| ConnectionStateTracker.java in activemq-client/src/main/java/org/apache/activemq/state |
615 | 52 |
| BaseDestination.java in activemq-broker/src/main/java/org/apache/activemq/broker/region |
605 | 102 |
| JournalPersistenceAdapter.java in activemq-jdbc-store/src/main/java/org/apache/activemq/store/journal |
601 | 57 |
| TransactionContext.java in activemq-client/src/main/java/org/apache/activemq |
594 | 38 |
| Message.java in activemq-client/src/main/java/org/apache/activemq/command |
571 | 108 |
| TempKahaDBStore.java in activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb |
561 | 50 |
| BaseDataStreamMarshaller.java in activemq-client/src/main/java/org/apache/activemq/openwire/v1 |
555 | 48 |
| BaseDataStreamMarshaller.java in activemq-client/src/main/java/org/apache/activemq/openwire/v9 |
555 | 48 |
| BaseDataStreamMarshaller.java in activemq-client/src/main/java/org/apache/activemq/openwire/v12 |
555 | 48 |
| BaseDataStreamMarshaller.java in activemq-client/src/main/java/org/apache/activemq/openwire/v11 |
555 | 48 |
| BaseDataStreamMarshaller.java in activemq-client/src/main/java/org/apache/activemq/openwire/v10 |
555 | 48 |
| BaseDataStreamMarshaller.java in activemq-openwire-legacy/src/main/java/org/apache/activemq/openwire/v6 |
555 | 48 |
| BaseDataStreamMarshaller.java in activemq-openwire-legacy/src/main/java/org/apache/activemq/openwire/v8 |
555 | 48 |
| BaseDataStreamMarshaller.java in activemq-openwire-legacy/src/main/java/org/apache/activemq/openwire/v7 |
555 | 48 |
| BaseDataStreamMarshaller.java in activemq-openwire-legacy/src/main/java/org/apache/activemq/openwire/v2 |
555 | 48 |
| BaseDataStreamMarshaller.java in activemq-openwire-legacy/src/main/java/org/apache/activemq/openwire/v5 |
555 | 48 |
| BaseDataStreamMarshaller.java in activemq-openwire-legacy/src/main/java/org/apache/activemq/openwire/v4 |
555 | 48 |
| File | # lines | # units |
|---|---|---|
| BrokerService.java in activemq-broker/src/main/java/org/apache/activemq/broker |
2358 | 280 |
| MessageDatabase.java in activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb |
3354 | 256 |
| ActiveMQConnection.java in activemq-client/src/main/java/org/apache/activemq |
1402 | 187 |
| PolicyEntry.java in activemq-broker/src/main/java/org/apache/activemq/broker/region/policy |
739 | 138 |
| ActiveMQConnectionFactory.java in activemq-client/src/main/java/org/apache/activemq |
771 | 131 |
| Statements.java in activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc |
754 | 127 |
| Queue.java in activemq-broker/src/main/java/org/apache/activemq/broker/region |
1988 | 120 |
| KahaDBStore.java in activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb |
1487 | 116 |
| TransportConnection.java in activemq-broker/src/main/java/org/apache/activemq/broker |
1420 | 110 |
| Message.java in activemq-client/src/main/java/org/apache/activemq/command |
571 | 108 |
| KahaDBPersistenceAdapter.java in activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb |
429 | 105 |
| ActiveMQSession.java in activemq-client/src/main/java/org/apache/activemq |
986 | 104 |
| BaseDestination.java in activemq-broker/src/main/java/org/apache/activemq/broker/region |
605 | 102 |
| FailoverTransport.java in activemq-client/src/main/java/org/apache/activemq/transport/failover |
1186 | 97 |
| PageFile.java in activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/page |
935 | 96 |
| DemandForwardingBridgeSupport.java in activemq-broker/src/main/java/org/apache/activemq/network |
1612 | 89 |
| Journal.java in activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/journal |
995 | 83 |
| ActiveMQActivationSpec.java in activemq-ra/src/main/java/org/apache/activemq/ra |
531 | 82 |
| JDBCPersistenceAdapter.java in activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc |
692 | 82 |
| EmbeddedActiveMQBroker.java in activemq-tooling/activemq-junit/src/main/java/org/apache/activemq/junit |
525 | 79 |
| RegionBroker.java in activemq-broker/src/main/java/org/apache/activemq/broker/region |
788 | 79 |
| ActiveMQMessageConsumer.java in activemq-client/src/main/java/org/apache/activemq |
1223 | 77 |
| NetworkBridgeConfiguration.java in activemq-broker/src/main/java/org/apache/activemq/network |
328 | 77 |
| SimpleCachedLDAPAuthorizationMap.java in activemq-broker/src/main/java/org/apache/activemq/security |
746 | 76 |
| TransactionContext.java in activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc |
511 | 75 |
| DestinationFilter.java in activemq-broker/src/main/java/org/apache/activemq/broker/region |
317 | 70 |
| AbstractKahaDBStore.java in activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb |
455 | 69 |
| ActiveMQMessage.java in activemq-client/src/main/java/org/apache/activemq/command |
649 | 68 |
| TransportConnector.java in activemq-broker/src/main/java/org/apache/activemq/broker |
477 | 68 |
| WireFormatInfo.java in activemq-client/src/main/java/org/apache/activemq/command |
303 | 67 |
| AdvisorySupport.java in activemq-client/src/main/java/org/apache/activemq/advisory |
487 | 67 |
| BrokerFilter.java in activemq-broker/src/main/java/org/apache/activemq/broker |
314 | 66 |
| ErrorBroker.java in activemq-broker/src/main/java/org/apache/activemq/broker |
312 | 65 |
| EmptyBroker.java in activemq-broker/src/main/java/org/apache/activemq/broker |
264 | 64 |
| BrokerView.java in activemq-broker/src/main/java/org/apache/activemq/broker/jmx |
424 | 64 |
| DestinationView.java in activemq-broker/src/main/java/org/apache/activemq/broker/jmx |
437 | 63 |
| ConsumerInfo.java in activemq-client/src/main/java/org/apache/activemq/command |
309 | 61 |
| TcpTransport.java in activemq-client/src/main/java/org/apache/activemq/transport/tcp |
499 | 58 |
| JournalPersistenceAdapter.java in activemq-jdbc-store/src/main/java/org/apache/activemq/store/journal |
601 | 57 |
| PooledSession.java in activemq-jms-pool/src/main/java/org/apache/activemq/jms/pool |
363 | 57 |
| LoggingBrokerPlugin.java in activemq-broker/src/main/java/org/apache/activemq/broker/util |
480 | 57 |
| ActiveMQConnectionRequestInfo.java in activemq-ra/src/main/java/org/apache/activemq/ra |
308 | 56 |
| ManagementContext.java in activemq-broker/src/main/java/org/apache/activemq/broker/jmx |
489 | 56 |
| MultiKahaDBPersistenceAdapter.java in activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb |
483 | 55 |
| AbstractPendingMessageCursor.java in activemq-broker/src/main/java/org/apache/activemq/broker/region/cursors |
272 | 55 |
| ActiveMQConnectionSupport.java in activemq-ra/src/main/java/org/apache/activemq/ra |
257 | 54 |
| TopicSubscription.java in activemq-broker/src/main/java/org/apache/activemq/broker/region |
617 | 54 |
| TcpTransportServer.java in activemq-client/src/main/java/org/apache/activemq/transport/tcp |
509 | 53 |
| LDAPAuthorizationMap.java in activemq-broker/src/main/java/org/apache/activemq/security |
386 | 53 |
| UdpTransport.java in activemq-client/src/main/java/org/apache/activemq/transport/udp |
339 | 52 |