[savara-commits] savara SVN: r112 - tools/eclipse/trunk/plugins/org.jboss.savara.tools.jbossesb/src/java/org/jboss/savara/tools/jbossesb/generator.
Author: objectiser
Date: 2009-12-06 07:09:04 -0500 (Sun, 06 Dec 2009)
New Revision: 112
Modified:
tools/eclipse/trunk/plugins/org.jboss.savara.tools.jbossesb/src/java/org/jboss/savara/tools/jbossesb/generator/DeploymentFileGenerator.java
tools/eclipse/trunk/plugins/org.jboss.savara.tools.jbossesb/src/java/org/jboss/savara/tools/jbossesb/generator/JBMMessagingSystem.java
Log:
SAVARA-2 - generate reply queue.
Modified:
tools/eclipse/trunk/plugins/org.jboss.savara.tools.jbossesb/src/java/org/jboss/savara/tools/jbossesb/generator/DeploymentFileGenerator.java
===================================================================
---
tools/eclipse/trunk/plugins/org.jboss.savara.tools.jbossesb/src/java/org/jboss/savara/tools/jbossesb/generator/DeploymentFileGenerator.java 2009-12-06
11:30:04 UTC (rev 111)
+++
tools/eclipse/trunk/plugins/org.jboss.savara.tools.jbossesb/src/java/org/jboss/savara/tools/jbossesb/generator/DeploymentFileGenerator.java 2009-12-06
12:09:04 UTC (rev 112)
@@ -70,6 +70,12 @@
buf.append("\t<depends>"+service.getCategory()+
".destination:service=Queue,name="+dest+
"</depends>\r\n");
+
+ if (service.isGateway()) {
+ buf.append("\t<depends>"+service.getCategory()+
+ ".destination:service=Queue,name="+dest+
+ "_reply</depends>\r\n");
+ }
} else {
logger.severe("Failed to find destination for JMS bus id '"+
service.getJMSBusIdRef()+"'");
Modified:
tools/eclipse/trunk/plugins/org.jboss.savara.tools.jbossesb/src/java/org/jboss/savara/tools/jbossesb/generator/JBMMessagingSystem.java
===================================================================
---
tools/eclipse/trunk/plugins/org.jboss.savara.tools.jbossesb/src/java/org/jboss/savara/tools/jbossesb/generator/JBMMessagingSystem.java 2009-12-06
11:30:04 UTC (rev 111)
+++
tools/eclipse/trunk/plugins/org.jboss.savara.tools.jbossesb/src/java/org/jboss/savara/tools/jbossesb/generator/JBMMessagingSystem.java 2009-12-06
12:09:04 UTC (rev 112)
@@ -70,6 +70,17 @@
buf.append("\t\t</depends>\r\n");
buf.append("\t\t<depends>jboss.messaging:service=PostOffice</depends>\r\n");
buf.append("\t</mbean>\r\n");
+
+ if (service.isGateway()) {
+ buf.append("\t<mbean
code=\"org.jboss.jms.server.destination.QueueService\"\r\n");
+ buf.append("\t\t\tname=\""+service.getCategory()+".destination:service=Queue,name="+dest+"_reply\"\r\n");
+ buf.append("\t\t\txmbean-dd=\"xmdesc/Queue-xmbean.xml\">\r\n");
+ buf.append("\t\t<depends
optional-attribute-name=\"ServerPeer\">\r\n");
+ buf.append("\t\t\tjboss.messaging:service=ServerPeer\r\n");
+ buf.append("\t\t</depends>\r\n");
+ buf.append("\t\t<depends>jboss.messaging:service=PostOffice</depends>\r\n");
+ buf.append("\t</mbean>\r\n");
+ }
} else {
logger.severe("Failed to find destination for JMS bus id '"+
service.getJMSBusIdRef()+"'");