[jboss-cvs] JBossAS SVN: r100661 - in branches/Branch_Hornet_Temporary_2/hornetq-int: src/main/java/org/jboss/as/integration/hornetq/deployers and 1 other directory.

[jboss-cvs-commits at lists.jboss.org]

Author: clebert.suconic at jboss.com
Date: 2010-02-06 23:05:29 -0500 (Sat, 06 Feb 2010)
New Revision: 100661

Modified:
   branches/Branch_Hornet_Temporary_2/hornetq-int/.classpath
   branches/Branch_Hornet_Temporary_2/hornetq-int/src/main/java/org/jboss/as/integration/hornetq/deployers/DestinationFactoryDeployerPlugin.java
Log:
Deployers

Modified: branches/Branch_Hornet_Temporary_2/hornetq-int/.classpath
===================================================================
--- branches/Branch_Hornet_Temporary_2/hornetq-int/.classpath	2010-02-07 03:31:24 UTC (rev 100660)
+++ branches/Branch_Hornet_Temporary_2/hornetq-int/.classpath	2010-02-07 04:05:29 UTC (rev 100661)
@@ -1,7 +1,7 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <classpath>
-	<classpathentry kind="src" output="target/classes" path="src/main/java"/>
 	<classpathentry excluding="**" kind="src" output="target/classes" path="src/resources"/>
+	<classpathentry kind="src" path="src/main"/>
 	<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/J2SE-1.5"/>
 	<classpathentry kind="con" path="org.maven.ide.eclipse.MAVEN2_CLASSPATH_CONTAINER"/>
 	<classpathentry kind="output" path="target/classes"/>

Modified: branches/Branch_Hornet_Temporary_2/hornetq-int/src/main/java/org/jboss/as/integration/hornetq/deployers/DestinationFactoryDeployerPlugin.java
===================================================================
--- branches/Branch_Hornet_Temporary_2/hornetq-int/src/main/java/org/jboss/as/integration/hornetq/deployers/DestinationFactoryDeployerPlugin.java	2010-02-07 03:31:24 UTC (rev 100660)
+++ branches/Branch_Hornet_Temporary_2/hornetq-int/src/main/java/org/jboss/as/integration/hornetq/deployers/DestinationFactoryDeployerPlugin.java	2010-02-07 04:05:29 UTC (rev 100661)
@@ -3,7 +3,12 @@
 import javax.jms.Queue;
 import javax.jms.Topic;
 
+import org.hornetq.core.server.cluster.QueueConfiguration;
 import org.hornetq.jms.server.JMSServerManager;
+import org.hornetq.jms.server.config.JMSConfiguration;
+import org.hornetq.jms.server.config.impl.JMSConfigurationImpl;
+import org.hornetq.jms.server.config.impl.QueueConfigurationImpl;
+import org.hornetq.jms.server.config.impl.TopicConfigurationImpl;
 import org.jboss.deployers.spi.DeploymentException;
 import org.jboss.deployers.structure.spi.DeploymentUnit;
 import org.jboss.ejb.deployers.CreateDestinationFactory;
@@ -20,13 +25,14 @@
  * @author <a href="clebert.suconic at jboss.com">Clebert Suconic</a>
  * @version $Revision: 82920 $
  */
-public class DestinationFactoryDeployerPlugin implements CreateDestinationFactory {
+public class DestinationFactoryDeployerPlugin implements
+		CreateDestinationFactory {
 
 	private static final Logger log = Logger
 			.getLogger(DestinationFactoryDeployerPlugin.class);
-	
+
 	private JMSServerManager jmsManager;
-	
+
 	public JMSServerManager getJmsManager() {
 		return jmsManager;
 	}
@@ -35,8 +41,8 @@
 		this.jmsManager = jmsManager;
 	}
 
-	public boolean create(DeploymentUnit unit, JBossMessageDrivenBeanMetaData mdb)
-			throws DeploymentException {
+	public boolean create(DeploymentUnit unit,
+			JBossMessageDrivenBeanMetaData mdb) throws DeploymentException {
 		String destinationName = null;
 		String destinationType = null;
 
@@ -59,13 +65,17 @@
 			return false;
 		}
 		boolean isTopic = false;
+		JMSConfiguration config = new JMSConfigurationImpl();
 		if (destinationType == null) {
 			log.warn("Unable to determine destination type for "
 					+ mdb.getName());
 			return false;
 		} else if (destinationType.equals(Queue.class.getName())) {
-			// Its a queue
+			config.getQueueConfigurations().add(
+					new QueueConfigurationImpl(destinationName, null, true,
+							"queue/" + destinationName));
 		} else if (destinationType.equals(Topic.class.getName())) {
+			config.getTopicConfigurations().add(new TopicConfigurationImpl(destinationName, "topic/" + destinationName));
 			isTopic = true;
 		} else {
 			log.warn("Unknown destination type '" + destinationType + "' for "
@@ -73,12 +83,9 @@
 			return false;
 		}
 
-		if (isTopic) {
-			System.out.println("Create topic " + destinationName);
-		} else {
-			System.out.println("Create queue " + destinationName);
-		}
 
+		unit.addAttachment(JMSConfiguration.class, config);
+		
 		return true;
 	}
 
@@ -99,4 +106,8 @@
 		return property.getValue();
 	}
 
+	public Class<?> getOutput() {
+		return JMSConfiguration.class;
+	}
+
 }