Gniazdo ZeroMQ pub buforuje wszystkie moje dane wychodzące podczas łączenia

Zauważyłem, że gniazdo ZeroMQ pub buforuje wszystkie wychodzące dane, jeśli jest podłączone, na przykład

import zmq
import time
context = zmq.Context()

# create a PUB socket
pub = context.socket (zmq.PUB)
pub.connect("tcp://127.0.0.1:5566")
# push some message before connected
# they should be dropped
for i in range(5):
    pub.send('a message should not be dropped')

time.sleep(1)

# create a SUB socket
sub = context.socket (zmq.SUB)
sub.bind("tcp://127.0.0.1:5566")
sub.setsockopt(zmq.SUBSCRIBE, "")

time.sleep(1)

# this is the only message we should see in SUB
pub.send('hi')

while True:
    print sub.recv()

Sub wiąże się po tych wiadomościach, powinny one zostać porzucone, ponieważ PUB powinien upuszczać wiadomości, Jeśli nikt się z nimi nie połączy. Ale zamiast upuszczać wiadomości, buforuje wszystkie wiadomości.

a message should not be dropped
a message should not be dropped
a message should not be dropped
a message should not be dropped
a message should not be dropped
hi

Jak widać, te "wiadomość nie powinna być upuszczona" są buforowane przez gniazdo, po podłączeniu przepuszcza je do gniazda podrzędnego. Jeśli zwiążę w pubie gniazdo i podłącz do gniazda SUB, a następnie działa poprawnie.

import zmq
import time
context = zmq.Context()

# create a PUB socket
pub = context.socket (zmq.PUB)
pub.bind("tcp://127.0.0.1:5566")
# push some message before connected
# they should be dropped
for i in range(5):
    pub.send('a message should not be dropped')

time.sleep(1)

# create a SUB socket
sub = context.socket (zmq.SUB)
sub.connect("tcp://127.0.0.1:5566")
sub.setsockopt(zmq.SUBSCRIBE, "")

time.sleep(1)

# this is the only message we should see in SUB
pub.send('hi')

while True:
    print repr(sub.recv())

I możesz zobaczyć tylko wyjście

'hi'

Tego rodzaju dziwne zachowanie powoduje problem, buforuje wszystkie dane na gniazdku łączącym, mam dwa serwery, serwer a publikuje dane na serwerze B

Server A -- publish --> Server B

Działa dobrze, jeśli serwer B zostanie włączony. Ale co jeśli uruchomię serwer A i nie uruchomię serwera B?

W rezultacie podłączenie gniazda PUB na serwerze a przechowuje wszystkie te dane, zużycie pamięci wzrasta i wyżej.

Tu jest problem, czy takie zachowanie to błąd czy funkcja? Jeśli jest to funkcja, gdzie mogę znaleźć dokument, który wspomina o tym zachowaniu? I jak Mogę zatrzymać łączenie pub socket buforuje wszystkie dane?