public String getSource() {
        return source;
    }
@Test
    public void testExchangeDone() throws Exception {
        // START SNIPPET: e2
        // register the NotificationListener
        ObjectName on = getCamelObjectName(TYPE_EVENT_NOTIFIER, "JmxEventNotifier");
        MyNotificationListener listener = new MyNotificationListener();
        context.getManagementStrategy().getManagementAgent().getMBeanServer().addNotificationListener(on,
                listener,
                new NotificationFilter() {
                    private static final long serialVersionUID = 1L;

                    public boolean isNotificationEnabled(Notification notification) {
                        return notification.getSource().equals("MyCamel");
                    }
                }, null);

        // END SNIPPET: e2
        getMockEndpoint("mock:result").expectedMessageCount(1);

        template.sendBody("direct:start", "Hello World");

        assertMockEndpointsSatisfied();

        assertEquals(8, listener.getEventCounter(), "Get a wrong number of events");

        context.stop();
    }