diff options
Diffstat (limited to 'java/broker/src/main/java/org/apache/qpid/tools')
4 files changed, 7 insertions, 7 deletions
diff --git a/java/broker/src/main/java/org/apache/qpid/tools/messagestore/MessageStoreTool.java b/java/broker/src/main/java/org/apache/qpid/tools/messagestore/MessageStoreTool.java index faa7b85d58..f26611f0bc 100644 --- a/java/broker/src/main/java/org/apache/qpid/tools/messagestore/MessageStoreTool.java +++ b/java/broker/src/main/java/org/apache/qpid/tools/messagestore/MessageStoreTool.java @@ -219,7 +219,7 @@ public class MessageStoreTool _console.println(""); - _console.println(BOILER_PLATE); + _console.println(BOILER_PLATE); runCLI(); } @@ -495,13 +495,13 @@ public class MessageStoreTool if (_exchange != null) { status.append("["); - status.append(_exchange.getName()); + status.append(_exchange.getNameShortString()); status.append("]"); if (_queue != null) { status.append("->'"); - status.append(_queue.getName()); + status.append(_queue.getNameShortString()); status.append("'"); if (_msgids != null) diff --git a/java/broker/src/main/java/org/apache/qpid/tools/messagestore/commands/Copy.java b/java/broker/src/main/java/org/apache/qpid/tools/messagestore/commands/Copy.java index ef3599bdc8..348c95572d 100644 --- a/java/broker/src/main/java/org/apache/qpid/tools/messagestore/commands/Copy.java +++ b/java/broker/src/main/java/org/apache/qpid/tools/messagestore/commands/Copy.java @@ -52,7 +52,7 @@ public class Copy extends Move protected void doCommand(AMQQueue fromQueue, long start, long end, AMQQueue toQueue) { ServerTransaction txn = new LocalTransaction(fromQueue.getVirtualHost().getTransactionLog()); - fromQueue.copyMessagesToAnotherQueue(start, end, toQueue.getName().toString(), txn); + fromQueue.copyMessagesToAnotherQueue(start, end, toQueue.getNameShortString().toString(), txn); txn.commit(); } diff --git a/java/broker/src/main/java/org/apache/qpid/tools/messagestore/commands/List.java b/java/broker/src/main/java/org/apache/qpid/tools/messagestore/commands/List.java index ab8e781df5..3c4a0c8fac 100644 --- a/java/broker/src/main/java/org/apache/qpid/tools/messagestore/commands/List.java +++ b/java/broker/src/main/java/org/apache/qpid/tools/messagestore/commands/List.java @@ -292,12 +292,12 @@ public class List extends AbstractCommand { if (exchange.isBound(queue)) { - data.add(queue.getName().toString()); + data.add(queue.getNameShortString().toString()); } } else { - data.add(queue.getName().toString()); + data.add(queue.getNameShortString().toString()); } } diff --git a/java/broker/src/main/java/org/apache/qpid/tools/messagestore/commands/Move.java b/java/broker/src/main/java/org/apache/qpid/tools/messagestore/commands/Move.java index 6a5e2a6025..615f6ec1c2 100644 --- a/java/broker/src/main/java/org/apache/qpid/tools/messagestore/commands/Move.java +++ b/java/broker/src/main/java/org/apache/qpid/tools/messagestore/commands/Move.java @@ -196,7 +196,7 @@ public class Move extends AbstractCommand protected void doCommand(AMQQueue fromQueue, long start, long id, AMQQueue toQueue) { ServerTransaction txn = new LocalTransaction(fromQueue.getVirtualHost().getTransactionLog()); - fromQueue.moveMessagesToAnotherQueue(start, id, toQueue.getName().toString(), txn); + fromQueue.moveMessagesToAnotherQueue(start, id, toQueue.getNameShortString().toString(), txn); txn.commit(); } } |