[jboss-cvs] JBossAS SVN: r100446 - branches/Branch_Hornet_Temporary_2/hornetq-int/src/main/java/org/jboss/as/integration/hornetq/deployer.

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

Author: clebert.suconic at jboss.com
Date: 2010-02-04 19:18:09 -0500 (Thu, 04 Feb 2010)
New Revision: 100446

Added:
   branches/Branch_Hornet_Temporary_2/hornetq-int/src/main/java/org/jboss/as/integration/hornetq/deployer/JMSConfigurationIntegration.java
Modified:
   branches/Branch_Hornet_Temporary_2/hornetq-int/src/main/java/org/jboss/as/integration/hornetq/deployer/JMSDeployer.java
Log:
deployer

Added: branches/Branch_Hornet_Temporary_2/hornetq-int/src/main/java/org/jboss/as/integration/hornetq/deployer/JMSConfigurationIntegration.java
===================================================================
--- branches/Branch_Hornet_Temporary_2/hornetq-int/src/main/java/org/jboss/as/integration/hornetq/deployer/JMSConfigurationIntegration.java	                        (rev 0)
+++ branches/Branch_Hornet_Temporary_2/hornetq-int/src/main/java/org/jboss/as/integration/hornetq/deployer/JMSConfigurationIntegration.java	2010-02-05 00:18:09 UTC (rev 100446)
@@ -0,0 +1,48 @@
+package org.jboss.as.integration.hornetq.deployer;
+
+import java.util.List;
+
+import org.hornetq.jms.server.JMSServerManager;
+import org.hornetq.jms.server.config.ConnectionFactoryConfiguration;
+import org.hornetq.jms.server.config.QueueConfiguration;
+import org.hornetq.jms.server.config.TopicConfiguration;
+import org.hornetq.jms.server.config.impl.JMSConfigurationImpl;
+
+public class JMSConfigurationIntegration extends JMSConfigurationImpl
+{
+    private final JMSServerManager jmsServer;
+
+    public JMSConfigurationIntegration(
+            final JMSServerManager jmsServer,
+            final List<ConnectionFactoryConfiguration> connectionFactoryConfigurations,
+            final List<QueueConfiguration> queueConfigurations,
+            final List<TopicConfiguration> topicConfigurations)
+    {
+        super(connectionFactoryConfigurations, queueConfigurations,
+                topicConfigurations);
+        this.jmsServer = jmsServer;
+    }
+
+    public void start()
+    {
+        for (int i = 0; i < 1000; i++)
+        {
+            System.out
+                    .println("yeaaaaaaaaaaaaaaaaaaaaaaaa... being started!!!!!");
+        }
+
+        System.out.flush();
+    }
+
+    public void stop()
+    {
+        for (int i = 0; i < 1000; i++)
+        {
+            System.out
+                    .println("Stop the press!!!!!");
+        }
+
+        System.out.flush();
+    }
+
+}

Modified: branches/Branch_Hornet_Temporary_2/hornetq-int/src/main/java/org/jboss/as/integration/hornetq/deployer/JMSDeployer.java
===================================================================
--- branches/Branch_Hornet_Temporary_2/hornetq-int/src/main/java/org/jboss/as/integration/hornetq/deployer/JMSDeployer.java	2010-02-05 00:06:47 UTC (rev 100445)
+++ branches/Branch_Hornet_Temporary_2/hornetq-int/src/main/java/org/jboss/as/integration/hornetq/deployer/JMSDeployer.java	2010-02-05 00:18:09 UTC (rev 100446)
@@ -1,69 +1,81 @@
 package org.jboss.as.integration.hornetq.deployer;
 
 import java.io.InputStream;
+import java.util.ArrayList;
 
 import org.hornetq.core.config.Configuration;
 import org.hornetq.jms.server.JMSServerConfigParser;
 import org.hornetq.jms.server.JMSServerManager;
+import org.hornetq.jms.server.config.ConnectionFactoryConfiguration;
 import org.hornetq.jms.server.config.JMSConfiguration;
