from onestep import step
from onestep.broker import MemoryBroker

broker = MemoryBroker()
broker.queue.put("test")  # 模拟手动发一条消息


@step(from_broker=broker)
def step1(message):
    print(message.body)


step.start(block=True)