[hornetq-commits] JBoss hornetq SVN: r11690 - branches/Branch_2_2_AS7/tests/src/org/hornetq/tests/integration/ra.
do-not-reply at jboss.org
do-not-reply at jboss.org
Sat Nov 12 05:10:55 EST 2011
Author: ataylor
Date: 2011-11-12 05:10:54 -0500 (Sat, 12 Nov 2011)
New Revision: 11690
Modified:
branches/Branch_2_2_AS7/tests/src/org/hornetq/tests/integration/ra/HornetQRATestBase.java
Log:
test fix for resource adapter
Modified: branches/Branch_2_2_AS7/tests/src/org/hornetq/tests/integration/ra/HornetQRATestBase.java
===================================================================
--- branches/Branch_2_2_AS7/tests/src/org/hornetq/tests/integration/ra/HornetQRATestBase.java 2011-11-11 10:13:15 UTC (rev 11689)
+++ branches/Branch_2_2_AS7/tests/src/org/hornetq/tests/integration/ra/HornetQRATestBase.java 2011-11-12 10:10:54 UTC (rev 11690)
@@ -16,8 +16,13 @@
import org.hornetq.api.core.client.ServerLocator;
import org.hornetq.core.config.Configuration;
import org.hornetq.core.server.HornetQServer;
+import org.hornetq.integration.jboss.recovery.AS7RecoveryRegistry;
import org.hornetq.jms.client.HornetQMessage;
import org.hornetq.tests.util.ServiceTestBase;
+import org.jboss.msc.service.*;
+import org.jboss.msc.value.Value;
+import org.jboss.tm.XAResourceRecovery;
+import org.jboss.tm.XAResourceRecoveryRegistry;
import javax.jms.Message;
import javax.jms.MessageListener;
@@ -29,9 +34,14 @@
import javax.resource.spi.endpoint.MessageEndpointFactory;
import javax.resource.spi.work.*;
import javax.transaction.xa.XAResource;
+import java.io.PrintStream;
import java.lang.reflect.Method;
+import java.util.Collection;
+import java.util.List;
+import java.util.Set;
import java.util.Timer;
import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.TimeUnit;
/**
* @author <a href="mailto:andy.taylor at jboss.org">Andy Taylor</a>
@@ -60,6 +70,7 @@
server = createServer(true, configuration);
server.start();
server.createQueue(MDBQUEUEPREFIXEDSIMPLE, MDBQUEUEPREFIXEDSIMPLE, null, true, false);
+ AS7RecoveryRegistry.container = new DummyServiceContainer();
}
@Override
@@ -84,6 +95,7 @@
}
public abstract boolean isSecure();
+
class DummyMessageEndpointFactory implements MessageEndpointFactory
{
private DummyMessageEndpoint endpoint;
@@ -211,4 +223,247 @@
}
}
}
+
+
+ private static class DummyServiceContainer implements ServiceContainer
+ {
+ public void shutdown()
+ {
+ //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public boolean isShutdownComplete()
+ {
+ return false; //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public void addTerminateListener(TerminateListener terminateListener)
+ {
+ //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public void awaitTermination() throws InterruptedException
+ {
+ //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public void awaitTermination(long l, TimeUnit timeUnit) throws InterruptedException
+ {
+ //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public void dumpServices()
+ {
+ //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public void dumpServices(PrintStream printStream)
+ {
+ //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public String getName()
+ {
+ return null; //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public ServiceController<?> getRequiredService(ServiceName serviceName) throws ServiceNotFoundException
+ {
+ return null; //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public ServiceController<?> getService(ServiceName serviceName)
+ {
+ ServiceController<XAResourceRecoveryRegistry> controller = new ServiceController<XAResourceRecoveryRegistry>()
+ {
+ public ServiceController<?> getParent()
+ {
+ return null; //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public ServiceContainer getServiceContainer()
+ {
+ return null; //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public Mode getMode()
+ {
+ return null; //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public boolean compareAndSetMode(Mode mode, Mode mode1)
+ {
+ return false; //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public void setMode(Mode mode)
+ {
+ //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public State getState()
+ {
+ return null; //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public Substate getSubstate()
+ {
+ return null; //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public XAResourceRecoveryRegistry getValue() throws IllegalStateException
+ {
+ XAResourceRecoveryRegistry registry = new XAResourceRecoveryRegistry()
+ {
+ public void addXAResourceRecovery(XAResourceRecovery xaResourceRecovery)
+ {
+ //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public void removeXAResourceRecovery(XAResourceRecovery xaResourceRecovery)
+ {
+ //To change body of implemented methods use File | Settings | File Templates.
+ }
+ };
+ return registry; //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public Service<XAResourceRecoveryRegistry> getService() throws IllegalStateException
+ {
+ return null; //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public ServiceName getName()
+ {
+ return null; //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public ServiceName[] getAliases()
+ {
+ return new ServiceName[0]; //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public void addListener(ServiceListener<? super XAResourceRecoveryRegistry> serviceListener)
+ {
+ //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public void addListener(ServiceListener.Inheritance inheritance, ServiceListener<Object> objectServiceListener)
+ {
+ //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public void removeListener(ServiceListener<? super XAResourceRecoveryRegistry> serviceListener)
+ {
+ //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public StartException getStartException()
+ {
+ return null; //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public void retry()
+ {
+ //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public Set<ServiceName> getImmediateUnavailableDependencies()
+ {
+ return null; //To change body of implemented methods use File | Settings | File Templates.
+ }
+ };
+ return controller; //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public List<ServiceName> getServiceNames()
+ {
+ return null; //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public <T> ServiceBuilder<T> addServiceValue(ServiceName serviceName, Value<? extends Service<T>> value)
+ {
+ return null; //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public <T> ServiceBuilder<T> addService(ServiceName serviceName, Service<T> tService)
+ {
+ return null; //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public ServiceTarget addListener(ServiceListener<Object> objectServiceListener)
+ {
+ return null; //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public ServiceTarget addListener(ServiceListener<Object>... serviceListeners)
+ {
+ return null; //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public ServiceTarget addListener(Collection<ServiceListener<Object>> serviceListeners)
+ {
+ return null; //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public ServiceTarget addListener(ServiceListener.Inheritance inheritance, ServiceListener<Object> objectServiceListener)
+ {
+ return null; //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public ServiceTarget addListener(ServiceListener.Inheritance inheritance, ServiceListener<Object>... serviceListeners)
+ {
+ return null; //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public ServiceTarget addListener(ServiceListener.Inheritance inheritance, Collection<ServiceListener<Object>> serviceListeners)
+ {
+ return null; //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public ServiceTarget removeListener(ServiceListener<Object> objectServiceListener)
+ {
+ return null; //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public Set<ServiceListener<Object>> getListeners()
+ {
+ return null; //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public ServiceTarget addDependency(ServiceName serviceName)
+ {
+ return null; //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public ServiceTarget addDependency(ServiceName... serviceNames)
+ {
+ return null; //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public ServiceTarget addDependency(Collection<ServiceName> serviceNames)
+ {
+ return null; //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public ServiceTarget removeDependency(ServiceName serviceName)
+ {
+ return null; //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public Set<ServiceName> getDependencies()
+ {
+ return null; //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public ServiceTarget subTarget()
+ {
+ return null; //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public BatchServiceTarget batchTarget()
+ {
+ return null; //To change body of implemented methods use File | Settings | File Templates.
+ }
+ }
}
More information about the hornetq-commits
mailing list