Merge branch 'master' of github.com:adymitruk/goes
This commit is contained in:
commit
e912ee597f
|
@ -4,7 +4,7 @@ import (
|
||||||
"fmt"
|
"fmt"
|
||||||
"github.com/pebbe/zmq4"
|
"github.com/pebbe/zmq4"
|
||||||
"github.com/satori/go.uuid"
|
"github.com/satori/go.uuid"
|
||||||
"bitbucket.org/nicdex/adaptech-goes"
|
"github.com/adymitruk/goes"
|
||||||
"bytes"
|
"bytes"
|
||||||
"errors"
|
"errors"
|
||||||
"flag"
|
"flag"
|
||||||
|
@ -151,4 +151,4 @@ func sendEvents(socket *zmq4.Socket, events []*goes.Event) {
|
||||||
}
|
}
|
||||||
socket.SendBytes(events[i].Payload.([]byte), 0)
|
socket.SendBytes(events[i].Payload.([]byte), 0)
|
||||||
fmt.Println("<-", len, "events")
|
fmt.Println("<-", len, "events")
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue
Block a user