Почему jeromq push send не прошел через промежуток времени

Я пытаюсь использовать шаблон push/pull с jeromq(0.3.2). В начале это работает хорошо. но через некоторое время. сторона push не отправляет сообщения и не блокируется там. Я не знаю почему. Я установил параметр sendTimeout и напечатал номер ошибки сокета zmq. это 35. Есть что-то, что я не замечаю? или другие подсказывают?

Спасибо!

Код толкающей стороны:

ZMQ.Context context = ZMQ.context(1);
ZMQ.Socket push4Topic = context.socket(ZMQ.PUSH);

private void init() {
        push4Topic.setTCPKeepAlive(1);
        push4Topic.setSendTimeOut(30000);
        push4Topic.bind(bindUrl);
}

public boolean send(String msg) {
        return push4Topic.send(msg);
}

private void destroy() {
        if (push4Topic != null) {
            push4Topic.close();
        }
        if (context != null) {
            context.term();
        }
        logger.info("destroy() socket destroied");
}

====

Я добавляю одну нитку монитора, отслеживающую сторону нажатия. затем я обнаружил это событие ZMQ_EVENT_DISCONNECTED. что это значит? у моего кода со стороны тяги есть проблемы?

0 ответов

Другие вопросы по тегам