Stock Quote Flow

gistfile1.xml

<flow name="main">
        <zeromq:inbound-endpoint address="tcp://*:9090" socket-operation="bind"
                                 exchange-pattern="request-response"/>
        <protobuf:deserialize
                protobufClass="com.acmesoft.stock.model.serialization.protobuf.StockQuoteRequestBuffer"/>
        <expression-transformer
                expression="com.acmesoft.stock.model.StockQuoteRequest.fromProtocolBuffer(payload)"/>
        <component class="com.acmesoft.stock.service.StockDataServiceImpl"/>
        <expression-transformer
                expression="return com.acmesoft.stock.model.StockQuote.toProtocolBuffer(payload)"/>
    </flow>