Почему 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. что это значит? у моего кода со стороны тяги есть проблемы?