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

[do-not-reply at jboss.org]

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