kiteq-client-go

kiteq/
├── README.md
├── log               конфигурация log4go
├── benchmark         Benchmark программы для KiteQ
├── client            клиент KiteQ

    Для KiteQClient требуется реализация слушателя сообщений, мы определили следующий интерфейс:
    type IListener interface {
        // Обработчик получения сообщения
        OnMessage(msg *protocol.StringMessage) bool
        // Обработчик транзакций
        // Все транзакции считаются неудачными, если они явно не были успешно завершены
        // Любое исключение или возврат значения false указывает на отсутствие подтверждения
        OnMessageCheck(tx *protocol.TxResponse) error
    }

    Запуск Producer:
        producer := client.NewKiteQClient(${zkhost}, ${groupId}, ${password}, &defaultListener{})
        producer.SetTopics([]string{"trade"})
        producer.Start()
        // Создание сообщения
        msg := &protocol.StringMessage{}
        msg.Header = &protocol.Header{
            MessageId:     proto.String(client.MessageId()),
            Topic:         proto.String("trade"),
            MessageType:   proto.String("pay-succ"),
            ExpiredTime:   proto.Int64(time.Now().Unix()),
            DeliveryLimit: proto.Int32(-1),
            GroupId:       proto.String("go-kite-test"),
            Commit:        proto.Bool(true)}
        msg.Body = proto.String("echo")
        // Отправка сообщения
        producer.SendStringMessage(msg)

    Запуск Consumer:
        consumer := client.NewKiteQClient(${zkhost}, ${groupId}, ${password}, &defaultListener{})
        consumer.SetBindings([]*binding.Binding{
            binding.Bind_Direct("s-mts-test", "trade", "pay-succ", 1000, true),
        })
        consumer.Start()