Imports IBM.WMQ
Imports System.Text

Module Module1
    Const HOST_NAME As String = "localhost"
    Const PORT As Integer= 1414
    Const QUEUE_MANAGER_NAME = "QM_APPLE"
    Const CHANNEL_NAME = "QM_ORANGE.QM_APPLE"
    Const QUEUE_NAME = "Q1"
    Const MESSAGE = "Hello World."
    
    Sub Main()
        ' キューへの接続情報
        Dim properties As New Hashtable()
        properties.Add(MQC.HOST_NAME_PROPERTY, HOST_NAME)
        properties.Add(MQC.PORT_PROPERTY, PORT)
        properties.Add(MQC.CHANNEL_PROPERTY, CHANNEL_NAME)
        Try
            Dim qMan = New MQQueueManager(QUEUE_MANAGER_NAME)
            Dim openOptions As Integer = MQC.MQOO_INPUT_AS_Q_DEF + MQC.MQOO_OUTPUT
            Dim queue = qMan.AccessQueue(QUEUE_NAME, openOptions)
            ' 送信処理
            Dim sendMessage = Encoding.UTF8.GetBytes(MESSAGE & Date.Now.ToString())
            Dim sendMQMessage As MQMessage = New MQMessage()
            sendMQMessage.Write(sendMessage)
            queue.Put(sendMQMessage)
            ' 受信処理
            Dim receiveMQMessage As MQMessage = New MQMessage()
            queue.Get(receiveMQMessage)
            Dim receiveMessage = Encoding.UTF8.GetString(receiveMQMessage.ReadBytes(receiveMQMessage.MessageLength))
            Console.WriteLine(receiveMessage)
        Catch e As Exception
            ' Do something
        End Try
    End Sub
End Module