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 |