Visual Basic Code Example: Matching Acknowledgment Messages
Applies To: Windows 10, Windows 7, Windows 8, Windows 8.1, Windows Server 2008, Windows Server 2008 R2, Windows Server 2012, Windows Server 2012 R2, Windows Server Technical Preview, Windows Vista
This example provides two Sub procedures: a private Sub procedure that searches an administration queue for the acknowledgment message that was returned as a result of sending a specific message, and a second helper procedure that is used to compare two variants.
This example assumes that the message was sent to a single destination queue, so it compares only the returned message identifier in the MSMQMessage.CorrelationId property of the acknowledgment message to the cached identifier of the message that was sent. For details on other information that is returned in the message properties of an acknowledgment message, see Acknowledgment Message Properties.
Note
For cases where the original message was sent to multiple destination queues, this example would need to be modified so that it compares the returned message identifier (MSMQMessage.CorrelationId) and the returned destination queue (MSMQMessage.ResponseQueueInfo) to the cached message identifier and destination queue respectfully. Both pieces of information need to be compared because messages sent to multiple destination queues all have the same message identifier.
To match acknowledgment messages
- Declare the objects needed to read the messages in the administration queue.
Note
When declaring the MSMQMessage object when reading messages, you cannot use the New keyword.
Create a direct format name for the queue using the computer and queue name provided by the caller.
Set the MSMQQueueInfo.FormatName property.
Call MSMQQueueInfo.Open to open the queue with receive access. When opening a queue with receive access the application can peek at or retrieve the messages in the queue.
Call MSMQQueue.PeekCurrent to initialize the cursor. This call points the cursor to the first message in the queue.
Using a loop, call VariantCompare to compare the correlation identifier of each acknowledgment message with the message identifier provided by the caller.
When there are no messages left, call MSMQQueue.Close to release resources used to open queue and exit the Sub procedure.
Code Example
The following code example can be run on all versions of Message Queuing.
' A function that compares between two variants.
Function VariantsCompare( _
var1 As Variant, _
var2 As Variant _
) As Boolean
' Check if the variants have the same bounds.
If LBound(var1) = LBound(var2) And UBound(var1) = UBound(var2) Then
' Compare the variants byte-by-byte.
For Counter = LBound(var1) To UBound(var2)
If Not var1(Counter) = var2(Counter) Then
VariantsCompare = False
Exit Function
End If
Next Counter
VariantsCompare = True
Else
VariantsCompare = False
End If
End Function
Private Sub MatchAcknowledgments(strQueueName As String, strComputerName As String, msgReg As MSMQMessage))
' Declare variables.
Dim strFormatName As String
Dim q As MSMQQueue
Dim qinfo As New MSMQQueueInfo
Dim msgAck As MSMQMessage
' Create a direct format name.
strFormatName = "DIRECT=OS:" & strComputerName & "\" & strQueueName
' Set the format name of the MSMQQueueInfo object.
On Error GoTo ErrorHandler
qinfo.FormatName = strFormatName
' Open the queue with receive access.
Set q = qinfo.Open(Access:=MQ_RECEIVE_ACCESS, ShareMode:=MQ_DENY_NONE)
' Peek at messages in the queue using the cursor, and look for the requested acknowledgment.
Set msgAck = q.PeekCurrent(ReceiveTimeout:=1000)
Do While Not msgAck Is Nothing
' Compare between the identifier of the given message and the
' correlation ID of the peeked at message.
If VariantsCompare(msgAck.CorrelationId, msgReg.Id) Then
MsgBox "An acknowledgment message was found.", , "Message: " & msgAck.Label
Exit Do
Else
Set msgAck = q.PeekNext(ReceiveTimeout:=1000)
End If
Loop
' If all the messages were peeked at, and no acknowledgment was found.
If msgAck Is Nothing Then
MsgBox "An acknowledgment message was not found."
End If
' Close the queue.
q.Close
Exit Sub
ErrorHandler:
MsgBox "Error " + Hex(Err.Number) + " was returned." _
+ Chr(13) + Err.Description
If Not q Is Nothing And q.IsOpen2 Then
q.Close
EndIf
End Sub