Package org.apache.karaf.cellar.core.event

Examples of org.apache.karaf.cellar.core.event.EventConsumer.stop()

126
127
128
129
130
131
132
133
134
135
136
                listGroups().put(groupName, group);
            }
            // shutdown the group consumer/producers
            for (Map.Entry<String, EventConsumer> consumerEntry : groupConsumer.entrySet()) {
                EventConsumer consumer = consumerEntry.getValue();
                consumer.stop();
            }
            groupConsumer.clear();
            groupProducers.clear();
        } finally {
            Thread.currentThread().setContextClassLoader(originalClassLoader);
View Full Code Here
468
469
470
471
472
473
474
475
476
477
478
            // remove consumers & producers
            groupProducers.remove(groupName);
            EventConsumer consumer = groupConsumer.remove(groupName);
            if (consumer != null) {
                consumer.stop();
            }

            // remove group from configuration
            try {
                Configuration configuration = configurationAdmin.getConfiguration(Configurations.NODE);
View Full Code Here
208
209
210
211
212
213
214
215
216
217
218
        registration.unregister();

        producers.remove(endpoint.getId());
        EventConsumer consumer = consumers.remove(endpoint.getId());
        if (consumer != null) {
            consumer.stop();
        }
    }

    public BundleContext getBundleContext() {
        return bundleContext;
View Full Code Here
71
72
73
74
75
76
77
78
79
80
81
    public void destroy() {
        bundleContext.removeServiceListener(this);
        for (Map.Entry<String, EventConsumer> consumerEntry : consumers.entrySet()) {
            EventConsumer consumer = consumerEntry.getValue();
            consumer.stop();
        }
        consumers.clear();
    }

    @Override
View Full Code Here
174
175
176
177
178
179
180
181
182
183
184
                    if (endpointDescription.getNodes().size() > 0) {
                        remoteEndpoints.put(endpointId, endpointDescription);
                    }

                    EventConsumer eventConsumer = consumers.remove(endpointId);
                    eventConsumer.stop();
                }
            }
        } finally {
            Thread.currentThread().setContextClassLoader(originalClassLoader);
        }
View Full Code Here
69
70
71
72
73
74
75
76
77
78
79
            ServiceRegistration registration = entry.getValue();
            registration.unregister();
        }
        for (Map.Entry<String, EventConsumer> consumerEntry : consumers.entrySet()) {
            EventConsumer consumer = consumerEntry.getValue();
            consumer.stop();
        }
        consumers.clear();
        producers.clear();
    }
View Full Code Here
70
71
72
73
74
75
76
77
78
79
80
            ServiceRegistration registration = entry.getValue();
            registration.unregister();
        }
        for (Map.Entry<String, EventConsumer> consumerEntry : consumers.entrySet()) {
            EventConsumer consumer = consumerEntry.getValue();
            consumer.stop();
        }
        consumers.clear();
        producers.clear();
    }
View Full Code Here
208
209
210
211
212
213
214
215
216
217
218
        registration.unregister();

        producers.remove(endpoint.getId());
        EventConsumer consumer = consumers.remove(endpoint.getId());
        if (consumer != null) {
            consumer.stop();
        }
    }

    public BundleContext getBundleContext() {
        return bundleContext;
View Full Code Here
71
72
73
74
75
76
77
78
79
80
81
    public void destroy() {
        bundleContext.removeServiceListener(this);
            for(Map.Entry<String,EventConsumer> consumerEntry:consumers.entrySet()) {
                EventConsumer consumer = consumerEntry.getValue();
                consumer.stop();
            }
            consumers.clear();
    }

    @Override
View Full Code Here
174
175
176
177
178
179
180
181
182
183
184
                    if(endpointDescription.getNodes().size() > 0) {
                        remoteEndpoints.put(endpointId,endpointDescription);
                    }

                    EventConsumer eventConsumer = consumers.remove(endpointId);
                    eventConsumer.stop();
                }
            }
        } finally {
            Thread.currentThread().setContextClassLoader(originalClassLoader);
        }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.