blob: 155b0323b3daab061bc806019e16e78fd4d0e90b [file] [log] [blame]
package org.apache.s4.processor;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNotNull;
import org.apache.s4.util.clock.WallClock;
import org.junit.Test;
public class TestPrototypeWrapper
{
/**
* Verifies ability to set an initialize method that will be called when
* a new PE is instantiated
*/
@Test
public void testCloneAndInitialize() {
MockPE prototype = new MockPE();
PrototypeWrapper prototypeWrapper = new PrototypeWrapper(prototype,
new WallClock());
assertEquals(0, prototype.getInitializeCount());
MockPE instance = (MockPE)prototypeWrapper.getPE("asd");
assertNotNull(instance);
assertEquals(0, prototype.getInitializeCount());
assertEquals(1, instance.getInitializeCount());
}
}