Продолжение поста IBM MQ automatic client reconnection to multi-instance queue manager.
Продолжение поста IBM MQ automatic client reconnection to multi-instance queue manager.
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 |
Connection parameters: TcsMQConnectionParams connectionParams = new TcsMQConnectionParams { Host = "mq-test01", Port = 1414, Channel = "CHN.T01", ManagerName = "QM1", TopicString = "/Cards/Events" }; Connection to topic - simple example: public sealed class WebSphereListenerService { private IConnection _connection; private ISession _session; private IDestination _destination; private IMessageConsumer _consumer; private readonly TcsMQConnectionParams _connectionParameters; private IConnectionFactory _connectionFactory; public WebSphereListenerService(TcsMQConnectionParams connectionParameters) { _connectionParameters = connectionParameters; } public void Start() { // Create the connection factories factory var factoryFactory = XMSFactoryFactory.GetInstance(XMSC.CT_WMQ); // Use the connection factories factory to create a connection factory _connectionFactory = factoryFactory.CreateConnectionFactory(); // Set the properties _connectionFactory.SetStringProperty(XMSC.WMQ_HOST_NAME, _connectionParameters.Host); _connectionFactory.SetIntProperty(XMSC.WMQ_PORT, _connectionParameters.Port); _connectionFactory.SetStringProperty(XMSC.WMQ_CHANNEL, _connectionParameters.Channel); _connectionFactory.SetStringProperty(XMSC.WMQ_QUEUE_MANAGER, _connectionParameters.ManagerName); _connectionFactory.SetStringProperty(XMSC.CLIENT_ID, $"ClientName_{Environment.MachineName}.{"TestApp"}"); CreateNewConnection(); } private void CreateNewConnection() { _connection = _connectionFactory.CreateConnection(); _session = _connection.CreateSession(false, AcknowledgeMode.AutoAcknowledge); _destination = _session.CreateTopic(_connectionParameters.TopicString); var subName = "subscriptionName"; _consumer = _session.CreateDurableSubscriber(_destination, subName); //_session.Unsubscribe(subName); _consumer.MessageListener = Receive; _connection.Start(); } private void Receive(IMessage msg) { // Handler } } |
В среде WebSphere MQ, где используется multi-instance менеджер очередей, необходимо обеспечить переподключение приложений-клиентов к другому инстансу менеджера в случае сбоев. Начиная с версии WebSphere MQ V7.0.1.3, для поддержки автоматического переподключения клиентов, в фабрике соединений (Connection Factory, CF) добавлено свойство CLIENTRECONNECTOPTIONS. Этот параметр…
При попытке запустить MQ Explorer появляется и исчезает окно запуска, MQ Explorer не запускается. MQ Explorer имеет логи, которые находятся в директории workspace: C:\Users\user_name\IBM\WebSphereMQ\workspace_name\.metadata Основным логом является файл “.log” Исследуем его на предмет наличия ошибок, коррелируемых с попытками запустить MQ Explorer:…
Когда необходимо быстро интегрировать с WebSphere MQ смежную систему, а у разработчиков нет времени или желания, или есть другие причины не разбираться с клиентом WMQ и писать клиентское приложение, на помощь приходит мост WMQ – HTTP.