Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

ARTEMIS-1840 Added Error and Doc to Import Message

This commit is contained in:
Martyn Taylor 2018-05-03 11:13:56 +01:00
parent 3c8c434f17
commit a6c48a37c7
1 changed files with 11 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/messages/DestAbstract.java
View File

@ -23,6 +23,7 @@ import java.nio.ByteBuffer;
import io.airlift.airline.Option; import io.airlift.airline.Option;
import org.apache.activemq.artemis.api.core.ActiveMQException; import org.apache.activemq.artemis.api.core.ActiveMQException;
import org.apache.activemq.artemis.api.core.ActiveMQExceptionType;
import org.apache.activemq.artemis.api.core.client.ActiveMQClient; import org.apache.activemq.artemis.api.core.client.ActiveMQClient;
import org.apache.activemq.artemis.api.core.client.ClientMessage; import org.apache.activemq.artemis.api.core.client.ClientMessage;
import org.apache.activemq.artemis.api.core.client.ClientRequestor; import org.apache.activemq.artemis.api.core.client.ClientRequestor;
@ -43,7 +44,7 @@ public class DestAbstract extends ConnectionAbstract {
private static final String FQQN_SEPERATOR = "::"; private static final String FQQN_SEPERATOR = "::";
@Option(name = "--destination", description = "Destination to be used. It can be prefixed with queue:// or topic:// (Default: queue://TEST)") @Option(name = "--destination", description = "Destination to be used. It can be prefixed with queue:// or topic:// or fqqn:// (Default: queue://TEST)")
String destination = "queue://TEST"; String destination = "queue://TEST";
@Option(name = "--message-count", description = "Number of messages to act on (Default: 1000)") @Option(name = "--message-count", description = "Number of messages to act on (Default: 1000)")
@ -111,11 +112,15 @@ public class DestAbstract extends ConnectionAbstract {
} }
public byte[] getQueueIdFromName(String queueName) throws Exception { public byte[] getQueueIdFromName(String queueName) throws Exception {
try {
ClientMessage message = getQueueAttribute(queueName, "ID"); ClientMessage message = getQueueAttribute(queueName, "ID");
Number idObject = (Number) ManagementHelper.getResult(message); Number idObject = (Number) ManagementHelper.getResult(message);
ByteBuffer byteBuffer = ByteBuffer.allocate(8); ByteBuffer byteBuffer = ByteBuffer.allocate(8);
byteBuffer.putLong(idObject.longValue()); byteBuffer.putLong(idObject.longValue());
return byteBuffer.array(); return byteBuffer.array();
} catch (Exception e) {
throw new ActiveMQException("Error occured when looking up FQQN. Please ensure the FQQN exists.", e, ActiveMQExceptionType.ILLEGAL_STATE);
}
} }
protected ClientMessage getQueueAttribute(String queueName, String attribute) throws Exception { protected ClientMessage getQueueAttribute(String queueName, String attribute) throws Exception {