activemq-client/src/main/java/org/apache/activemq/TransactionContext.java (4 lines): - line 373: // TODO: verify that the server has seen the xid - line 376: // // TODO: verify that the xid was suspended. - line 460: // TODO: cache the known xids so we don't keep recreating this one?? - line 645: // TODO determine if this can happen... I think not. activemq-ra/src/main/java/org/apache/activemq/ra/InboundConnectionProxy.java (3 lines): - line 46: // TODO we could decide to barf if someone passes in incompatible options - line 51: // TODO we could decide to barf if someone passes in incompatible options - line 56: // TODO we could decide to barf if someone passes in incompatible options activemq-web-console/src/main/webapp/js/plotkit/Layout.js (3 lines): - line 68: // valid external options : TODO: input verification - line 175: // TODO: make this more efficient with better datastructures - line 233: // TODO: actually doesn't work if we don't know how the Canvas activemq-client/src/main/java/org/apache/activemq/ActiveMQConnection.java (3 lines): - line 742: // TODO if we move the TaskRunnerFactory to the connection - line 774: // TODO : org.apache.activemq.message.BrokerAdminCommand not yet - line 1544: //TODO shouldn't this check be on userSpecifiedClientID rather than the value of clientID? activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java (3 lines): - line 888: // TODO: do we need to modify the ack positions for the pub sub case? - line 1004: // TODO: do we need to modify the ack positions for the pub sub case? - line 2155: // TODO: prepare records can be dropped but completion records (maybe only commit outcomes) need to be migrated activemq-web/src/main/java/org/apache/activemq/web/WebClient.java (2 lines): - line 58: * stored inside a HttpSession TODO controls to prevent DOS attacks with users - line 59: * requesting many consumers TODO configure consumers with small prefetch. activemq-client/src/main/java/org/apache/activemq/filter/ConstantExpression.java (2 lines): - line 121: * TODO: more efficient hashCode() - line 130: * TODO: more efficient hashCode() activemq-web-console/src/main/webapp/js/prettify.js (2 lines): - line 206: // TODO: maybe style special characters inside a regexp as punctuation. - line 509: // TODO: handle letters in numeric escapes. activemq-http/src/main/java/org/apache/activemq/transport/ws/WSTransportProxy.java (2 lines): - line 248: // FIXME: Convert to async API w/ tiemeout getDefaultSendTimeOut(), TimeUnit.SECONDS); - line 269: // FIXME: Convert to async API w/ tiemeout getDefaultSendTimeOut(), TimeUnit.SECONDS); activemq-console/src/main/java/org/apache/activemq/console/filter/AmqMessagesQueryFilter.java (2 lines): - line 122: // TODO: should we use a durable subscriber or a retroactive non-durable - line 124: // TODO: if a durable subscriber is used, how do we manage it? activemq-broker/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java (2 lines): - line 88: // TODO: when the slave becomes a master, He should send a NULL message to all the - line 344: // TODO: what if the message is already in a DLQ??? activemq-stomp/src/main/java/org/apache/activemq/transport/stomp/ProtocolConverter.java (2 lines): - line 813: // TODO legacy - line 817: // TODO legacy activemq-client/src/main/java/org/apache/activemq/filter/UnaryExpression.java (2 lines): - line 214: * TODO: more efficient hashCode() - line 223: * TODO: more efficient hashCode() activemq-client/src/main/java/org/apache/activemq/filter/BinaryExpression.java (2 lines): - line 52: * TODO: more efficient hashCode() - line 61: * TODO: more efficient hashCode() activemq-broker/src/main/java/org/apache/activemq/broker/region/AbstractRegion.java (2 lines): - line 278: // TODO: implement a way to notify the subscribers that we want to - line 370: // TODO: think about this a little more. This is good cause activemq-broker/src/main/java/org/apache/activemq/broker/region/policy/RetainedMessageSubscriptionRecoveryPolicy.java (1 line): - line 66: // TODO should we remove the publisher's retain property?? activemq-broker/src/main/java/org/apache/activemq/network/LdapNetworkConnector.java (1 line): - line 306: // FIXME: disable JMX listing of LDAP managed connectors, we will activemq-broker/src/main/java/org/apache/activemq/broker/view/ConnectionDotFileInterceptor.java (1 line): - line 169: // TODO use clientId one day activemq-console/src/main/java/org/apache/activemq/console/command/ShutdownCommand.java (1 line): - line 138: // TODO: Check exceptions throwned activemq-client/src/main/java/org/apache/activemq/transport/udp/CommandDatagramChannel.java (1 line): - line 97: // TODO could use a DataInput implementation that talks direct activemq-client/src/main/java/org/apache/activemq/ActiveMQSessionExecutor.java (1 line): - line 127: // TODO - we should use a Map for this indexed by consumerId activemq-broker/src/main/java/org/apache/activemq/broker/region/DurableTopicSubscription.java (1 line): - line 323: // TODO: need to get from store activemq-client/src/main/java/org/apache/activemq/util/IdGenerator.java (1 line): - line 78: // TODO: replace the following line with IOHelper.close(ss) when Java 6 support is dropped activemq-broker/src/main/java/org/apache/activemq/broker/BrokerBroadcaster.java (1 line): - line 106: // TODO decide what to do with return values activemq-broker/src/main/java/org/apache/activemq/broker/jmx/AnnotatedMBean.java (1 line): - line 208: // [AMQ-9563] TODO: JDK 21 use Subject.current() instead activemq-web-console/src/main/webapp/message.jsp (1 line): - line 227: //TODO i18n messages activemq-client/src/main/java/org/apache/activemq/ActiveMQSession.java (1 line): - line 1988: // TODO: AMQ-8500 - update this when openwire supports JMSDeliveryTime activemq-client/src/main/java/org/apache/activemq/state/CommandVisitorAdapter.java (1 line): - line 226: // TODO Auto-generated method stub activemq-web-console/src/main/webapp/js/plotkit/Canvas.js (1 line): - line 673: // TODO: should we emit an event anyway? activemq-web-console/src/main/webapp/js/plotkit/SVG.js (1 line): - line 605: // TODO: we don't completely emulate the MochiKit.DOM.createElement activemq-kahadb-store/src/main/proto/journal-data.proto (1 line): - line 255: // TODO things to ponder activemq-client/src/main/java/org/apache/activemq/filter/DestinationMapNode.java (1 line): - line 174: // TODO is this correct, we are appending wildcard values here??? activemq-web/src/main/java/org/apache/activemq/web/MessageServletSupport.java (1 line): - line 313: // TODO cache destinations ??? activemq-web-console/src/main/java/org/apache/activemq/web/WebConsoleStarter.java (1 line): - line 72: // [AMQ-9239] TODO: Confirm jakarta ServeletContext API usage change activemq-http/src/main/java/org/apache/activemq/transport/util/TextWireFormat.java (1 line): - line 74: // TODO Implement for inactivity monitor activemq-client/src/main/java/org/apache/activemq/ActiveMQProducer.java (1 line): - line 451: // TODO: Update PropertyExpression to handle converting message headers to properties for JMSProducer. activemq-client/src/main/java/org/apache/activemq/transport/udp/DatagramHeaderMarshaller.java (1 line): - line 37: // TODO for large dynamic networks activemq-console/src/main/java/org/apache/activemq/console/filter/MBeansRegExQueryFilter.java (1 line): - line 54: // TODO why not just use instanceof? activemq-client/src/main/java/org/apache/activemq/ActiveMQMessageTransformation.java (1 line): - line 184: toMessage.setJMSDeliveryTime(getFromMessageDeliveryTime(fromMessage)); // TODO: AMQ-8500 DeliveryTime support ref: ActiveMQSession#send activemq-ra/src/main/java/org/apache/activemq/ra/ManagedConnectionProxy.java (1 line): - line 83: //TODO is this dangerous? should we copy the list before iterating? activemq-karaf/src/main/java/org/apache/activemq/karaf/commands/ActiveMQCommand.java (1 line): - line 181: //TODO implement completers activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/journal/Journal.java (1 line): - line 1196: // TODO: see if we can build a better hash activemq-broker/src/main/java/org/apache/activemq/network/jms/JmsConnector.java (1 line): - line 498: // TODO - How do we handle the re-wiring of replyToBridges in this case. activemq-http/src/main/java/org/apache/activemq/transport/https/HttpsTransportFactory.java (1 line): - line 82: // TODO Not sure if there is a better way of removing transport.verifyHostName here? activemq-client/src/main/java/org/apache/activemq/transport/discovery/simple/SimpleDiscoveryAgent.java (1 line): - line 104: // TODO: Should we not remove the services on the listener? activemq-client/src/main/java/org/apache/activemq/transport/udp/CommandDatagramSocket.java (1 line): - line 73: // TODO could use a DataInput implementation that talks direct activemq-web-demo/src/main/webapp/js/chat.js (1 line): - line 171: // TODO more encoding? activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQManagedConnectionFactory.java (1 line): - line 40: * @version $Revisio n$ TODO: Must override equals and hashCode (JCA spec 16.4) activemq-http/src/main/java/org/apache/activemq/transport/ws/jetty11/StompSocket.java (1 line): - line 51: // FIXME: convert to timeout async get(getDefaultSendTimeOut(), TimeUnit.SECONDS) activemq-broker/src/main/java/org/apache/activemq/util/osgi/Activator.java (1 line): - line 155: * TODO: consider a way to get the Broker release any references to activemq-client/src/main/java/org/apache/activemq/transport/nio/NIOSSLTransport.java (1 line): - line 421: // TODO deal with BUFFER_OVERFLOW activemq-broker/src/main/java/org/apache/activemq/broker/region/policy/TimedSubscriptionRecoveryPolicy.java (1 line): - line 47: // TODO: need to get a better synchronized linked list that has little activemq-client/src/main/java/org/apache/activemq/transport/reliable/ReliableTransport.java (1 line): - line 290: // TODO we could proactively remove ack'd stuff from the replay activemq-tooling/activemq-junit/src/main/java/org/apache/activemq/junit/EmbeddedActiveMQBroker.java (1 line): - line 425: // TODO: Figure out how to do this for Topics activemq-client/src/main/java/org/apache/activemq/transport/reliable/DefaultReplayStrategy.java (1 line): - line 54: // TODO we could pro-actively evict stuff from the buffer if we knew there was only one client activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQManagedConnection.java (1 line): - line 53: public class ActiveMQManagedConnection implements ManagedConnection, ExceptionListener { // TODO: activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpSender.java (1 line): - line 490: // TODO: message could not be generated what now? activemq-spring/src/main/java/org/apache/activemq/xbean/XBeanBrokerFactory.java (1 line): - line 95: // TODO warning resources from the context may not be closed down! activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/util/SequenceSet.java (1 line): - line 91: // TODO we can probably optimize this a bit activemq-web/src/main/java/org/apache/activemq/web/MessageListenerServlet.java (1 line): - line 206: // TODO return message IDs activemq-web-console/src/main/java/org/apache/activemq/web/controller/SendMessage.java (1 line): - line 174: // TODO create Bytes message from request body... activemq-osgi/src/main/java/org/apache/activemq/osgi/ActiveMQServiceFactory.java (1 line): - line 135: // TODO deal with multiple brokers activemq-client/src/main/java/org/apache/activemq/openwire/OpenWireFormat.java (1 line): - line 472: // TODO: extract the sequence from the dis and associate it. activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ManagedRegionBroker.java (1 line): - line 163: // TODO refactor to allow views for custom destinations activemq-broker/src/main/java/org/apache/activemq/transport/auto/AutoSslTransportServer.java (1 line): - line 58: // TODO Auto-generated constructor stub activemq-http/src/main/java/org/apache/activemq/transport/ws/jetty11/MQTTSocket.java (1 line): - line 59: // FIXME: convert to async .get(getDefaultSendTimeOut(), TimeUnit.SECONDS) activemq-client/src/main/java/org/apache/activemq/transport/discovery/zeroconf/ZeroconfDiscoveryAgent.java (1 line): - line 250: // TODO: is there a way to notify the JmDNS that the service failed? activemq-console/src/main/java/org/apache/activemq/console/command/store/StoreExporter.java (1 line): - line 183: // TODO: use a real JSON encoder like jackson.