Tidy up some TODOs

This commit is contained in:
Dave Syer
2011-03-31 14:29:50 +01:00
parent f2ab3a7a06
commit 05f72da069
5 changed files with 1 additions and 5 deletions

View File

@@ -146,7 +146,7 @@ public class MessageProperties {
this.type = type;
}
//TODO what is this? is it stuctureType - int in qpid
//NOTE stuctureType is int in qpid
public String getType() {
return this.type;
}

View File

@@ -24,7 +24,6 @@ public class SimpleConnection implements Connection {
this.delegate = delegate;
}
// TODO: expose the transactional flag
public Channel createChannel(boolean transactional) {
try {
Channel channel = delegate.createChannel();

View File

@@ -263,7 +263,6 @@ public class RabbitTemplate extends RabbitAccessor implements RabbitOperations {
Assert.isNull(message.getMessageProperties().getReplyTo(),
"Send-and-receive methods can only be used if the Message does not already have a replyTo property.");
// TODO: first check for a replyToAddress property on this template
DeclareOk queueDeclaration = channel.queueDeclare();
Address replyToAddress = new Address(ExchangeTypes.DIRECT, DEFAULT_EXCHANGE, queueDeclaration
.getQueue());

View File

@@ -107,7 +107,6 @@ public abstract class AbstractMessageListenerContainer extends RabbitAccessor im
}
public void setQueues(Queue... queues) {
// TODO: Merge with string queue name values?
String[] queueNames = new String[queues.length];
for (int i = 0; i < queues.length; i++) {
Assert.notNull(queues[i], "Queue must not be null.");

View File

@@ -243,7 +243,6 @@ public class MessageListenerRecoveryCachingConnectionIntegrationTests {
boolean waited = latch.await(timeout, TimeUnit.SECONDS);
assertTrue("Timed out waiting for message", waited);
// TODO: is there a race condition here where the template gets a closed connection and this receive fails?
assertNull(template.receiveAndConvert(queue.getName()));
}