J'ai fait un petit service me permettant de récupérer un ensemble de message dans une fil activemq. Pour cela j'utilise la librairie stomp.py. je rencontre un soucis voici le message :
Code : Sélectionner tout - Visualiser dans une fenêtre à part
1
2
3
 
Une exception non geree a ete rencontree dans la boucle du recepteur Stomp
Detail Erreur: (<class 'stomp.ConnectionClosedException'>, ConnectionClosedException(), <traceback object at 0x3>)
voici la fonction dans lequel se trouve cette boucle :
Code : Sélectionner tout - Visualiser dans une fenêtre à part
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
 
    def __receiver_loop(self):
        """
        Main loop listening for incoming data.
        """
        try:
            try:
                threading.currentThread().setName("StompReceiver")
                while self.__running:
                    log.debug('starting receiver loop')
 
                    if self.__socket is None:
                        break
 
                    try:
                        try:
                            self.__notify('connecting')
 
                            while self.__running:
                                frames = self.__read()
 
                                for frame in frames:
                                    (frame_type, headers, body) = self.__parse_frame(frame)
                                    log.debug("Received frame: result=%r, headers=%r, body=%r" % (frame_type, headers, body))
                                    frame_type = frame_type.lower()
                                    if frame_type in [ 'connected', 'message', 'receipt', 'error' ]:
                                        self.__notify(frame_type, headers, body)
                                    else:
                                        log.warning('Unknown response frame type: "%s" (frame length was %d)' % (frame_type, len(frame)))
                        finally:
                            try:
                                self.__socket.close()
                            except:
                                pass # ignore errors when attempting to close socket
                            self.__socket = None
                            self.__current_host_and_port = None
                    except ConnectionClosedException():
                        if self.__running:
                            log.error("Lost connection")
                            self.__notify('disconnected')
                            #
                            # Clear out any half-received messages after losing connection
                            #
                            self.__recvbuf = ''
                            continue
                        else:
                            break
            except:
                log.exception("Une exception non geree a ete rencontree dans la boucle du recepteur Stomp")
		print "Detail Erreur:", sys.exc_info()
 
        finally:
            self.__receiver_thread_exit_condition.acquire()
            self.__receiver_thread_exited = True
            self.__receiver_thread_exit_condition.notifyAll()
            self.__receiver_thread_exit_condition.release()
quelqu'un a t il une idee ?