Path Lines of Code activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpSender.java 392 activemq-broker/src/main/java/org/apache/activemq/broker/BrokerBroadcaster.java 221 activemq-broker/src/main/java/org/apache/activemq/broker/jmx/AnnotatedMBean.java 200 activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ManagedRegionBroker.java 768 activemq-broker/src/main/java/org/apache/activemq/broker/region/AbstractRegion.java 555 activemq-broker/src/main/java/org/apache/activemq/broker/region/DurableTopicSubscription.java 370 activemq-broker/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java 670 activemq-broker/src/main/java/org/apache/activemq/broker/region/policy/RetainedMessageSubscriptionRecoveryPolicy.java 92 activemq-broker/src/main/java/org/apache/activemq/broker/region/policy/TimedSubscriptionRecoveryPolicy.java 94 activemq-broker/src/main/java/org/apache/activemq/broker/view/ConnectionDotFileInterceptor.java 263 activemq-broker/src/main/java/org/apache/activemq/network/LdapNetworkConnector.java 271 activemq-broker/src/main/java/org/apache/activemq/network/jms/JmsConnector.java 404 activemq-broker/src/main/java/org/apache/activemq/transport/auto/AutoSslTransportServer.java 53 activemq-broker/src/main/java/org/apache/activemq/util/osgi/Activator.java 180 activemq-client/src/main/java/org/apache/activemq/ActiveMQConnection.java 1431 activemq-client/src/main/java/org/apache/activemq/ActiveMQMessageTransformation.java 140 activemq-client/src/main/java/org/apache/activemq/ActiveMQProducer.java 427 activemq-client/src/main/java/org/apache/activemq/ActiveMQSession.java 1039 activemq-client/src/main/java/org/apache/activemq/ActiveMQSessionExecutor.java 164 activemq-client/src/main/java/org/apache/activemq/TransactionContext.java 594 activemq-client/src/main/java/org/apache/activemq/filter/BinaryExpression.java 34 activemq-client/src/main/java/org/apache/activemq/filter/ConstantExpression.java 97 activemq-client/src/main/java/org/apache/activemq/filter/DestinationMapNode.java 192 activemq-client/src/main/java/org/apache/activemq/filter/UnaryExpression.java 184 activemq-client/src/main/java/org/apache/activemq/openwire/OpenWireFormat.java 552 activemq-client/src/main/java/org/apache/activemq/state/CommandVisitorAdapter.java 172 activemq-client/src/main/java/org/apache/activemq/transport/discovery/simple/SimpleDiscoveryAgent.java 180 activemq-client/src/main/java/org/apache/activemq/transport/discovery/zeroconf/ZeroconfDiscoveryAgent.java 183 activemq-client/src/main/java/org/apache/activemq/transport/nio/NIOSSLTransport.java 426 activemq-client/src/main/java/org/apache/activemq/transport/reliable/DefaultReplayStrategy.java 30 activemq-client/src/main/java/org/apache/activemq/transport/reliable/ReliableTransport.java 210 activemq-client/src/main/java/org/apache/activemq/transport/udp/CommandDatagramChannel.java 168 activemq-client/src/main/java/org/apache/activemq/transport/udp/CommandDatagramSocket.java 160 activemq-client/src/main/java/org/apache/activemq/transport/udp/DatagramHeaderMarshaller.java 34 activemq-client/src/main/java/org/apache/activemq/util/IdGenerator.java 147 activemq-console/src/main/java/org/apache/activemq/console/command/ShutdownCommand.java 101 activemq-console/src/main/java/org/apache/activemq/console/command/store/StoreExporter.java 219 activemq-console/src/main/java/org/apache/activemq/console/filter/AmqMessagesQueryFilter.java 73 activemq-console/src/main/java/org/apache/activemq/console/filter/MBeansRegExQueryFilter.java 64 activemq-http/src/main/java/org/apache/activemq/transport/https/HttpsTransportFactory.java 58 activemq-http/src/main/java/org/apache/activemq/transport/util/TextWireFormat.java 44 activemq-http/src/main/java/org/apache/activemq/transport/ws/WSTransportProxy.java 209 activemq-http/src/main/java/org/apache/activemq/transport/ws/jetty11/MQTTSocket.java 107 activemq-http/src/main/java/org/apache/activemq/transport/ws/jetty11/StompSocket.java 67 activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java 3363 activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/journal/Journal.java 995 activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/util/SequenceSet.java 312 activemq-kahadb-store/src/main/proto/journal-data.proto 212 activemq-karaf/src/main/java/org/apache/activemq/karaf/commands/ActiveMQCommand.java 141 activemq-osgi/src/main/java/org/apache/activemq/osgi/ActiveMQServiceFactory.java 140 activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQManagedConnection.java 259 activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQManagedConnectionFactory.java 155 activemq-ra/src/main/java/org/apache/activemq/ra/InboundConnectionProxy.java 79 activemq-ra/src/main/java/org/apache/activemq/ra/ManagedConnectionProxy.java 156 activemq-spring/src/main/java/org/apache/activemq/xbean/XBeanBrokerFactory.java 80 activemq-stomp/src/main/java/org/apache/activemq/transport/stomp/ProtocolConverter.java 821 activemq-tooling/activemq-junit/src/main/java/org/apache/activemq/junit/EmbeddedActiveMQBroker.java 525 activemq-web-console/src/main/java/org/apache/activemq/web/WebConsoleStarter.java 70 activemq-web-console/src/main/java/org/apache/activemq/web/controller/SendMessage.java 194 activemq-web-console/src/main/webapp/js/plotkit/Canvas.js 529 activemq-web-console/src/main/webapp/js/plotkit/Layout.js 445 activemq-web-console/src/main/webapp/js/plotkit/SVG.js 504 activemq-web-console/src/main/webapp/js/prettify.js 958 activemq-web-console/src/main/webapp/message.jsp 225 activemq-web-demo/src/main/webapp/js/chat.js 136 activemq-web/src/main/java/org/apache/activemq/web/MessageListenerServlet.java 353 activemq-web/src/main/java/org/apache/activemq/web/MessageServletSupport.java 298 activemq-web/src/main/java/org/apache/activemq/web/WebClient.java 304