public void testFireServiceAddedBeanContextServiceAvailableEvent() { MockBeanContextServicesSupport support = new MockBeanContextServicesSupport(); MockBeanContextServicesSupport childSupport = new MockBeanContextServicesSupport(); support.add(childSupport); MockBeanContextServicesListener l1 = new MockBeanContextServicesListener(); MockBeanContextServicesListener l2 = new MockBeanContextServicesListener(); support.addBeanContextServicesListener(l1); childSupport.addBeanContextServicesListener(l2); support.records.assertRecord("initialize", null); childSupport.records.assertRecord("initialize", null); BeanContextServiceAvailableEvent evt = new BeanContextServiceAvailableEvent( support, Collection.class); support.publicFireServiceAdded(evt); support.records.assertEndOfRecords(); childSupport.records.assertEndOfRecords(); assertSame(evt, l1.lastAvailableEvent); assertNull(l2.lastAvailableEvent); }
public void test_serviceAvailable_LBeanContextServiceRevokedEvent() { BeanContextServicesSupport support = new BeanContextServicesSupport(); support.add(new MySupport()); support.addBeanContextServicesListener(new MyListener()); Class c = Object.class; support.addService(c, new MyProvider()); BeanContextServiceAvailableEvent availableEvent = new BeanContextServiceAvailableEvent( support, c); support.serviceAvailable(availableEvent); assertEquals(0, serviceRevoked); assertEquals(2, serviceAvailable); }
private void assertEqualsSerially(BeanContextServiceAvailableEvent orig, BeanContextServiceAvailableEvent ser) { assertNull(ser.getSource()); // check propagatedFrom if (orig.getPropagatedFrom() instanceof Serializable) { BeanContext origFrom = orig.getPropagatedFrom(); BeanContext serFrom = ser.getPropagatedFrom(); assertEquals(origFrom.getClass(), serFrom.getClass()); if (origFrom instanceof MockBeanContextDelegateS) { assertEquals(((MockBeanContextDelegateS) origFrom).id, ((MockBeanContextDelegateS) serFrom).id); } } // check serviceClass assertEquals(orig.getServiceClass(), ser.getServiceClass()); }
/** * @param bcsae the BeanContextServiceAvailableEvent */ public void serviceAvailable(BeanContextServiceAvailableEvent bcsae) { // Get a reference to the context BeanContextServices context = bcsae.getSourceAsBeanContextServices(); // Use the service, if it's available if (context.hasService(TestCounter.class)) { // System.out.println("Attempting to use the service..."); try { // Got the service service = (TestCounter) context.getService(this, this, TestCounter.class, str, this); service.counter(); } catch (Exception e) { } this.bcsae = bcsae; } }
public void testAddServiceClassBeanContextServiceProvider_ParentContext() { MockBeanContextServicesSupport support = new MockBeanContextServicesSupport(); MockBeanContextServicesSupport childSupport = new MockBeanContextServicesSupport(); support.add(childSupport); MockBeanContextServicesListener l1 = new MockBeanContextServicesListener(); MockBeanContextServicesListener l2 = new MockBeanContextServicesListener(); support.addBeanContextServicesListener(l1); childSupport.addBeanContextServicesListener(l2); support.records.assertRecord("initialize", null); childSupport.records.assertRecord("initialize", null); MockBeanContextServiceProvider provider = new MockBeanContextServiceProvider(); boolean result = support.addService(Collection.class, provider); assertTrue(result); assertEquals(1, support.services().size()); assertEquals(0, childSupport.services().size()); Object bcssProvider = support.services().get(Collection.class); support.records.assertRecord("createBCSSServiceProvider", Collection.class, provider, bcssProvider); support.records.assertEndOfRecords(); BeanContextServiceAvailableEvent evt = (BeanContextServiceAvailableEvent) childSupport.records .getArg(0); childSupport.records.assertRecord("serviceAvailable", evt, null); assertSame(support, evt.getSourceAsBeanContextServices()); assertSame(Collection.class, evt.getServiceClass()); childSupport.records.assertEndOfRecords(); assertSame(support, l1.lastAvailableEvent .getSourceAsBeanContextServices()); assertSame(Collection.class, l1.lastAvailableEvent.getServiceClass()); assertSame(support, l2.lastAvailableEvent .getSourceAsBeanContextServices()); assertSame(Collection.class, l2.lastAvailableEvent.getServiceClass()); }
public void testBeanContextServiceAvailableEvent_NullParam() { BeanContextServices services = new MockBeanContextServices(); try { new MockBeanContextServiceAvailableEvent(null, BeanContext.class); fail("IAE expected"); } catch (IllegalArgumentException e) { // expected } BeanContextServiceAvailableEvent event = new MockBeanContextServiceAvailableEvent( services, null); assertNull(event.getServiceClass()); assertSame(services, event.getSource()); assertSame(services, event.getSourceAsBeanContextServices()); }
public void testBeanContextServiceAvailableEvent() { BeanContextServices services = new MockBeanContextServices(); BeanContextServiceAvailableEvent event = new MockBeanContextServiceAvailableEvent( services, BeanContext.class); assertSame(BeanContext.class, event.getServiceClass()); assertSame(services, event.getSource()); assertSame(services, event.getSourceAsBeanContextServices()); }
public void testGetSourceAsBeanContextServices() { BeanContextServices services = new MockBeanContextServices(); BeanContextServiceAvailableEvent event = new MockBeanContextServiceAvailableEvent( services, BeanContext.class); assertSame(services, event.getSource()); assertSame(services, event.getSourceAsBeanContextServices()); }
public void testGetCurrentServiceSelectors() { BeanContextServices services = new MockBeanContextServices(); BeanContextServiceAvailableEvent event = new MockBeanContextServiceAvailableEvent( services, BeanContext.class); Iterator expectedIt = services .getCurrentServiceSelectors(BeanContext.class); Iterator it = event.getCurrentServiceSelectors(); while (expectedIt.hasNext()) { assertSame(expectedIt.next(), it.next()); } assertFalse(expectedIt.hasNext()); assertFalse(it.hasNext()); }
public void testSerialization() throws IOException, ClassNotFoundException { BeanContextServiceAvailableEvent event = new BeanContextServiceAvailableEvent( new MockBeanContextServices(), ArrayList.class); event.setPropagatedFrom(new MockBeanContextDelegateS("from ID")); assertEqualsSerially(event, (BeanContextServiceAvailableEvent) SerializationTester .getDeserilizedObject(event)); }
public void testSerialization_Compatibility() throws Exception { BeanContextServiceAvailableEvent event = new BeanContextServiceAvailableEvent( new MockBeanContextServices(), ArrayList.class); event.setPropagatedFrom(new MockBeanContextDelegateS("from ID")); SerializationTest.verifyGolden(this, event, new SerializableAssert(){ public void assertDeserialized(Serializable orig, Serializable ser) { assertEqualsSerially((BeanContextServiceAvailableEvent) orig, (BeanContextServiceAvailableEvent) ser); } }); }
public void testSerialization_Compatibility() throws Exception { BeanContextServiceAvailableEvent event = new BeanContextServiceAvailableEvent( new MockBeanContextServices(), ArrayList.class); event.setPropagatedFrom(new MockBeanContextDelegateS("from ID")); assertEqualsSerially( event, (BeanContextServiceAvailableEvent) SerializationTester .readObject(event, "serialization/java/beans/beancontext/BeanContextServiceAvailableEvent.ser")); }
public void serviceAvailable(BeanContextServiceAvailableEvent p0) { return; }
public void publicFireServiceAdded(BeanContextServiceAvailableEvent evt) { fireServiceAdded(evt); }
@Override public void serviceAvailable(BeanContextServiceAvailableEvent bcssae) { super.serviceAvailable(bcssae); records.add("serviceAvailable", bcssae, null); }
public void testAddServiceClassBeanContextServiceProvider_Exist() { MockBeanContextServicesSupport support = new MockBeanContextServicesSupport(); MockBeanContextServicesSupport childSupport = new MockBeanContextServicesSupport(); support.add(childSupport); MockBeanContextServicesListener l1 = new MockBeanContextServicesListener(); MockBeanContextServicesListener l2 = new MockBeanContextServicesListener(); support.addBeanContextServicesListener(l1); childSupport.addBeanContextServicesListener(l2); support.records.assertRecord("initialize", null); childSupport.records.assertRecord("initialize", null); MockBeanContextServiceProvider provider = new MockBeanContextServiceProvider(); boolean result = support.addService(Collection.class, provider); assertTrue(result); assertEquals(1, support.services().size()); assertEquals(0, childSupport.services().size()); Object bcssProvider = support.services().get(Collection.class); support.records.assertRecord("createBCSSServiceProvider", Collection.class, provider, bcssProvider); support.records.assertEndOfRecords(); BeanContextServiceAvailableEvent evt = (BeanContextServiceAvailableEvent) childSupport.records .getArg(0); childSupport.records.assertRecord("serviceAvailable", evt, null); assertSame(support, evt.getSourceAsBeanContextServices()); assertSame(Collection.class, evt.getServiceClass()); childSupport.records.assertEndOfRecords(); assertSame(support, l1.lastAvailableEvent .getSourceAsBeanContextServices()); assertSame(Collection.class, l1.lastAvailableEvent.getServiceClass()); assertSame(support, l2.lastAvailableEvent .getSourceAsBeanContextServices()); assertSame(Collection.class, l2.lastAvailableEvent.getServiceClass()); l1.clearLastEvent(); l2.clearLastEvent(); // add exist MockBeanContextServiceProvider another = new MockBeanContextServiceProvider(); result = support.addService(Collection.class, another); assertFalse(result); support.records.assertEndOfRecords(); childSupport.records.assertEndOfRecords(); assertNull(l1.lastAvailableEvent); assertNull(l2.lastAvailableEvent); }
public void serviceAvailable(BeanContextServiceAvailableEvent event) { serviceAvailable++; }
public void testGetServiceClass() { BeanContextServices services = new MockBeanContextServices(); BeanContextServiceAvailableEvent event = new MockBeanContextServiceAvailableEvent( services, BeanContext.class); assertSame(BeanContext.class, event.getServiceClass()); }
public void serviceAvailable(BeanContextServiceAvailableEvent arg0) { support.serviceAvailable(arg0); }
public void serviceAvailable(BeanContextServiceAvailableEvent bcsae) { lastAvailableEvent = bcsae; }