broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerSessionDelegate.java (9 lines): - line 193: TODO - work around broken Python tests - line 533: // TODO: we currently do not send MessageAccept when AcceptMode is EXPLICIT - line 610: // TODO - check current tx mode - line 617: // TODO - check current tx mode - line 624: // TODO - check current tx mode - line 631: // TODO - check current tx mode - line 1235: //TODO - here because of non-compliant python tests - line 1544: //TODO: do we need to check that the queue already exists with exactly the same "configuration"? - line 1705: // TODO - Error code perftests/src/main/java/org/apache/qpid/disttest/db/ResultsDbWriter.java (7 lines): - line 399: statement.setLong(columnIndex++, 0 /* TODO PRODUCER_INTERVAL*/); - line 400: statement.setLong(columnIndex++, 0 /* TODO IS_TOPIC*/); - line 401: statement.setLong(columnIndex++, 0 /* TODO IS_DURABLE_SUBSCRIPTION*/); - line 402: statement.setLong(columnIndex++, 0 /* TODO IS_BROWSING_SUBSCRIPTION*/); - line 403: statement.setLong(columnIndex++, 0 /* TODO IS_SELECTOR*/); - line 404: statement.setLong(columnIndex++, 0 /* TODO IS_NO_LOCAL*/); - line 405: statement.setLong(columnIndex++, 0 /* TODO IS_SYNCHRONOUS_CONSUMER*/); broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/SendingLinkEndpoint.java (6 lines): - line 99: // TODO: QPID-7845 : remove after implementation of link resuming - line 128: // TODO QPID-7952: this method might modify the source. this is not good encapsulation. furthermore if it does so then it should inform the link/linkregistry about it! - line 576: // TODO: QPID-7845 : Resuming links is unsupported at the moment. Destroying link unconditionally. - line 705: // TODO: QPID-7845 : Resuming links is unsupported at the moment. Thus, cleaning up unsettled deliveries unconditionally. - line 774: // TODO: QPID-7845: Handle rejected and modified outcome - line 783: // TODO:QPID-7845: exists in receivers map, but not yet got an outcome ... should resend with resume = true broker-core/src/main/java/org/apache/qpid/server/model/AbstractConfiguredObject.java (5 lines): - line 694: // TODO consider removing each child from the parent as each child close completes, rather - line 961: //TODO: children of ERRORED CO will continue to remain in ACTIVE state - line 1345: // TODO - really we should define with meta data which attributes any given derived attr is dependent upon - line 1812: //TODO: don't put nulls - line 3720: // TODO - RG - This isn't right :-( broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/Session_1_0.java (5 lines): - line 464: // TODO - we should use a better metric here, and/or manage session credit across the whole connection - line 862: // TODO temporary topics? - line 932: // TODO convert AMQP 1-0 node properties to queue attributes - line 1227: // TODO: QPID-7951 is the closed guard important? - line 1312: //TODO: QPID-7954 broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/AMQChannel.java (5 lines): - line 1105: boolean requiresSuspend = _suspended.compareAndSet(false,true); // TODO This is probably superfluous owing to the - line 2347: // TODO - should we do anything here? - line 2959: //TODO: do we need to check that the queue already exists with exactly the same "configuration"? - line 3187: // TODO - Error code - line 3409: // TODO: This is not spec compliant but we currently seem to rely on this behaviour broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/ConsumerTarget_1_0.java (4 lines): - line 533: // TODO: apply source's default outcome - line 556: // TODO: apply source's default outcome if settled - line 589: // TODO: apply source's default outcome - line 612: // TODO: apply source's default outcome broker-plugins/management-amqp/src/main/java/org/apache/qpid/server/management/amqp/ManagementNode.java (3 lines): - line 357: // TODO - handle runtime exceptions - line 1306: // TODO - get the objects - line 1478: // TODO - enumerate management operations broker-core/src/main/java/org/apache/qpid/server/transport/SelectorThread.java (3 lines): - line 330: // TODO Inform the model object - line 414: // TODO Communicate condition back to model object to make it go into the ERROR state - line 632: // TODO Port should really not proceed with closing the selector until all of the broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/servlet/rest/ApiDocsServlet.java (3 lines): - line 541: // TODO - valid values and patterns might contain characters which should be escaped - line 565: // TODO - generate a description of the type in the array - line 570: // TODO - generate a description of the type in the object broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/StandardReceivingLinkEndpoint.java (3 lines): - line 172: // TODO: QPID-7845: create message ? - line 275: // TODO - disposition not updated for the non-transaction case - line 424: // TODO: QPID-7845: Resuming links is unsupported at the moment. Destroying link unconditionally. broker-core/src/main/java/org/apache/qpid/server/message/MessageSource.java (3 lines): - line 51: * TODO Move to top level, used outside this class. - line 64: * TODO Move to top level, used outside this class. - line 78: * TODO Move to top level, used outside this class. broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/AbstractLinkEndpoint.java (2 lines): - line 130: // TODO: QPID-7845 : Functionality for resuming links is not fully implemented - line 458: //TODO: QPID-7954: improve detach broker-core/src/main/java/org/apache/qpid/server/filter/BinaryExpression.java (2 lines): - line 57: * TODO: more efficient hashCode() - line 68: * TODO: more efficient hashCode() broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/AMQMethodListener.java (2 lines): - line 34: * TODO Document why the exception is passed to the error method. Is it so that the exception can be passed - line 53: * TODO Consider narrowing the exception. bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/AbstractBDBMessageStore.java (2 lines): - line 89: //TODO: Add upgrader to remove BRIDGES and LINKS - line 164: // TODO this relies on the fact that the VH will call upgrade just before putting the VH into service. broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ProtocolInitiation.java (2 lines): - line 34: // TODO: generate these constants automatically from the xml protocol spec file - line 209: // TODO: add list of available versions in list to msg... broker-core/src/main/java/org/apache/qpid/server/filter/ConstantExpression.java (2 lines): - line 172: * TODO: more efficient hashCode() - line 183: * TODO: more efficient hashCode() broker-core/src/main/java/org/apache/qpid/server/model/adapter/FileBasedGroupProviderImpl.java (2 lines): - line 135: // TODO - we know this is safe, but the sync method shouldn't really be called from the management thread - line 385: // TODO - need to relate to the User object broker-core/src/main/java/org/apache/qpid/server/queue/AbstractQueue.java (2 lines): - line 2094: // TODO log requeues with a post enqueue action - line 2099: // TODO log discard broker-core/src/main/java/org/apache/qpid/server/filter/UnaryExpression.java (2 lines): - line 158: * TODO: more efficient hashCode() - line 169: * TODO: more efficient hashCode() broker-core/src/main/java/org/apache/qpid/server/security/auth/manager/PrincipalDatabaseAuthenticationManager.java (1 line): - line 361: // TODO - this does not belong here! broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/EncodingUtils.java (1 line): - line 336: // TODO: check length fits in an unsigned byte broker-plugins/websocket/src/main/java/org/apache/qpid/server/transport/websocket/WebSocketProvider.java (1 line): - line 636: // TODO: For efficiency perhaps only coalesce sequential small buffers and let large buffers broker-core/src/main/java/org/apache/qpid/server/security/auth/sasl/plain/PlainNegotiator.java (1 line): - line 90: // TODO: should not get pwd as a String but as a char array... broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/AMQVersionAwareProtocolSession.java (1 line): - line 32: * TODO Why is this a separate interface to {@link ProtocolVersionAware}, could they be combined into a single broker-plugins/management-http/src/main/java/resources/js/qpid/management/dashboard/widget/query.js (1 line): - line 240: // TODO: remove hardcoded sizes broker-core/src/main/java/org/apache/qpid/server/consumer/AbstractConsumerTarget.java (1 line): - line 151: // TODO - if not closed broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/HttpManagement.java (1 line): - line 546: // TODO - RG - probably does nothing broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/preferences/QueryPreferenceValue.java (1 line): - line 48: // TODO: how should we treat unrecognised attributes? ignore/pass-through, discard, error? broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/AMQDecoder.java (1 line): - line 45: * TODO If protocol initiation decoder not needed, then don't create it. Probably not a big deal, but it adds to the broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/AMQProtocolClassException.java (1 line): - line 26: * TODO Not an AMQP exception as no status code. tools/src/main/java/org/apache/qpid/tools/RestStressTestClient.java (1 line): - line 474: //TODO: we need to track sessions for basic auth in order to logout those broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/controller/latest/LatestManagementController.java (1 line): - line 511: //TODO: define format how to report the results for bulk delete, i.e. how to report individual errors and success statuses broker-plugins/amqp-1-0-bdb-store/src/main/java/org/apache/qpid/server/protocol/v1_0/store/bdb/BDBLinkStore.java (1 line): - line 226: OperationStatus status = database.put(txn, key, value); // TODO: create transaction broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/AMQPInvalidClassException.java (1 line): - line 25: *