-import org.hornetq.jms.server.config.impl.JMSConfigurationImpl;
+import org.hornetq.jms.server.config.QueueConfiguration;
+import org.hornetq.jms.server.config.TopicConfiguration;
 import org.hornetq.jms.server.impl.JMSServerConfigParserImpl;
 import org.jboss.deployers.vfs.spi.deployer.AbstractVFSParsingDeployer;
 import org.jboss.deployers.vfs.spi.structure.VFSDeploymentUnit;
 import org.jboss.virtual.VirtualFile;
 
-public class JMSDeployer extends AbstractVFSParsingDeployer<JMSConfiguration>{
-	public static final String FILENAME = "hornetq-jms.xml";
-	
-	
-	private final Configuration configuration;
-	private final JMSServerManager jmsServer;
-	private final JMSServerConfigParser jmsConfigParser;
-	
-	
-	public JMSDeployer(Configuration hornetQConfig, JMSServerManager jmsServer)
-	{
-		super(JMSConfiguration.class);
-		
-		this.configuration = hornetQConfig;
-		this.jmsServer = jmsServer;
-		this.jmsConfigParser = new JMSServerConfigParserImpl(configuration);
-		setName(FILENAME);
-	}
+public class JMSDeployer extends AbstractVFSParsingDeployer<JMSConfigurationIntegration>
+{
+    public static final String FILENAME = "hornetq-jms.xml";
 
+    private final Configuration configuration;
+    private final JMSServerManager jmsServer;
+    private final JMSServerConfigParser jmsConfigParser;
 
-	@Override
-	protected JMSConfiguration parse(VFSDeploymentUnit unit, VirtualFile file,
-			JMSConfiguration root) throws Exception {
-		
-		for (int i = 0 ; i < 100; i++) System.out.println("Deployed file " + file);
-		
-		System.out.flush();
-		
-		
-		InputStream deploymentStream = null;
-		
-		try
-		{
-			deploymentStream = file.openStream();
-			JMSConfiguration config = jmsConfigParser.parseConfiguration(deploymentStream);
-			System.out.println("Config = " + config);
-			
-			System.out.flush();
-			
-			return config;
-		}
-		finally
-		{
-			try
-			{
-				deploymentStream.close();
-			}
-			catch (Exception ignored)
-			{
-			}
-		}
-	}
- 
+    public JMSDeployer(Configuration hornetQConfig, JMSServerManager jmsServer)
+    {
+        super(JMSConfigurationIntegration.class);
 
+        this.configuration = hornetQConfig;
+        this.jmsServer = jmsServer;
+        this.jmsConfigParser = new LocalParser(configuration)
+        {
+
+        };
+        setName(FILENAME);
+    }
+
+    class LocalParser extends JMSServerConfigParserImpl
+    {
+        public LocalParser(Configuration configuration)
+        {
+            super(configuration);
+        }
+        
+        protected JMSConfiguration newConfig(final ArrayList<QueueConfiguration> queues,
+                final ArrayList<TopicConfiguration> topics,
+                final ArrayList<ConnectionFactoryConfiguration> cfs)
+        {
+            return new JMSConfigurationIntegration(jmsServer, cfs, queues, topics);
+        }
+    }
+
+    @Override
+    protected JMSConfigurationIntegration parse(VFSDeploymentUnit unit, VirtualFile file,
+            JMSConfigurationIntegration root) throws Exception
+    {
+
+        InputStream deploymentStream = null;
+
+        try
+        {
+            deploymentStream = file.openStream();
+            JMSConfiguration config = jmsConfigParser
+                    .parseConfiguration(deploymentStream);
+            System.out.println("Config = " + config);
+
+            System.out.flush();
+
+            return (JMSConfigurationIntegration)config;
+        } finally
+        {
+            try
+            {
+                deploymentStream.close();
+            } catch (Exception ignored)
+            {
+            }
+        }
+    }
 }