Skip to content
KubeMQ - MSMQ Connector Demo
C# Other
  1. C# 98.9%
  2. Other 1.1%
Branch: master
Clone or download
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Permalink
Type Name Latest commit message Commit time
Failed to load latest commit information.
Client
Server
.gitignore
README.md

README.md

kubemq_msmq_demo

Kubemq.msmsq.sdk example use case, the upgrade to .Net Core when legacy code still depends on MSMQ.

Getting Started

This demo includes three main components

  • msmq_generator(.Net) - representing the unchanged legacy code - MSMQ message generator running on windows server.
  • kubemq_msmq_worker(.Net) - KubeMQ connector, performs as a bridge between KubeMQ and .Net, running on windows server.
  • kubemq_msmq_receiver - represents an upgraded .Net Core process communicating with the msmq_generator(.Net) using KubeMQ

Prerequisites

  • Kubernetes environment or docker orchestration
  • Windows server .net with MSMQ queues ".\private$\raqueue", ".\private$\receiver"
  • KubeMQ running with port forward access to GRPC_PORT and REST_PORT

Installing

Windows server: Configure MSMQ queues ".\private$\raqueue", ".\private$\receiver" run kubemq_msmq_rates_generator configure kubme_msmq_worker appsettings.json and run

"KubeMQ": {
    "ChannelName": "MsDemo.KubeMQ.0", //equal to the SDK
    "Timeout": 10000, //RPC timout
    "Address": "104.47.142.90:50000", //KubmeMQ GRPC_PORT 
    "GroupName": ""//fill if more then one in round robing pattern
  }

Docker: Deploy KubeMQ from kubemq.io (https://account.kubemq.io/home/get-kubemq/kubernetes)

Deploy client container kubemq/kubemq_msmq_client

docker pull kubemq/kubemq_msmq_client

Deploy kubemq_msmq_receiver

docker pull kubemq/msmq_receiver

msmq_receiver has some environment variable to communicate with kubme_msmq_worker

 Environment:
      KUBEMQSCHANNEL:       MsDemo.KubeMQ.0
      KUBEMQTIMEOUT:        10000
      KubeMQServerAddress:  104.47.142.90:50000

login to kubemq_msmq_client

You can’t perform that action at this time.