[jboss-cvs] JBossAS SVN: r99850 - in branches/Branch_Hornet_Temporary/messaging/src/main/java/org/jboss/jms: testintegration and 1 other directory.

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

Author: clebert.suconic at jboss.com
Date: 2010-01-22 21:38:02 -0500 (Fri, 22 Jan 2010)
New Revision: 99850

Added:
   branches/Branch_Hornet_Temporary/messaging/src/main/java/org/jboss/jms/testintegration/
   branches/Branch_Hornet_Temporary/messaging/src/main/java/org/jboss/jms/testintegration/HornetQAdminFactory.java
   branches/Branch_Hornet_Temporary/messaging/src/main/java/org/jboss/jms/testintegration/HornetQTestAdmin.java
   branches/Branch_Hornet_Temporary/messaging/src/main/java/org/jboss/jms/testintegration/JMSTestAdmin.java
   branches/Branch_Hornet_Temporary/messaging/src/main/java/org/jboss/jms/testintegration/JMSTestAdminFactory.java
   branches/Branch_Hornet_Temporary/messaging/src/main/java/org/jboss/jms/testintegration/TestRole.java
Log:
changes

Added: branches/Branch_Hornet_Temporary/messaging/src/main/java/org/jboss/jms/testintegration/HornetQAdminFactory.java
===================================================================
--- branches/Branch_Hornet_Temporary/messaging/src/main/java/org/jboss/jms/testintegration/HornetQAdminFactory.java	                        (rev 0)
+++ branches/Branch_Hornet_Temporary/messaging/src/main/java/org/jboss/jms/testintegration/HornetQAdminFactory.java	2010-01-23 02:38:02 UTC (rev 99850)
@@ -0,0 +1,15 @@
+package org.jboss.jms.testintegration;
+
+import javax.management.MBeanServerConnection;
+
+
+public class HornetQAdminFactory extends JMSTestAdminFactory
+{
+
+	@Override
+	JMSTestAdmin newAdmin(MBeanServerConnection jmxConnection)
+	{
+		return new HornetQTestAdmin(jmxConnection);
+	}
+
+}

Added: branches/Branch_Hornet_Temporary/messaging/src/main/java/org/jboss/jms/testintegration/HornetQTestAdmin.java
===================================================================
--- branches/Branch_Hornet_Temporary/messaging/src/main/java/org/jboss/jms/testintegration/HornetQTestAdmin.java	                        (rev 0)
+++ branches/Branch_Hornet_Temporary/messaging/src/main/java/org/jboss/jms/testintegration/HornetQTestAdmin.java	2010-01-23 02:38:02 UTC (rev 99850)
@@ -0,0 +1,55 @@
+package org.jboss.jms.testintegration;
+
+import javax.management.MBeanServerConnection;
+import javax.management.ObjectName;
+
+import org.jboss.util.NestedRuntimeException;
+
+public class HornetQTestAdmin implements JMSTestAdmin
+{
+	private final MBeanServerConnection jmx;
+
+	protected static final ObjectName hornetQJMSServerName;
+
+	static
+	{
+		try
+		{
+			hornetQJMSServerName = new ObjectName("module=JMS,type=Server");
+		} catch (Exception e)
+		{
+			throw new NestedRuntimeException(e);
+		}
+	}
+
+	public HornetQTestAdmin(MBeanServerConnection connection)
+	{
+		this.jmx = connection;
+	}
+
+	public Object createQueue(String name, TestRole[] securityConfig) throws Exception
+	{
+		//return jmx.invoke(hornetQJMSServerName, create, params, signature);
+		return null;
+	}
+
+	public Object createTopic(String name, TestRole[] securityConfig)
+	{
+		// TODO Auto-generated method stub
+
+		return null;
+	}
+
+	public void deleteQueue(Object name)
+	{
+		// TODO Auto-generated method stub
+
+	}
+
+	public void deleteTopic(Object name)
+	{
+		// TODO Auto-generated method stub
+
+	}
+
+}

Added: branches/Branch_Hornet_Temporary/messaging/src/main/java/org/jboss/jms/testintegration/JMSTestAdmin.java
===================================================================
--- branches/Branch_Hornet_Temporary/messaging/src/main/java/org/jboss/jms/testintegration/JMSTestAdmin.java	                        (rev 0)
+++ branches/Branch_Hornet_Temporary/messaging/src/main/java/org/jboss/jms/testintegration/JMSTestAdmin.java	2010-01-23 02:38:02 UTC (rev 99850)
@@ -0,0 +1,23 @@
+package org.jboss.jms.testintegration;
+
+/**
+ * 
+ * @author <mailto:clebert.suconic at jboss.org">Clebert Suconic</a>
+ *
+ */
+public interface JMSTestAdmin
+{
+	/**
+	 * 
+	 * @param name
+	 * @param securityConfig
+	 * @return information about the deployment required to undeploy/remove the topic
+	 */
+	Object createTopic(String name, TestRole[] securityConfig);
+
+	void deleteTopic(Object topic);
+
+	Object createQueue(String name, TestRole[] securityConfig) throws Exception;
+
+	void deleteQueue(Object queue);
+}

Added: branches/Branch_Hornet_Temporary/messaging/src/main/java/org/jboss/jms/testintegration/JMSTestAdminFactory.java
===================================================================
--- branches/Branch_Hornet_Temporary/messaging/src/main/java/org/jboss/jms/testintegration/JMSTestAdminFactory.java	                        (rev 0)
+++ branches/Branch_Hornet_Temporary/messaging/src/main/java/org/jboss/jms/testintegration/JMSTestAdminFactory.java	2010-01-23 02:38:02 UTC (rev 99850)
@@ -0,0 +1,14 @@
+package org.jboss.jms.testintegration;
+
+import javax.management.MBeanServerConnection;
+
+public abstract class JMSTestAdminFactory
+{
+	static JMSTestAdminFactory getFactory()
+	{
+		// TODO: make this configurable
+		return new HornetQAdminFactory();
+	}
+	
+	abstract JMSTestAdmin newAdmin(MBeanServerConnection jmxConnection);
+}

Added: branches/Branch_Hornet_Temporary/messaging/src/main/java/org/jboss/jms/testintegration/TestRole.java
===================================================================
--- branches/Branch_Hornet_Temporary/messaging/src/main/java/org/jboss/jms/testintegration/TestRole.java	                        (rev 0)
+++ branches/Branch_Hornet_Temporary/messaging/src/main/java/org/jboss/jms/testintegration/TestRole.java	2010-01-23 02:38:02 UTC (rev 99850)
@@ -0,0 +1,53 @@
+package org.jboss.jms.testintegration;
+
+public class TestRole
+{
+	private String name;
+
+	private boolean read;
+
+	private boolean write;
+
+	private boolean create;
+
+	public String getName()
+	{
+		return name;
+	}
+
+	public void setName(String name)
+	{
+		this.name = name;
+	}
+
+	public boolean isRead()
+	{
+		return read;
+	}
+
+	public void setRead(boolean read)
+	{
+		this.read = read;
+	}
+
+	public boolean isWrite()
+	{
+		return write;
+	}
+
+	public void setWrite(boolean write)
+	{
+		this.write = write;
+	}
+
+	public boolean isCreate()
+	{
+		return create;
+	}
+
+	public void setCreate(boolean create)
+	{
+		this.create = create;
+	}
+
+}