This commit is contained in:
Justin Bertram 2017-03-28 09:18:36 -05:00
commit 3efeccfa04
3 changed files with 24 additions and 0 deletions

View File

@ -56,6 +56,12 @@ public interface QueueControl {
@Attribute(desc = "whether this queue is durable")
boolean isDurable();
/**
* The routing type of this queue.
*/
@Attribute(desc = "The routing type of this queue")
byte getRoutingType() throws Exception;
/**
* Returns the filter associated with this queue.
*/

View File

@ -175,6 +175,19 @@ public class QueueControlImpl extends AbstractControl implements QueueControl {
}
}
@Override
public byte getRoutingType() throws Exception {
checkStarted();
clearIO();
try {
return queue.getRoutingType().getType();
} finally {
blockOnIO();
}
}
@Override
public boolean isTemporary() {
checkStarted();

View File

@ -171,6 +171,11 @@ public class QueueControlUsingCoreTest extends QueueControlTest {
return (Boolean) proxy.retrieveAttributeValue("durable");
}
@Override
public byte getRoutingType() throws Exception {
return (byte) proxy.retrieveAttributeValue("routingType");
}
@Override
public boolean isTemporary() {
return (Boolean) proxy.retrieveAttributeValue("temporary");