.NET (Core and Framework)

Private Sub StartRouter(ByVal myNode As XmlNode)
    Try
        m_RouterQueueName = myNode.Attributes("queuename").Value
        TheRouter = New Router(m_RouterQueueName)
        AddHandler TheRouter.onRouterStarted, AddressOf LogActivity
        AddHandler TheRouter.onRouterMessageReceived, AddressOf LogActivity
        AddHandler TheRouter.onRouterError, AddressOf LogError
    Catch ex As Exception
        LogError(ex)
    End Try

End Sub

Public Sub New(ByVal QueueName As String)
       Try
           m_QueueName = QueueName
           StartListening()
       Catch ex As Exception
           RaiseEvent onRouterError(ex)
       End Try
   End Sub

Private Sub StartListening()
    myReceiveQueue = New MessageQueue(m_QueueName, QueueAccessMode.SendAndReceive, False, QueueAccessMode.SendAndReceive)
    Try
        'myReceiveQueue = New MessageQueue()
        'myReceiveQueue.Path = m_QueueName
        myReceiveQueue.Formatter = New XmlMessageFormatter(New Type() {GetType(System.String)})
        myReceiveQueue.UseJournalQueue = True
        RaiseEvent onRouterStarted("Router listening to " & m_QueueName, "Started")
        AddHandler myReceiveQueue.ReceiveCompleted, AddressOf MSMQ_ReceiveCompleted
        myResult = myReceiveQueue.BeginReceive()
    Catch ex As Exception
        RaiseEvent onRouterError(ex)
    End Try
End Sub

Private Sub SpawnProcessors(ByVal myNode As XmlNode)
    Try
        For Each childnode As XmlNode In myNode
            Dim myNewProcessor As New Processor(childnode)
            AddHandler myNewProcessor.onProcessorStarted, AddressOf LogActivity
            AddHandler myNewProcessor.onProcessorError, AddressOf LogError
            AddHandler myNewProcessor.onProcessorMessageReceived, AddressOf LogActivity
            ProcessorCollection.Add(myNewProcessor)
        Next

        ' once we've been through all the processors and started them all, introduce this list to the router
        TheRouter.IntroduceProceduresToRouter(ProcessorCollection)
    Catch ex As Exception
        LogError(ex)
    End Try
End Sub

Public Sub IntroduceProceduresToRouter(ByVal myList As List(Of Processor))
     m_KnownProcesses = myList
 End Sub

Public Sub New(ByVal myNode As XmlNode)
    Try
        Config = myNode
        m_QueueName = myNode.Attributes("queuename").Value
        m_Type = myNode.Attributes("processtype").Value
        StartListening()

    Catch ex As Exception
        RaiseEvent onProcessorError(ex)
    End Try
End Sub

Private Sub StartListening()
    Try
        myProcQueue = New MessageQueue(m_QueueName, False, False, QueueAccessMode.SendAndReceive)
        myProcQueue.Formatter = New XmlMessageFormatter(New Type() {GetType(System.String)})
        myProcQueue.UseJournalQueue = True
        RaiseEvent onProcessorStarted("Processor listening to " & m_QueueName, "Started")
        AddHandler myProcQueue.ReceiveCompleted, AddressOf MSMQ_ReceiveCompleted
        myResult = myProcQueue.BeginReceive()
    Catch ex As Exception
        RaiseEvent onProcessorError(ex)
    End Try
End Sub

Private Sub MSMQ_ReceiveCompleted(ByVal p_source As Object, ByVal p_objAsyncResult As ReceiveCompletedEventArgs)
     Try
         Dim myMessage As Message
         myMessage = myReceiveQueue.EndReceive(p_objAsyncResult.AsyncResult)
         RaiseEvent onRouterMessageReceived("Router", "New message Received in Router Queue" & Chr(13) & myMessage.ToString)
         RouteMessage(myMessage)
         myResult = myReceiveQueue.BeginReceive()
     Catch ex As Exception
         RaiseEvent onRouterError(ex)
     End Try
 End Sub

Private Sub RouteMessage(ByVal msgToProcess As Message)
      Try
          ' get the XML from the body of the message
          Dim xmlDoc As New Xml.XmlDocument
          xmldoc.LoadXml(msgToProcess.Body)
          Dim myNode As XmlNode
          myNode = xmlDoc.SelectSingleNode("descendant::process")

          ' read the first child to determine what the next process is
          Dim NextAction As String
          NextAction = myNode.ChildNodes(0).Attributes("type").Value

          For Each SingleProcess As Processor In m_KnownProcesses
              If NextAction = SingleProcess.Config.Attributes("processtype").Value Then
                  'Dim myQueue As New MessageQueue(SingleProcess.myProcQueue.Path)
                  '                    myQueue.Send(myNode.OuterXml)
                  SingleProcess.myProcQueue.Send("Test Message")
                  'myQueue.Send("Test Message")
                  'myQueue = Nothing
                  'SingleProcess.myProcQueue.Send(myNode.OuterXml)
                  Exit For
              End If
          Next
      Catch ex As Exception
          RaiseEvent onRouterError(ex)
      End Try
  End Sub