Discussion :

[magic.goby]

Bonjour,

Je suis actuellement en train de faire un programme permettant de lire dans une queue activeMQ.

Ce programme est en VB.net (2008) et j'utilise NMS pour accèder à activeMQ, toutefois j'ai un souci, car lorsque je donne une instruction receive, je reçoit bien un message, mais a queue passe à zéro, je perd donc les autre messages.

Voici le code utilisé:

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
 
Private Sub Button1_Click(ByVal sender As System.Object, ByVal e As System.EventArgs) Handles Button1.Click
       connectionfactory = New ConnectionFactory(monURI)
 
        connection = connectionfactory.CreateConnection
        connection.Start()
 
        session = connection.CreateSession(AcknowledgementMode.AutoAcknowledge)
 
        mQueue = New ActiveMQQueue(MyQueueName)
 
        consumer = session.CreateConsumer(mQueue)
 
        Dim message As IMessage = Nothing
        message = consumer.Receive()
 
        If Not message Is Nothing Then
            TextBox1.Text = TextBox1.Text & message.Properties("Text") & vbCrLf
        End If
 
        consumer.Close()
        session.Close()
        connection.Close()
    End Sub

Merci d'avance pour votre aide.

[magic.goby]

J'ai trouvé la solution,

il ne faut pas utiliser le mode d'acknowledge par défaut mais passer en clientAcknowledge et acquitter les messages dans le code au fur et à mesure.

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

session = connection.CreateSession(AcknowledgementMode.ClientAcknowledge)

puis

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

message.Acknowledge()