artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQSession.java (5 lines): - line 283: // TODO Auto-generated method stub - line 289: // TODO Auto-generated method stub - line 310: // TODO Auto-generated method stub - line 319: // TODO Auto-generated method stub - line 325: // TODO Auto-generated method stub artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/OpenWireProtocolManager.java (4 lines): - line 457: // TODO: Use the Storage ID here... - line 557: // TODO Auto-generated method stub - line 562: // TODO Auto-generated method stub - line 567: // TODO Auto-generated method stub artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientSessionImpl.java (3 lines): - line 1412: // TODO remove this and encapsulate it - line 1615: // TODO: this will be encapsulated by the SessionContext - line 2034: // TODO: this could semantically change on other servers. I know for instance on stomp this is just an ignore artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/impl/ClusterConnectionImpl.java (3 lines): - line 591: // TODO: shouldn't we send the current time here? and change the current topology? - line 759: // FIXME required to prevent cluster connections w/o discovery group - line 1111: // TODO - optimised this by just passing int in header - but filter needs to be extended to support IN with artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/LargeMessageControllerImpl.java (3 lines): - line 142: * TODO: move this to ConsumerContext as large message is a protocol specific thing - line 658: // TODO: optimize this by using System.arraycopy - line 665: // TODO: optimize this by using System.arraycopy artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServerSessionImpl.java (2 lines): - line 1781: * TODO: figure out how to get rid of this - line 2194: // TODO: move this check somewhere else? this is a JMS-specific bit of logic in the core impl artemis-server/src/main/java/org/apache/activemq/artemis/core/server/NodeManager.java (2 lines): - line 87: // TODO make it abstract - line 92: // TODO make it abstract artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/AbstractJournalStorageManager.java (2 lines): - line 1791: * TODO: Is this still being used ? - line 1990: // TODO: do I need to remove the record on commit? artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/CompressedLargeMessageControllerImpl.java (2 lines): - line 276: // TODO: reset positioning if possible - line 311: // TODO: optimize this by using System.arraycopy artemis-server/src/main/java/org/apache/activemq/artemis/core/deployers/impl/FileConfigurationParser.java (2 lines): - line 2065: // TODO: validate if either jgroups or UDP is being filled - line 2099: // TODO: validate if either jgroups or UDP is being filled artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/AnyLiveNodeLocatorForReplication.java (1 line): - line 105: * TODO: there will be a better way to do this by finding which nodes backup has gone down. artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/handler/ExecutorNettyAdapter.java (1 line): - line 43: * TODO: This could be refactored out of the main codebase but at a high cost. artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/jdbc/JdbcNodeManager.java (1 line): - line 370: // TODO need some tolerance//renew here? artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/codec/FinishPageMessageOperation.java (1 line): - line 31: // TODO: merge this class with the one on the PagingStoreImpl artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ScaleDownHandler.java (1 line): - line 290: // TODO: what if oldRouteToIDs == null ?? artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/ProtonAbstractReceiver.java (1 line): - line 301: // TODO: how to implement flow here? artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/RemotingConnectionImpl.java (1 line): - line 394: // TODO we really need a lock here? artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/v10/StompFrameHandlerV10.java (1 line): - line 169: // TODO Auto-generated method stub artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/DefaultConnectionProperties.java (1 line): - line 84: // TODO: improve this once we implement failover:// as ActiveMQ5 does artemis-commons/src/main/java/org/apache/activemq/artemis/utils/collections/PriorityLinkedListImpl.java (1 line): - line 149: // TODO - A better prioritization algorithm artemis-core-client/src/main/java/org/apache/activemq/artemis/utils/ConfirmationWindowWarning.java (1 line): - line 22: * TODO: get rid of this artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ReplicationBackupActivation.java (1 line): - line 564: // TODO replication endpoint close? artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java (1 line): - line 3776: // TODO load users/roles artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/StompConnection.java (1 line): - line 164: // TODO this should take a type - send or receive so it knows whether to check the address or the queue artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/impl/ClusterConnectionBridge.java (1 line): - line 197: // TODO - we can optimise this artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/ActiveMQPacketHandler.java (1 line): - line 199: // TODO - where is this removed? artemis-quorum-ri/src/main/java/org/apache/activemq/artemis/quorum/zookeeper/CuratorDistributedLock.java (1 line): - line 168: // TODO silent, but debug ;) artemis-quorum-ri/src/main/java/org/apache/activemq/artemis/quorum/zookeeper/CuratorDistributedPrimitiveManager.java (1 line): - line 273: // TODO log? artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQConnectionContext.java (1 line): - line 246: // TODO: check what this means, artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/journal/JDBCJournalImpl.java (1 line): - line 302: // TODO (mtaylor) perhaps we could store a reverse mapping of IDs to prevent this O(n) loop artemis-server/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/HttpAcceptorHandler.java (1 line): - line 169: // TODO: This can be optimized a lot artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/UDPBroadcastEndpointFactory.java (1 line): - line 154: // TODO: Do we need this? artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/client/ProtonClientSenderContext.java (1 line): - line 26: * TODO: Merge {@link ProtonServerSenderContext} and {@link ProtonClientSenderContext} once we support 'global' link names. The split is a workaround for outgoing links artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/OpenwireMessage.java (1 line): - line 32: // TODO: Implement this artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientSessionFactoryImpl.java (1 line): - line 579: * TODO: Maybe this belongs to ActiveMQClientProtocolManager artemis-commons/src/main/java/org/apache/activemq/artemis/utils/UTF8Util.java (1 line): - line 351: // TODO look at replacing this with io.netty.buffer.ByteBufUtil.utf8Bytes(java.lang.CharSequence) artemis-server/src/main/java/org/apache/activemq/artemis/core/postoffice/impl/PostOfficeImpl.java (1 line): - line 918: // TODO - needs to be synchronized to prevent happening concurrently with activate() artemis-server/src/main/java/org/apache/activemq/artemis/core/server/transformer/ServerMessageImpl.java (1 line): - line 155: // TODO ASk clebert artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/AMQPBrokerConnection.java (1 line): - line 355: // TODO implement this as part of https://issues.apache.org/jira/browse/ARTEMIS-2965 artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/AMQPSessionContext.java (1 line): - line 182: // TODO: Remove this check when we have support for global link names artemis-quorum-ri/src/main/java/org/apache/activemq/artemis/quorum/file/FileBasedPrimitiveManager.java (1 line): - line 103: // TODO no op for now: log would be better!