@Test void testEventListenerRegisteredOnInit() { verify(mockEventBus, never()).subscribe(any()); testSubject.afterPropertiesSet(); verify(mockEventBus).subscribe(any()); }
@Override public void afterPropertiesSet() { messageSource.subscribe(this::handle); }
OutboundEventMessageChannelAdapter implements InitializingBean { @Override public void afterPropertiesSet() { messageSource.subscribe(this::handle); } }
OutboundEventMessageChannelAdapter implements InitializingBean { @Override public void afterPropertiesSet() { messageSource.subscribe(this::handle); } OutboundEventMessageChannelAdapter(SubscribableMessageSource<EventMessage<?>> messageSource,
                                              MessageChannel channel);  OutboundEventMessageChannelAdapter(SubscribableMessageSource<EventMessage<?>> messageSource,
                                              MessageChannel channel, Predicate<? super EventMessage<?>> filter);  OutboundEventMessageChannelAdapter(SubscribableMessageSource<EventMessage<?>> messageSource,
                                              MessageChannel channel, Predicate<? super EventMessage<?>> filter,
                                              EventMessageConverter eventMessageConverter); }
OutboundEventMessageChannelAdapter implements InitializingBean { @Override public void afterPropertiesSet() { messageSource.subscribe(this::handle); } OutboundEventMessageChannelAdapter(SubscribableMessageSource<EventMessage<?>> messageSource,
                                              MessageChannel channel);  OutboundEventMessageChannelAdapter(SubscribableMessageSource<EventMessage<?>> messageSource,
                                              MessageChannel channel, Predicate<? super EventMessage<?>> filter);  OutboundEventMessageChannelAdapter(SubscribableMessageSource<EventMessage<?>> messageSource,
                                              MessageChannel channel, Predicate<? super EventMessage<?>> filter,
                                              EventMessageConverter eventMessageConverter); @Override void afterPropertiesSet(); }
OutboundEventMessageChannelAdapter implements InitializingBean { @Override public void afterPropertiesSet() { messageSource.subscribe(this::handle); } OutboundEventMessageChannelAdapter(SubscribableMessageSource<EventMessage<?>> messageSource,
                                              MessageChannel channel);  OutboundEventMessageChannelAdapter(SubscribableMessageSource<EventMessage<?>> messageSource,
                                              MessageChannel channel, Predicate<? super EventMessage<?>> filter);  OutboundEventMessageChannelAdapter(SubscribableMessageSource<EventMessage<?>> messageSource,
                                              MessageChannel channel, Predicate<? super EventMessage<?>> filter,
                                              EventMessageConverter eventMessageConverter); @Override void afterPropertiesSet();  }