1 21 22 package org.jacorb.test.notification.engine; 23 24 import java.util.Collections ; 25 26 import junit.framework.Test; 27 import junit.framework.TestSuite; 28 29 import org.jacorb.notification.engine.AbstractFilterTask; 30 import org.jacorb.notification.engine.FilterConsumerAdminTask; 31 import org.jacorb.notification.interfaces.FilterStage; 32 33 37 public class FilterConsumerAdminTaskTest extends AbstractFilterTaskTestCase 38 { 39 private FilterConsumerAdminTask objectUnderTest_; 40 41 46 public FilterConsumerAdminTaskTest(String name) 47 { 48 super(name); 49 } 50 51 protected AbstractFilterTask newObjectUnderTest() 52 { 53 objectUnderTest_ = new FilterConsumerAdminTask(mockTaskFactory_, mockTaskExecutor_); 54 55 return objectUnderTest_; 56 } 57 58 public void testNoConsumerAdminConnected() throws Exception 59 { 60 mockMessage_.isInvalid(); 61 controlMessage_.setReturnValue(false); 62 mockMessage_.dispose(); 63 64 controlMessage_.replay(); 65 66 objectUnderTest_.setMessage(mockMessage_); 67 68 objectUnderTest_.run(); 69 70 controlMessage_.verify(); 71 } 72 73 public void testFilter() throws Exception 74 { 75 mockMessage_.isInvalid(); 76 controlMessage_.setDefaultReturnValue(false); 77 78 mockMessage_.match(mockFilterStage_); 79 controlMessage_.setReturnValue(true); 80 81 mockMessage_.dispose(); 82 83 controlMessage_.replay(); 84 85 objectUnderTest_.setMessage(mockMessage_); 86 87 mockFilterStage_.isDisposed(); 88 controlFilterStage_.setReturnValue(false); 89 90 mockFilterStage_.hasInterFilterGroupOperatorOR(); 91 controlFilterStage_.setReturnValue(false); 92 93 mockFilterStage_.getSubsequentFilterStages(); 94 controlFilterStage_.setReturnValue(Collections.singletonList(mockNextFilterStage_)); 95 96 controlFilterStage_.replay(); 97 98 mockTaskFactory_.newFilterProxySupplierTask(objectUnderTest_); 99 controlTaskFactory_.setReturnValue(mockSchedulable_); 100 101 controlTaskFactory_.replay(); 102 103 mockSchedulable_.schedule(); 104 controlSchedulable_.replay(); 105 106 objectUnderTest_.setCurrentFilterStage(new FilterStage[] { mockFilterStage_ }); 107 108 objectUnderTest_.run(); 109 110 controlFilterStage_.verify(); 111 controlMessage_.verify(); 112 controlTaskFactory_.verify(); 113 controlSchedulable_.verify(); 114 } 115 116 public static Test suite() 117 { 118 return new TestSuite(FilterConsumerAdminTaskTest.class); 119 } 120 } | Popular Tags |