<gh_stars>1-10
"""
Sponge Knowledge Base
Camel integration
"""

from java.util.concurrent.atomic import AtomicBoolean

def onInit():
    # Variables for assertions only
    sponge.setVariable("sentCamelMessage", AtomicBoolean(False))

class CamelTrigger(Trigger):
    def onConfigure(self):
        self.withEvent("spongeProducer")
    def onRun(self, event):
        print event.body
        sponge.getVariable("sentCamelMessage").set(True)

"""
Sponge Knowledge Base
Camel integration
"""

from java.util.concurrent.atomic import AtomicBoolean

def onInit():
    # Variables for assertions only
    sponge.setVariable("sentCamelMessage", AtomicBoolean(False))

class CamelTrigger(Trigger):
    def onConfigure(self):
        self.withEvent("spongeProducer")
    def onRun(self, event):
        print event.body
        sponge.getVariable("sentCamelMessage").set(True)
Sponge Knowledge Base
 Camel integration # Variables for assertions only