[hornetq-commits] JBoss hornetq SVN: r10754 - branches/Branch_2_2_EAP_export_tool/src/main/org/hornetq/core/persistence/tools.

Author: jicken Date: 2011-05-31 15:37:23 -0400 (Tue, 31 May 2011) New Revision: 10754 Modified: branches/Branch_2_2_EAP_export_tool/src/main/org/hornetq/core/persistence/tools/ManageDataTool.java Log: fixed no reply from management queue by starting the session :) Modified: branches/Branch_2_2_EAP_export_tool/src/main/org/hornetq/core/persistence/tools/ManageDataTool.java =================================================================== --- branches/Branch_2_2_EAP_export_tool/src/main/org/hornetq/core/persistence/tools/ManageDataTool.java 2011-05-31 18:19:22 UTC (rev 10753) +++ branches/Branch_2_2_EAP_export_tool/src/main/org/hornetq/core/persistence/tools/ManageDataTool.java 2011-05-31 19:37:23 UTC (rev 10754) @@ -29,7 +29,6 @@ import java.util.Map; import java.util.Set; -import javax.jms.TextMessage; import javax.xml.bind.JAXBContext; import javax.xml.bind.JAXBException; import javax.xml.bind.Marshaller; @@ -535,13 +534,23 @@ } private long getNewQueueId(QueueType queue) throws Exception { - final ClientSession requestorSession = finalSf.createSession(true, true); + final ClientSession requestorSession = finalSf.createSession(false, true, true); + requestorSession.start(); ClientRequestor requestor = new ClientRequestor(requestorSession, ConfigurationImpl.DEFAULT_MANAGEMENT_ADDRESS); ClientMessage m = requestorSession.createMessage(false); ManagementHelper.putAttribute(m, ResourceNames.CORE_QUEUE + queue.getName(), "ID"); - final TextMessage reply = (TextMessage) requestor.request(m, 5000); - return Long.parseLong(reply.getText()); + try + { + final ClientMessage reply = requestor.request(m); + Object result = ManagementHelper.getResult(reply); + + return ((Integer) result).longValue(); + } + catch (Exception e) + { + throw new IllegalStateException(e); + } } private ClientMessage generateClientMessage(MessageType message) throws IOException