TODO Could just re-use an existing exception like IllegalArgumentException or ClassCastException. bdbstore/src/main/java/org/apache/qpid/server/virtualhostnode/berkeleydb/BDBHAVirtualHostNodeImpl.java (1 line): - line 1254: // TODO: Used when the node is a replica and it runs out of disk. Currently we cause the whole Broker broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/AMQProtocolVersionException.java (1 line): - line 25: * TODO Not an AMQP exception as no status code. broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/codec/CharTypeConstructor.java (1 line): - line 46: int codePoint = in.getInt(); // TODO look wrong AMQP 1.0 type is actually UTF-32BE not a code point broker-core/src/main/java/org/apache/qpid/server/virtualhost/AbstractVirtualHost.java (1 line): - line 2686: // TODO if message recovery fails we ought to be transitioning the VH into ERROR and releasing the thread-pools etc. broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/AMQType.java (1 line): - line 508: // FIXME: use proper charset encoder broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/NodeReceivingDestination.java (1 line): - line 195: // TODO - fix bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/upgrade/UpgradeFrom4To5.java (1 line): - line 330: // TODO QPID-3490 we should not persist a default exchange binding broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/AMQProtocolInstanceException.java (1 line): - line 26: * TODO Not an AMQP exception as no status code. broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/ExchangeSendingDestination.java (1 line): - line 355: // TODO: QPID-7642 - due to inconsistent handling of invalid filters broker-plugins/logging-logback/src/main/java/org/apache/qpid/server/logging/logback/AbstractLogger.java (1 line): - line 91: // TODO generalise for virtualhost too broker-plugins/access-control/src/main/java/org/apache/qpid/server/security/access/config/AclFileParser.java (1 line): - line 152: tokenizer.whitespaceChars('\u0000', '\u0020'); // whitespace (to be ignored) TODO properly bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/replication/ReplicatedEnvironmentFacade.java (1 line): - line 2432: // TODO: calling handleUncaughtExceptionInExecutorService() looks more attractive then delegating broker close to VHN broker-plugins/management-http/src/main/java/resources/js/qpid/management/port/amqp/show.js (1 line): - line 51: indirectSelection: true, // KW TODO checkme perftests/src/main/java/org/apache/qpid/disttest/controller/Controller.java (1 line): - line 128: // TODO clientRegistry should expose a deregisterClient bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/upgrade/UpgradeFrom5To6.java (1 line): - line 407: // TODO: check and remove orphaned bindings broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/MessageMetaData_1_0.java (1 line): - line 69: // TODO move to somewhere more useful perftests/src/main/java/org/apache/qpid/disttest/json/ObjectMapperFactory.java (1 line): - line 172: // TODO Do we use this? broker-core/src/main/java/org/apache/qpid/server/txn/DtxRegistry.java (1 line): - line 52: // TODO if the virtualhost is shutdown, the housekeeper may be null broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/servlet/query/ConfiguredObjectExpressionFactory.java (1 line): - line 235: // TODO If obj itself is another configured object perhaps we should just use its name or id? The CO.toString value probably isn't too useful. broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/AnonymousRelayDestination.java (1 line): - line 107: // TODO - fix broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/type/codec/AMQPDescribedTypeRegistry.java (1 line): - line 364: // TODO primitive array types broker-core/src/main/java/org/apache/qpid/server/model/ConfiguredObject.java (1 line): - line 268: // TODO - remove this when objects become responsible for their own storage perftests/src/main/java/org/apache/qpid/disttest/results/aggregation/ITestResult.java (1 line): - line 27: // TODO should weaken to Collection broker-core/src/main/java/org/apache/qpid/server/exchange/ExchangeDefaults.java (1 line): - line 28: * TODO A type safe enum, might be more appropriate for the exchange types. perftests/src/main/java/org/apache/qpid/disttest/results/formatting/CSVOrderParticipantResultComparator.java (1 line): - line 33: // TODO yuk broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/AMQPConnection_0_8Impl.java (1 line): - line 600: // TODO MultiVersionProtocolEngine takes responsibility for making the ProtocolVersion determination. perftests/src/main/java/org/apache/qpid/disttest/results/aggregation/AggregatedTestResult.java (1 line): - line 70: // TODO should weaken to Collection broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/AMQPConnection_1_0Impl.java (1 line): - line 1716: // TODO - should we try to set the hostname based on the connection information? doc/java-broker/src/docbkx/management/channels/Java-Broker-Management-Channel-HTTP.xml (1 line): - line 53: