Ich untersuche mit ActiveMQ als eingebettete in-Prozess-Nachrichtenwarteschlange in meiner Anwendung, aber ich bin ein bisschen fest, wie ich gehe über eine solche Anwendung starten. Ich sehe es wie so (Pseudo-Code, natürlich):In-Prozess ActiveMQ Produzent/Verbraucher Beispiel?
configureBroker()
broker.start()
createProducer (broker)
producer.start()
for each desired consumer
createConsumer (broker)
consumer.start()
waitForSignal()
signalProducerShutdown()
waitForEmptyQueues()
signalConsumerShutdown()
broker.stop()
Ich habe versucht, eine einfache Version davon zu montieren, aber ich bin fest, wie die Produzenten und Konsumenten so schreiben, wie um sie für immer arbeiten zu lassen, oder bis gesagt, um zu beenden. Was ist der beste Weg, dies zu tun? Ich spreche speziell über den Threading-Aspekt; Was brauche ich/möchte ich in einem eigenen Thread spawnen?
Ich bin völlig neu in Nachrichtenwarteschlangen-basierten Anwendungen, also seien Sie bitte ausführlich mit Ihren Beispielen.