1 21 22 package org.jacorb.test.notification.engine; 23 24 import junit.framework.Test; 25 import junit.framework.TestSuite; 26 27 import org.jacorb.notification.engine.AbstractFilterTask; 28 import org.jacorb.notification.engine.FilterProxySupplierTask; 29 import org.jacorb.notification.interfaces.FilterStage; 30 31 35 public class FilterProxySupplierTaskTest extends AbstractFilterTaskTestCase 36 { 37 private FilterProxySupplierTask objectUnderTest_; 38 39 43 public FilterProxySupplierTaskTest(String name) 44 { 45 super(name); 46 } 47 48 protected AbstractFilterTask newObjectUnderTest() 49 { 50 objectUnderTest_ = new FilterProxySupplierTask(mockTaskFactory_, mockTaskExecutor_); 51 52 return objectUnderTest_; 53 } 54 55 56 public void testFilter() throws Exception 57 { 58 mockMessage_.isInvalid(); 59 controlMessage_.setDefaultReturnValue(false); 60 61 mockMessage_.match(mockFilterStage_); 62 controlMessage_.setReturnValue(false); 63 64 mockMessage_.dispose(); 65 controlMessage_.replay(); 66 objectUnderTest_.setMessage(mockMessage_); 67 68 mockFilterStage_.isDisposed(); 69 controlFilterStage_.setDefaultReturnValue(false); 70 71 mockFilterStage_.hasPriorityFilter(); 72 controlFilterStage_.setDefaultReturnValue(false); 73 74 mockFilterStage_.hasLifetimeFilter(); 75 controlFilterStage_.setDefaultReturnValue(false); 76 77 controlFilterStage_.replay(); 78 79 mockTaskFactory_.enqueueMessage(objectUnderTest_); 80 controlTaskFactory_.replay(); 81 82 84 objectUnderTest_.setCurrentFilterStage(new FilterStage[] {mockFilterStage_}); 85 86 objectUnderTest_.run(); 87 88 90 controlMessage_.verify(); 91 92 controlFilterStage_.verify(); 93 controlTaskFactory_.verify(); 94 } 95 96 public static Test suite() 97 { 98 return new TestSuite(FilterProxySupplierTaskTest.class); 99 } 100 } 101 | Popular Tags |