[hornetq-commits] JBoss hornetq SVN: r9383 - in trunk: tests/src/org/hornetq/tests/integration/ra and 1 other directory.
do-not-reply at jboss.org
do-not-reply at jboss.org
Wed Jul 7 10:06:52 EDT 2010
Author: ataylor
Date: 2010-07-07 10:06:50 -0400 (Wed, 07 Jul 2010)
New Revision: 9383
Added:
trunk/tests/src/org/hornetq/tests/integration/ra/OutgoingConnectionTest.java
trunk/tests/src/org/hornetq/tests/integration/ra/ResourceAdapterTest.java
Modified:
trunk/src/main/org/hornetq/ra/HornetQResourceAdapter.java
trunk/tests/src/org/hornetq/tests/integration/ra/HornetQMessageHandlerTest.java
Log:
HORNETQ-140 - JCA Integration more tests and a couple of tweaks
Modified: trunk/src/main/org/hornetq/ra/HornetQResourceAdapter.java
===================================================================
--- trunk/src/main/org/hornetq/ra/HornetQResourceAdapter.java 2010-07-07 12:50:27 UTC (rev 9382)
+++ trunk/src/main/org/hornetq/ra/HornetQResourceAdapter.java 2010-07-07 14:06:50 UTC (rev 9383)
@@ -411,36 +411,6 @@
}
/**
- * Get load balancing policy class name
- *
- * @return The value
- */
- public String getLoadBalancingPolicyClassName()
- {
- if (HornetQResourceAdapter.trace)
- {
- HornetQResourceAdapter.log.trace("getLoadBalancingPolicyClassName()");
- }
-
- return raProperties.getConnectionLoadBalancingPolicyClassName();
- }
-
- /**
- * Set load balancing policy class name
- *
- * @param loadBalancingPolicyClassName The value
- */
- public void setLoadBalancingPolicyClassName(final String loadBalancingPolicyClassName)
- {
- if (HornetQResourceAdapter.trace)
- {
- HornetQResourceAdapter.log.trace("setLoadBalancingPolicyClassName(" + loadBalancingPolicyClassName + ")");
- }
-
- raProperties.setConnectionLoadBalancingPolicyClassName(loadBalancingPolicyClassName);
- }
-
- /**
* Get client failure check period
*
* @return The value
Modified: trunk/tests/src/org/hornetq/tests/integration/ra/HornetQMessageHandlerTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/ra/HornetQMessageHandlerTest.java 2010-07-07 12:50:27 UTC (rev 9382)
+++ trunk/tests/src/org/hornetq/tests/integration/ra/HornetQMessageHandlerTest.java 2010-07-07 14:06:50 UTC (rev 9383)
@@ -19,6 +19,8 @@
import org.hornetq.core.postoffice.impl.LocalQueueBinding;
import org.hornetq.ra.HornetQResourceAdapter;
import org.hornetq.ra.inflow.HornetQActivationSpec;
+
+import javax.jms.Message;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;
@@ -63,6 +65,58 @@
qResourceAdapter.endpointDeactivation(endpointFactory, spec);
}
+ public void testInvalidAckMode() throws Exception
+ {
+ HornetQResourceAdapter qResourceAdapter = new HornetQResourceAdapter();
+ MyBootstrapContext ctx = new MyBootstrapContext();
+ qResourceAdapter.start(ctx);
+ HornetQActivationSpec spec = new HornetQActivationSpec();
+ try
+ {
+ spec.setAcknowledgeMode("CLIENT_ACKNOWLEDGE");
+ fail("should throw exception");
+ }
+ catch (java.lang.IllegalArgumentException e)
+ {
+ //pass
+ }
+ }
+
+ public void testSimpleMessageReceivedOnQueueInLocalTX() throws Exception
+ {
+ HornetQResourceAdapter qResourceAdapter = new HornetQResourceAdapter();
+ qResourceAdapter.setUseLocalTx(true);
+ MyBootstrapContext ctx = new MyBootstrapContext();
+ qResourceAdapter.start(ctx);
+ HornetQActivationSpec spec = new HornetQActivationSpec();
+ spec.setResourceAdapter(qResourceAdapter);
+ spec.setUseJNDI(false);
+ spec.setDestinationType("javax.jms.Queue");
+ spec.setDestination(MDBQUEUE);
+ qResourceAdapter.setConnectorClassName(INVM_CONNECTOR_FACTORY);
+ CountDownLatch latch = new CountDownLatch(1);
+ ExceptionDummyMessageEndpoint endpoint = new ExceptionDummyMessageEndpoint(latch);
+ DummyMessageEndpointFactory endpointFactory = new DummyMessageEndpointFactory(endpoint, false);
+ qResourceAdapter.endpointActivation(endpointFactory, spec);
+ ClientSession session = createFactory(false).createSession();
+ ClientProducer clientProducer = session.createProducer(MDBQUEUEPREFIXED);
+ ClientMessage message = session.createMessage(true);
+ message.getBodyBuffer().writeString("teststring");
+ clientProducer.send(message);
+ session.close();
+ latch.await(5, TimeUnit.SECONDS);
+
+ assertNull(endpoint.lastMessage);
+ latch = new CountDownLatch(1);
+ endpoint.reset(latch);
+ latch.await(5, TimeUnit.SECONDS);
+
+ assertNotNull(endpoint.lastMessage);
+ assertEquals(endpoint.lastMessage.getCoreMessage().getBodyBuffer().readString(), "teststring");
+
+ qResourceAdapter.endpointDeactivation(endpointFactory, spec);
+ }
+
public void testSimpleMessageReceivedOnQueueWithSelector() throws Exception
{
HornetQResourceAdapter qResourceAdapter = new HornetQResourceAdapter();
@@ -376,5 +430,24 @@
}
+ class ExceptionDummyMessageEndpoint extends DummyMessageEndpoint
+ {
+ boolean throwException = true;
+ public ExceptionDummyMessageEndpoint(CountDownLatch latch)
+ {
+ super(latch);
+ }
+
+ @Override
+ public void onMessage(Message message)
+ {
+ if(throwException)
+ {
+ throwException = false;
+ throw new IllegalStateException("boo!");
+ }
+ super.onMessage(message);
+ }
+ }
}
Added: trunk/tests/src/org/hornetq/tests/integration/ra/OutgoingConnectionTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/ra/OutgoingConnectionTest.java (rev 0)
+++ trunk/tests/src/org/hornetq/tests/integration/ra/OutgoingConnectionTest.java 2010-07-07 14:06:50 UTC (rev 9383)
@@ -0,0 +1,212 @@
+/*
+ * Copyright 2009 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (the "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied. See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+package org.hornetq.tests.integration.ra;
+
+import org.hornetq.api.core.client.HornetQClient;
+import org.hornetq.api.jms.HornetQJMSClient;
+import org.hornetq.core.remoting.impl.invm.InVMConnectorFactory;
+import org.hornetq.core.security.Role;
+import org.hornetq.core.transaction.impl.XidImpl;
+import org.hornetq.ra.*;
+import org.hornetq.utils.UUIDGenerator;
+
+import javax.jms.*;
+import javax.jms.IllegalStateException;
+import javax.transaction.xa.XAResource;
+import javax.transaction.xa.Xid;
+import java.util.HashSet;
+import java.util.Set;
+
+/**
+ * @author <a href="mailto:andy.taylor at jboss.org">Andy Taylor</a>
+ * Created Jul 7, 2010
+ */
+public class OutgoingConnectionTest extends HornetQRATestBase
+{
+ @Override
+ public boolean isSecure()
+ {
+ return true;
+ }
+
+ @Override
+ protected void setUp() throws Exception
+ {
+ super.setUp();
+ server.getSecurityManager().addUser("testuser", "testpassword");
+ server.getSecurityManager().addUser("guest", "guest");
+ server.getSecurityManager().setDefaultUser("guest");
+ server.getSecurityManager().addRole("testuser", "arole");
+ server.getSecurityManager().addRole("guest", "arole");
+ Role role = new Role("arole", true, true, true, true, true, true, true);
+ Set<Role> roles = new HashSet<Role>();
+ roles.add(role);
+ server.getSecurityRepository().addMatch(MDBQUEUEPREFIXED, roles);
+ }
+
+ public void testSimpleMessageSendAndReceive() throws Exception
+ {
+ HornetQResourceAdapter qResourceAdapter = new HornetQResourceAdapter();
+ qResourceAdapter.setConnectorClassName(InVMConnectorFactory.class.getName());
+ MyBootstrapContext ctx = new MyBootstrapContext();
+ qResourceAdapter.start(ctx);
+ HornetQRAConnectionManager qraConnectionManager = new HornetQRAConnectionManager();
+ HornetQRAManagedConnectionFactory mcf = new HornetQRAManagedConnectionFactory();
+ mcf.setResourceAdapter(qResourceAdapter);
+ HornetQRAConnectionFactory qraConnectionFactory = new HornetQRAConnectionFactoryImpl(mcf, qraConnectionManager);
+ QueueConnection queueConnection = qraConnectionFactory.createQueueConnection();
+ Session s = queueConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+ Queue q = HornetQJMSClient.createQueue(MDBQUEUE);
+ MessageProducer mp = s.createProducer(q);
+ MessageConsumer consumer = s.createConsumer(q);
+ Message message = s.createTextMessage("test");
+ mp.send(message);
+ queueConnection.start();
+ TextMessage textMessage = (TextMessage) consumer.receive(1000);
+ assertNotNull(textMessage);
+ assertEquals(textMessage.getText(), "test");
+ s.close();
+ }
+
+ public void testSimpleMessageSendAndReceiveXA() throws Exception
+ {
+ Xid xid = new XidImpl("xa1".getBytes(), 1, UUIDGenerator.getInstance().generateStringUUID().getBytes());
+ HornetQResourceAdapter qResourceAdapter = new HornetQResourceAdapter();
+ qResourceAdapter.setConnectorClassName(InVMConnectorFactory.class.getName());
+ MyBootstrapContext ctx = new MyBootstrapContext();
+ qResourceAdapter.start(ctx);
+ HornetQRAConnectionManager qraConnectionManager = new HornetQRAConnectionManager();
+ HornetQRAManagedConnectionFactory mcf = new HornetQRAManagedConnectionFactory();
+ mcf.setResourceAdapter(qResourceAdapter);
+ HornetQRAConnectionFactory qraConnectionFactory = new HornetQRAConnectionFactoryImpl(mcf, qraConnectionManager);
+ XAQueueConnection queueConnection = qraConnectionFactory.createXAQueueConnection();
+ XASession s = queueConnection.createXASession();
+
+ XAResource resource = s.getXAResource();
+ resource.start(xid, XAResource.TMNOFLAGS);
+ Queue q = HornetQJMSClient.createQueue(MDBQUEUE);
+ MessageProducer mp = s.createProducer(q);
+ MessageConsumer consumer = s.createConsumer(q);
+ Message message = s.createTextMessage("test");
+ mp.send(message);
+ queueConnection.start();
+ TextMessage textMessage = (TextMessage) consumer.receiveNoWait();
+ assertNull(textMessage);
+ resource.end(xid, XAResource.TMSUCCESS);
+ resource.commit(xid, true);
+ resource.start(xid, XAResource.TMNOFLAGS);
+ textMessage = (TextMessage) consumer.receiveNoWait();
+ resource.end(xid, XAResource.TMSUCCESS);
+ resource.commit(xid, true);
+ assertNotNull(textMessage);
+ assertEquals(textMessage.getText(), "test");
+ s.close();
+ }
+
+ public void testSimpleMessageSendAndReceiveTransacted() throws Exception
+ {
+ HornetQResourceAdapter qResourceAdapter = new HornetQResourceAdapter();
+ qResourceAdapter.setConnectorClassName(InVMConnectorFactory.class.getName());
+ qResourceAdapter.setUseLocalTx(true);
+ MyBootstrapContext ctx = new MyBootstrapContext();
+ qResourceAdapter.start(ctx);
+ HornetQRAConnectionManager qraConnectionManager = new HornetQRAConnectionManager();
+ HornetQRAManagedConnectionFactory mcf = new HornetQRAManagedConnectionFactory();
+ mcf.setResourceAdapter(qResourceAdapter);
+ HornetQRAConnectionFactory qraConnectionFactory = new HornetQRAConnectionFactoryImpl(mcf, qraConnectionManager);
+ QueueConnection queueConnection = qraConnectionFactory.createQueueConnection();
+ Session s = queueConnection.createSession(true, Session.AUTO_ACKNOWLEDGE);
+ Queue q = HornetQJMSClient.createQueue(MDBQUEUE);
+ MessageProducer mp = s.createProducer(q);
+ MessageConsumer consumer = s.createConsumer(q);
+ Message message = s.createTextMessage("test");
+ mp.send(message);
+ s.commit();
+ queueConnection.start();
+ TextMessage textMessage = (TextMessage) consumer.receive(1000);
+ assertNotNull(textMessage);
+ assertEquals(textMessage.getText(), "test");
+ s.rollback();
+ textMessage = (TextMessage) consumer.receive(1000);
+ assertNotNull(textMessage);
+ assertEquals(textMessage.getText(), "test");
+ s.commit();
+ s.close();
+ }
+
+ public void testMultipleSessionsThrowsException() throws Exception
+ {
+ HornetQResourceAdapter qResourceAdapter = new HornetQResourceAdapter();
+ qResourceAdapter.setConnectorClassName(InVMConnectorFactory.class.getName());
+ MyBootstrapContext ctx = new MyBootstrapContext();
+ qResourceAdapter.start(ctx);
+ HornetQRAConnectionManager qraConnectionManager = new HornetQRAConnectionManager();
+ HornetQRAManagedConnectionFactory mcf = new HornetQRAManagedConnectionFactory();
+ mcf.setResourceAdapter(qResourceAdapter);
+ HornetQRAConnectionFactory qraConnectionFactory = new HornetQRAConnectionFactoryImpl(mcf, qraConnectionManager);
+ QueueConnection queueConnection = qraConnectionFactory.createQueueConnection();
+ Session s = queueConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+ try
+ {
+ Session s2 = queueConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+ fail("should throw javax,jms.IllegalStateException: Only allowed one session per connection. See the J2EE spec, e.g. J2EE1.4 Section 6.6");
+ }
+ catch (JMSException e)
+ {
+ assertTrue(e.getLinkedException() instanceof IllegalStateException);
+ }
+ s.close();
+ }
+
+ public void testConnectionCredentials() throws Exception
+ {
+ HornetQResourceAdapter qResourceAdapter = new HornetQResourceAdapter();
+ qResourceAdapter.setConnectorClassName(InVMConnectorFactory.class.getName());
+ MyBootstrapContext ctx = new MyBootstrapContext();
+ qResourceAdapter.start(ctx);
+ HornetQRAConnectionManager qraConnectionManager = new HornetQRAConnectionManager();
+ HornetQRAManagedConnectionFactory mcf = new HornetQRAManagedConnectionFactory();
+ mcf.setResourceAdapter(qResourceAdapter);
+ HornetQRAConnectionFactory qraConnectionFactory = new HornetQRAConnectionFactoryImpl(mcf, qraConnectionManager);
+ QueueConnection queueConnection = qraConnectionFactory.createQueueConnection();
+ queueConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE).close();
+ queueConnection.close();
+ queueConnection = qraConnectionFactory.createQueueConnection("testuser", "testpassword");
+ queueConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE).close();
+ }
+
+ public void testConnectionCredentialsFail() throws Exception
+ {
+ HornetQResourceAdapter qResourceAdapter = new HornetQResourceAdapter();
+ qResourceAdapter.setConnectorClassName(InVMConnectorFactory.class.getName());
+ MyBootstrapContext ctx = new MyBootstrapContext();
+ qResourceAdapter.start(ctx);
+ HornetQRAConnectionManager qraConnectionManager = new HornetQRAConnectionManager();
+ HornetQRAManagedConnectionFactory mcf = new HornetQRAManagedConnectionFactory();
+ mcf.setResourceAdapter(qResourceAdapter);
+ HornetQRAConnectionFactory qraConnectionFactory = new HornetQRAConnectionFactoryImpl(mcf, qraConnectionManager);
+ QueueConnection queueConnection = qraConnectionFactory.createQueueConnection();
+ queueConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE).close();
+ queueConnection.close();
+ queueConnection = qraConnectionFactory.createQueueConnection("testuser", "testwrongpassword");
+ try
+ {
+ queueConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE).close();
+ fail("should throw esxception");
+ }
+ catch (JMSException e)
+ {
+ //pass
+ }
+ }
+}
Added: trunk/tests/src/org/hornetq/tests/integration/ra/ResourceAdapterTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/ra/ResourceAdapterTest.java (rev 0)
+++ trunk/tests/src/org/hornetq/tests/integration/ra/ResourceAdapterTest.java 2010-07-07 14:06:50 UTC (rev 9383)
@@ -0,0 +1,198 @@
+/*
+ * Copyright 2009 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (the "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied. See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+package org.hornetq.tests.integration.ra;
+
+import org.hornetq.ra.HornetQResourceAdapter;
+import org.hornetq.ra.inflow.HornetQActivationSpec;
+import org.hornetq.tests.util.ServiceTestBase;
+
+import javax.resource.ResourceException;
+import javax.resource.spi.BootstrapContext;
+import javax.resource.spi.ResourceAdapterInternalException;
+import javax.resource.spi.UnavailableException;
+import javax.resource.spi.XATerminator;
+import javax.resource.spi.endpoint.MessageEndpoint;
+import javax.resource.spi.endpoint.MessageEndpointFactory;
+import javax.resource.spi.work.WorkManager;
+import javax.transaction.xa.XAResource;
+import java.lang.reflect.Method;
+import java.util.Timer;
+import java.util.concurrent.CountDownLatch;
+
+/**
+ * @author <a href="mailto:andy.taylor at jboss.org">Andy Taylor</a>
+ * Created Jul 7, 2010
+ */
+public class ResourceAdapterTest extends HornetQRATestBase
+{
+ public void testStartStop() throws Exception
+ {
+ HornetQResourceAdapter qResourceAdapter = new HornetQResourceAdapter();
+ HornetQRATestBase.MyBootstrapContext ctx = new HornetQRATestBase.MyBootstrapContext();
+ qResourceAdapter.start(ctx);
+ HornetQActivationSpec spec = new HornetQActivationSpec();
+ spec.setResourceAdapter(qResourceAdapter);
+ spec.setUseJNDI(false);
+ spec.setDestinationType("javax.jms.Queue");
+ spec.setDestination(MDBQUEUE);
+ qResourceAdapter.setConnectorClassName(INVM_CONNECTOR_FACTORY);
+ CountDownLatch latch = new CountDownLatch(1);
+ DummyMessageEndpoint endpoint = new DummyMessageEndpoint(latch);
+ DummyMessageEndpointFactory endpointFactory = new DummyMessageEndpointFactory(endpoint, false);
+ qResourceAdapter.endpointActivation(endpointFactory, spec);
+ qResourceAdapter.stop();
+ assertTrue(endpoint.released);
+ }
+
+ public void testSetters() throws Exception
+ {
+ Boolean b = Boolean.TRUE;
+ Long l = (long) 1000;
+ Integer i = 1000;
+ Double d = (double) 1000;
+ String className = "testConnector";
+ String backupConn = "testBackupConnector";
+ String testConfig = "key=val";
+ String testid = "testid";
+ String testBalancer = "testBalancer";
+ String testParams = "key=val";
+ String testaddress = "testaddress";
+ String loadbalancer = "loadbalancer";
+ String testpass = "testpass";
+ String testuser = "testuser";
+ HornetQResourceAdapter qResourceAdapter = new HornetQResourceAdapter();
+ testParams(b, l, i, d, className, backupConn, testConfig, testid, testBalancer, testParams, testaddress, testpass, testuser, qResourceAdapter);
+ }
+
+ public void testSetters2() throws Exception
+ {
+ Boolean b = Boolean.FALSE;
+ Long l = (long) 2000;
+ Integer i = 2000;
+ Double d = (double) 2000;
+ String className = "testConnector2";
+ String backupConn = "testBackupConnector2";
+ String testConfig = "key2=val2";
+ String testid = "testid2";
+ String testBalancer = "testBalancer2";
+ String testParams = "key=val2";
+ String testaddress = "testaddress2";
+ String loadbalancer = "loadbalancer2";
+ String testpass = "testpass2";
+ String testuser = "testuser2";
+ HornetQResourceAdapter qResourceAdapter = new HornetQResourceAdapter();
+ testParams(b, l, i, d, className, backupConn, testConfig, testid, testBalancer, testParams, testaddress, testpass, testuser, qResourceAdapter);
+ }
+
+
+ private void testParams(Boolean b, Long l, Integer i, Double d, String className, String backupConn, String testConfig, String testid, String testBalancer, String testParams, String testaddress, String testpass, String testuser, HornetQResourceAdapter qResourceAdapter)
+ {
+ qResourceAdapter.setUseLocalTx(b);
+ qResourceAdapter.setConnectorClassName(className);
+ qResourceAdapter.setAutoGroup(b);
+ qResourceAdapter.setBackupConnectorClassName(backupConn);
+ qResourceAdapter.setBackupTransportConfiguration(testConfig);
+ qResourceAdapter.setBlockOnAcknowledge(b);
+ qResourceAdapter.setBlockOnDurableSend(b);
+ qResourceAdapter.setBlockOnNonDurableSend(b);
+ qResourceAdapter.setCallTimeout(l);
+ qResourceAdapter.setClientFailureCheckPeriod(l);
+ qResourceAdapter.setClientID(testid);
+ qResourceAdapter.setConfirmationWindowSize(i);
+ qResourceAdapter.setConnectionLoadBalancingPolicyClassName(testBalancer);
+ qResourceAdapter.setConnectionParameters(testParams);
+ qResourceAdapter.setConnectionTTL(l);
+ qResourceAdapter.setConsumerMaxRate(i);
+ qResourceAdapter.setConsumerWindowSize(i);
+ qResourceAdapter.setDiscoveryAddress(testaddress);
+ qResourceAdapter.setDiscoveryInitialWaitTimeout(l);
+ qResourceAdapter.setDiscoveryPort(i);
+ qResourceAdapter.setDiscoveryRefreshTimeout(l);
+ qResourceAdapter.setDupsOKBatchSize(i);
+ qResourceAdapter.setFailoverOnServerShutdown(b);
+ qResourceAdapter.setMinLargeMessageSize(i);
+ qResourceAdapter.setPassword(testpass);
+ qResourceAdapter.setPreAcknowledge(b);
+ qResourceAdapter.setProducerMaxRate(i);
+ qResourceAdapter.setReconnectAttempts(i);
+ qResourceAdapter.setRetryInterval(l);
+ qResourceAdapter.setRetryIntervalMultiplier(d);
+ qResourceAdapter.setScheduledThreadPoolMaxSize(i);
+ qResourceAdapter.setThreadPoolMaxSize(i);
+ qResourceAdapter.setTransactionBatchSize(i);
+ qResourceAdapter.setUseGlobalPools(b);
+ qResourceAdapter.setUseLocalTx(b);
+ qResourceAdapter.setUserName(testuser);
+
+ assertEquals(qResourceAdapter.getUseLocalTx(), b);
+ assertEquals(qResourceAdapter.getConnectorClassName(), className);
+ assertEquals(qResourceAdapter.getAutoGroup(), b);
+ assertEquals(qResourceAdapter.getBackupConnectorClassName(), backupConn);
+ //assertEquals(qResourceAdapter.getBackupTransportConfiguration(),"testConfig");
+ assertEquals(qResourceAdapter.getBlockOnAcknowledge(), b);
+ assertEquals(qResourceAdapter.getBlockOnDurableSend(), b);
+ assertEquals(qResourceAdapter.getBlockOnNonDurableSend(), b);
+ assertEquals(qResourceAdapter.getCallTimeout(), l);
+ assertEquals(qResourceAdapter.getClientFailureCheckPeriod(), l);
+ assertEquals(qResourceAdapter.getClientID(), testid);
+ assertEquals(qResourceAdapter.getConfirmationWindowSize(), i);
+ assertEquals(qResourceAdapter.getConnectionLoadBalancingPolicyClassName(), testBalancer);
+ assertEquals(qResourceAdapter.getConnectionParameters(), testParams);
+ assertEquals(qResourceAdapter.getConnectionTTL(), l);
+ assertEquals(qResourceAdapter.getConsumerMaxRate(), i);
+ assertEquals(qResourceAdapter.getConsumerWindowSize(), i);
+ assertEquals(qResourceAdapter.getDiscoveryAddress(), testaddress);
+ assertEquals(qResourceAdapter.getDiscoveryInitialWaitTimeout(), l);
+ assertEquals(qResourceAdapter.getDiscoveryPort(), i);
+ assertEquals(qResourceAdapter.getDiscoveryRefreshTimeout(), l);
+ assertEquals(qResourceAdapter.getDupsOKBatchSize(), i);
+ assertEquals(qResourceAdapter.getFailoverOnServerShutdown(), b);
+ assertEquals(qResourceAdapter.getMinLargeMessageSize(), i);
+ assertEquals(qResourceAdapter.getPassword(), testpass);
+ assertEquals(qResourceAdapter.getPreAcknowledge(), b);
+ assertEquals(qResourceAdapter.getProducerMaxRate(), i);
+ assertEquals(qResourceAdapter.getReconnectAttempts(), i);
+ assertEquals(qResourceAdapter.getRetryInterval(), l);
+ assertEquals(qResourceAdapter.getRetryIntervalMultiplier(), d);
+ assertEquals(qResourceAdapter.getScheduledThreadPoolMaxSize(), i);
+ assertEquals(qResourceAdapter.getThreadPoolMaxSize(), i);
+ assertEquals(qResourceAdapter.getTransactionBatchSize(), i);
+ assertEquals(qResourceAdapter.getUseGlobalPools(), b);
+ assertEquals(qResourceAdapter.getUseLocalTx(), b);
+ assertEquals(qResourceAdapter.getUserName(), testuser);
+ }
+
+ @Override
+ public boolean isSecure()
+ {
+ return false;
+ }
+
+ class DummyEndpoint implements MessageEndpoint
+ {
+ public void beforeDelivery(Method method) throws NoSuchMethodException, ResourceException
+ {
+ //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public void afterDelivery() throws ResourceException
+ {
+ //To change body of implemented methods use File | Settings | File Templates.
+ }
+
+ public void release()
+ {
+ //To change body of implemented methods use File | Settings | File Templates.
+ }
+ }
+}
More information about the hornetq-commits
mailing list