Class App Inherits Application

Const kEditClear = "&Delete"

Const kFileQuit = "&Quit"

Const kFileQuitShortcut = ""

EventHandler Sub Open() Const hostname = "192.168.2.70" Const port = 5672 Const exchange = "test" Const bindingkey = "test" Dim conn As New RabbitMQConnectionMBS If Not conn.NewTCPSocket Then MsgBox "Failed to create TCP socket" Return End If Dim status As Integer status = conn.OpenSocket(hostname, port) If status <> 0 Then MsgBox "Failed to open TCP socket" Return End If Dim r As RabbitMQRPCReplyMBS r = conn.LoginPlain("/", 0, 131072, 0, "test", "test") If Failed(r) Then Return Call conn.ChannelOpen(1) r = conn.RPCReply If Failed(r) Then Return Const channel = 1 Const passive = False Const durable = False Const exclusive = False Const autoDelete = True Dim arguments As Dictionary = Nil Log "QueueDeclare..." Dim QueueDeclareResult As Dictionary = conn.QueueDeclare(channel, "", passive, durable, exclusive, autoDelete, arguments) r = conn.RPCReply If Failed(r) Then Return Dim queuename As String = QueueDeclareResult.Value("queue") If queuename.Len = 0 Then Break // failed? Log "queuename: "+queuename Const consumerTag = "" Const noLocal = False Const noAck = False Dim QueueBindResult As Dictionary = conn.QueueBind(channel, queuename, exchange, bindingkey, arguments) r = conn.RPCReply If Failed(r) Then Return Dim BasicConsumeResult As Dictionary = conn.BasicConsume(channel, queuename, consumerTag, noLocal, noAck, exclusive, arguments) r = conn.RPCReply If Failed(r) Then Return While True Dim res As RabbitMQRPCReplyMBS dim envelope as RabbitMQEnvelopeMBS res = conn.ConsumeMessage(envelope, 0.01) If res.Type = res.ResponseTypeNormal Then Log "Delivery: "+Str(envelope.DeliveryTag) Log "Exchange: "+envelope.Exchange Log "Routingkey: "+envelope.Routingkey Dim properties As RabbitMQBasicPropertiesMBS = envelope.message.properties 'Dim Flags As Integer = properties.flags 'If BitwiseAnd(Flags, RabbitMQBasicPropertiesMBS.kFlagContentType) = RabbitMQBasicPropertiesMBS.kFlagContentType Then If properties.HasContentType Then Log "Content-type: "+Properties.ContentType Dim BodyString As String = envelope.Message.Body // fix text encoding If encodings.UTF8.IsValidData(BodyString) Then BodyString = DefineEncoding(BodyString, encodings.UTF8) Else BodyString = DefineEncoding(BodyString, encodings.ISOLatin1) End If Log "Body: "+BodyString End If end if app.DoEvents wend r = conn.ConnectionClose If Failed(r) Then Return End EventHandler

Function Failed(r as RabbitMQRPCReplyMBS) As Boolean If r = Nil Then Return True End If Select Case r.Type Case r.ResponseTypeNone Break Case r.ResponseTypeNormal Return False // okay Case r.ResponseTypeLibraryException MsgBox "Library error: "+Str(r.LibraryError)+" "+RabbitMQConnectionMBS.ErrorString(r.LibraryError) Return True Case r.ResponseTypeServerException Dim d As Dictionary = r.MethodDecoded Dim c As String = d.Lookup("ReplyCode", "") Dim t As String = d.Lookup("ReplyText", "") MsgBox "Server error "+c+": "+t If t = "" Then Break Return True end Select End Function

Sub Log(s as string) System.DebugLog s MainWindow.List.AddRow s End Sub

End Class

Class MainWindow Inherits Window

End Class

MenuBar MainMenuBar

MenuItem FileMenu = "&File"

MenuItem FileQuit = "#App.kFileQuit"

MenuItem EditMenu = "&Edit"

MenuItem EditUndo = "&Undo"

MenuItem EditSeparator1 = "-"

MenuItem EditCut = "Cu&t"

MenuItem EditCopy = "&Copy"

MenuItem EditPaste = "&Paste"

MenuItem EditClear = "#App.kEditClear"

MenuItem EditSeparator2 = "-"

MenuItem EditSelectAll = "Select &All"

End MenuBar