去年,我开发了一个队列监视器,它使用System.Reactive.Linq检查IBM总线上是否有消息 代码如下所示 public class QueueMonitor : IObservable<1)如果重启IBMMQ,目前QueueMonitor没有收到新的传入消息,需要重启。 我该怎么处理呢?我不知道是否在Monitor端重新启动了IBM MQ。 2)更复杂。我们正在迁移到一个新的平衡IBMMQ集群。它有4个主动节点配置为主动节点。它们都在负载均衡器之后,所以当我将消息放到总线上时,我会将其发送到单个地址。
我试图理解Linux中消息队列的工作原理。最后,我希望有一个可以在不同线程/进程之间发送和接收内容的程序,但首先,我只创建一个消息队列,并让它在队列中的输入上阻塞,但是mq_receive()返回Message too long。查看文档,此错误指示`msg_len小于消息队列的mq_msgsize属性,但对我来说并非如此。
对不起,如果我错过了一些显而易见的</