service

import org.springframework.beans.factory.InitializingBean
import org.zeromq.ZMQ

class ParseService implements InitializingBean {
    def pullSocket
    def pubSocket
    
    def running = true
    def pollingRate = 200
    
    void afterPropertiesSet() {
        def ctx = ZMQ.context(1)
        pullSocket = ctx.socket(ZMQ.PULL)
        pullSocket.connect("tcp://xxx:5000")
        
        pubSocket = ctx.socket(ZMQ.PUB)
        pubSocket.bind("tcp://127.0.0.1:5000")
        
        scannerThread = new Thread() {
            while(running) {
                def buff = pullSocket.recv(0)
                process(buff)
                try {
                    Thread.sleep(pollingRate)                    
                } catch (e) {}
            }
        }
        
        scannerThread.start()
    }
    
    def process(byte[] buff) {
        // first 10 bytes is id
        
        // rest is stream
        
        def type = ....
        
        pubSocket.send("${id}:${type}".bytes, 0)
    }
}