Tag: activemq

为什么不为ActiveMQ Temp Queue创建消费者？: 除SimpleMessageListenerContainer选项外，不会为临时队列创建使用者。我不会将SimpleMessageListenerContainer用于此处遇到的一些问题。以下代码不起作用…（即使没有创建临时队列） using (IConnection connection = connectionFactory.CreateConnection()) using (ISession session = connection.CreateSession()) { IDestination destination = SessionUtil.GetDestination(session, aQueueName); var replyDestination = session.CreateTemporaryQueue(); // Create a consumer and producer using (IMessageProducer producer = session.CreateProducer(destination)) { // Start the connection so that messages will be processed. connection.Start(); IBytesMessage request = session.CreateBytesMessage(aMsg); request.NMSReplyTo = replyDestination; IMessageConsumer consumer […]

什么序列化方法用于ActiveMQ NMS C＃对象消息？: 我打算将Apache NMS用于ActiveMQ消息传递，我想知道在我发送的对象上将使用什么序列化方法？ XML /二进制？什么控制序列化以及如何自定义？有没有人有使用C＃对象的经验？你知道有什么陷阱吗？

带有C＃和Apache NMS的ActiveMQ – 计算队列中的消息: 我正在使用ActiveMQ使用C＃应用程序发送和接收消息。但是我只是在计算队列中的消息时遇到了一些困难。这是我的代码： public int GetMessageCount() { int messageCount = 0; Uri connecturi = new Uri(this.ActiveMQUri); IConnectionFactory factory = new NMSConnectionFactory(connecturi); using (IConnection connection = factory.CreateConnection()) using (ISession session = connection.CreateSession()) { IDestination requestDestination = SessionUtil.GetDestination(session, this.QueueRequestUri); IQueueBrowser queueBrowser = session.CreateBrowser((IQueue)requestDestination); IEnumerator messages = queueBrowser.GetEnumerator(); while(messages.MoveNext()) { messageCount++; } connection.Close(); session.Close(); connection.Close(); } return messageCount; } […]