* <p>The following fields must be set before executing this: <ul> <li>UEB_SERVERS</li>
  * <li>INTERNAL_TOPIC</li> <li>EXTERNAL_TOPIC</li> </ul>
  */
-public class FeatureTest2 {
+public class EndToEndFeatureTest {
 
-    private static final Logger logger = LoggerFactory.getLogger(FeatureTest2.class);
+    private static final Logger logger = LoggerFactory.getLogger(EndToEndFeatureTest.class);
 
     /**
      * UEB servers for both internal & external topics.
     /**
      * Consumer group to use when polling the external topic.
      */
-    private static final String EXTERNAL_GROUP = FeatureTest2.class.getName();
+    private static final String EXTERNAL_GROUP = EndToEndFeatureTest.class.getName();
 
     /**
      * Name of the controller.
 
 import org.junit.Test;
 import org.onap.policy.common.endpoints.event.comm.Topic.CommInfrastructure;
 
-public class ForwardTest extends BasicMessageTester<Forward> {
+public class ForwardTest extends SupportBasicMessageTester<Forward> {
     // values set by makeValidMessage()
     public static final CommInfrastructure VALID_PROTOCOL = CommInfrastructure.UEB;
     public static final int VALID_HOPS = 0;
 
 
 import static org.junit.Assert.assertEquals;
 
-public class HeartbeatTest extends BasicMessageTester<Heartbeat> {
+public class HeartbeatTest extends SupportBasicMessageTester<Heartbeat> {
     
     /**
      * Sequence number to validate time stamps within the heart beat.
 
 import org.junit.Before;
 import org.junit.Test;
 
-public class IdentificationTest extends MessageWithAssignmentsTester<Identification> {
+public class IdentificationTest extends SupportMessageWithAssignmentsTester<Identification> {
 
     public IdentificationTest() {
         super(Identification.class);
 
 import org.junit.Before;
 import org.junit.Test;
 
-public class LeaderTest extends MessageWithAssignmentsTester<Leader> {
+public class LeaderTest extends SupportMessageWithAssignmentsTester<Leader> {
 
     public LeaderTest() {
         super(Leader.class);
 
 
 import org.junit.Test;
 
-public class MessageTest extends BasicMessageTester<Message> {
+public class MessageTest extends SupportBasicMessageTester<Message> {
 
     public MessageTest() {
         super(Message.class);
 
 
 package org.onap.policy.drools.pooling.message;
 
-public class OfflineTest extends BasicMessageTester<Offline> {
+public class OfflineTest extends SupportBasicMessageTester<Offline> {
 
     public OfflineTest() {
         super(Offline.class);
 
 
 package org.onap.policy.drools.pooling.message;
 
-public class QueryTest extends BasicMessageTester<Query> {
+public class QueryTest extends SupportBasicMessageTester<Query> {
 
     public QueryTest() {
         super(Query.class);
 
  * 
  * @param <T> type of {@link Message} subclass that this tests
  */
-public abstract class BasicMessageTester<T extends Message> {
+public abstract class SupportBasicMessageTester<T extends Message> {
     // values set by makeValidMessage()
     public static final String VALID_HOST_PREDECESSOR = "hostA";
     public static final String VALID_HOST = "hostB";
      * 
      * @param subclazz subclass of {@link Message} being tested
      */
-    public BasicMessageTester(Class<T> subclazz) {
+    public SupportBasicMessageTester(Class<T> subclazz) {
         this.subclazz = subclazz;
     }
 
 
  * 
  * @param <T> type of {@link MessageWithAssignments} subclass that this tests
  */
-public abstract class MessageWithAssignmentsTester<T extends MessageWithAssignments> extends BasicMessageTester<T> {
+public abstract class SupportMessageWithAssignmentsTester<T extends MessageWithAssignments>
+        extends SupportBasicMessageTester<T> {
     // values set by makeValidMessage()
     public static final String[] VALID_ARRAY = {VALID_HOST, VALID_HOST + "_xxx"};
     public static final BucketAssignments VALID_ASGN = new BucketAssignments(VALID_ARRAY);
      * 
      * @param subclazz subclass of {@link MessageWithAssignments} being tested
      */
-    public MessageWithAssignmentsTester(Class<T> subclazz) {
+    public SupportMessageWithAssignmentsTester(Class<T> subclazz) {
         super(subclazz);
     }
 
 
 import org.onap.policy.drools.utils.Pair;
 import org.onap.policy.drools.utils.Triple;
 
-public class ActiveStateTest extends BasicStateTester {
+public class ActiveStateTest extends SupportBasicStateTester {
 
     private ActiveState state;
 
 
 import org.onap.policy.drools.pooling.message.Offline;
 import org.onap.policy.drools.pooling.message.Query;
 
-public class IdleStateTest extends BasicStateTester {
+public class IdleStateTest extends SupportBasicStateTester {
 
     private IdleState state;
 
 
 import org.onap.policy.drools.pooling.message.Query;
 import org.onap.policy.drools.utils.Pair;
 
-public class InactiveStateTest extends BasicStateTester {
+public class InactiveStateTest extends SupportBasicStateTester {
 
     private InactiveState state;
 
 
 import org.onap.policy.drools.pooling.message.Query;
 import org.onap.policy.drools.pooling.state.ProcessingState.HostBucket;
 
-public class ProcessingStateTest extends BasicStateTester {
+public class ProcessingStateTest extends SupportBasicStateTester {
 
     private ProcessingState state;
     private HostBucket hostBucket;
 
 import org.onap.policy.drools.pooling.message.Offline;
 import org.onap.policy.drools.utils.Pair;
 
-public class QueryStateTest extends BasicStateTester {
+public class QueryStateTest extends SupportBasicStateTester {
 
     private QueryState state;
 
 
 import org.onap.policy.drools.utils.Pair;
 import org.onap.policy.drools.utils.Triple;
 
-public class StartStateTest extends BasicStateTester {
+public class StartStateTest extends SupportBasicStateTester {
 
     private StartState state;
 
 
 import org.onap.policy.drools.pooling.message.Offline;
 import org.onap.policy.drools.pooling.message.Query;
 
-public class StateTest extends BasicStateTester {
+public class StateTest extends SupportBasicStateTester {
 
     private State state;
 
 
 /**
  * Superclass used to test subclasses of {@link State}.
  */
-public class BasicStateTester {
+public class SupportBasicStateTester {
 
     protected static final long STD_HEARTBEAT_WAIT_MS = 10;
     protected static final long STD_REACTIVATE_WAIT_MS = STD_HEARTBEAT_WAIT_MS + 1;
     protected PoolingProperties props;
     protected State prevState;
 
-    public BasicStateTester() {
+    public SupportBasicStateTester() {
         super();
     }
 
 
 import org.onap.policy.drools.core.PolicyContainer;
 import org.onap.policy.drools.system.PolicyController;
 
-public class TestTransactionTest2 {
+public class TestTransactionAdditionalTest {
 
     private static final int MAX_SLEEP_COUNT = 3;
     private static final String EXPECTED = "expected exception";