We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents 50c5636 + ac0dd06 commit 08b3f66Copy full SHA for 08b3f66
moksha.hub/moksha/hub/stomp/protocol.py
@@ -102,7 +102,7 @@ def error(self, msg):
102
super(StompProtocol, self).error(msg)
103
log.error("Requesting shutdown of hub for STOMP error.")
104
reactor.callLater(0, self.client.hub.close)
105
- reactor.callLater(0, reactor.close)
+ reactor.callLater(0, reactor.stop)
106
107
def ack(self, msg):
108
""" Override stomper's own ack to be smarter, based on mode. """
0 commit comments