Examples of whitewerx.com.trapos.gateway.TextMessageGateway

whitewerx.com.trapos.gateway.TextMessageGateway
This is a text gateway that accepts messages line by line. It is implemented using Netty. @author ewhite

        SequenceBarrier positionBarrier = ringBuffer.newBarrier(tradeProcessor.getSequence(),
                rateProcessor.getSequence());
        EventProcessor portfolioPositionProcessor = createPortfolioPositionProcessor(ringBuffer, positionBarrier);
        
        // Netty Event Publisher
        TextMessageGateway gateway = createGatewayEventPublisher(ringBuffer);


        // The producer can't move past this barrier.
        ringBuffer.setGatingSequences(tradeProcessor.getSequence(), rateProcessor.getSequence(),
                portfolioPositionProcessor.getSequence());

View Full Code Here

     * @param ringBuffer
     * @return
     */
    private TextMessageGateway createGatewayEventPublisher(RingBuffer<MarketEvent> ringBuffer) {
        MarketEventPublisher eventPublisher = new MarketEventPublisher(new RingBufferAdapter<MarketEvent>(ringBuffer));
        TextMessageGateway gateway = new TextMessageGateway(eventPublisher, this);
        return gateway;
    }

View Full Code Here

TOP

Related Classes of whitewerx.com.trapos.gateway.TextMessageGateway

org.jboss.netty.bootstrap.ServerBootstrap

org.jboss.netty.channel.Channel

org.jboss.netty.channel.ChannelPipeline

org.jboss.netty.channel.ChannelPipelineFactory

org.jboss.netty.channel.group.ChannelGroupFuture

org.jboss.netty.channel.socket.nio.NioServerSocketChannelFactory

org.jboss.netty.handler.codec.frame.DelimiterBasedFrameDecoder

org.jboss.netty.handler.codec.string.StringDecoder

whitewerx.com.trapos.App

whitewerx.com.trapos.ShutdownListener

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.