Re: Slow Consumer slows down the producer

These are small json string messages. The memory settings are, -- View this message in conte

Slow Consumer slows down the producer

Hi, I am using ActiveMQ 5.8.0 and publishing messages on a topic, on which there is a slow consumer. Approx. 8000 messages are published at a interval of 1 minute. All messages are sent all together. I have set the constantPendingMessageLimitStrategy limit to "5" in the conf file and prefetch

Re: ActiveMQ : 'Expiring messages done' messages in logs

So its just an informative message...not error.. nothing to worry... -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-Expiring-messages-done-messages-in-logs-tp4667940p4667942.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

ActiveMQ : 'Expiring messages done' messages in logs

Hi, I am running ActiveMQ will DEBUG logging enabled and I am seeing lot of messages as 'expiring messages done'. What the messages signifies. 2013-06-05 17:27:50,531 | DEBUG | temp-queue://ID:-0:1:2 expiring messages done. | org.apache.activemq.broker.region.Queue | ActiveMQ Broker[bart2] Schedu

Re: Amazon EC2 and ActiveMQ : Inactive client disconnects

I have already set wireFormat.maxInactivityDuration = 0, which is supposed to disable the inactivity monitor. Also, when I send request on the queue where this consumer was connected, I got the following errors in the logs, 2013-06-05 15:56:17,667 | WARN | Transport Connection to: tcp://:3906 fa

Amazon EC2 and ActiveMQ : Inactive client disconnects

HI, I am using ActiveMQ 5.8.0 setup on Amazon EC2 Ubuntu instance. The inactive consumer connected from external networks got disconnected after some time, but the same consumers when running internally works fine. The external consumer works fine until there is flow of requests but if no request

Re: ActiveMQ Transport failed: java.io.EOFException

Is there a way to make sure that client always disconnects properly. I dont have any control over the client code.Its a external client but I can change settings in the broker. Thanks Manu -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-Transport-failed-java-io-

ActiveMQ Transport connection : java.io.EOFException

Hi, I am using ActiveMQ 5.8.0 and whenever a client disconnects, I get the following exceptions in the logs, 2013-06-05 14:39:05,459 | WARN | Transport Connection to: tcp://:11801 failed: java.io.IOException: Connection reset by peer | org.apache.activemq.broker.TransportConnection.Transport | A

ActiveMQ Transport failed: java.io.EOFException

Hi, In ActiveMQ logs, I keep on getting the following exceptions. 2013-06-05 12:37:43,886 | INFO | Transport failed: java.io.EOFException | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///:54978 2013-06-05 12:37:43,888 | INFO | Transport failed: java.io.EO

ActiveMQ Transport failed: java.io.EOFException

HI, I am running ActiveMQ 5.5.1 and allowing SSL connections. In the logs I am seeing lot of exceptions as shown below. PLease let me know what could be the reason for these. Am I doing something wrong in configuration or is it improper handshake when client doesnt have proper certificate. 2013-0

Re: ActiveMQ 5.8 : Active connections are not displayed in Web UI

Thanks Tim. -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-5-8-Active-connections-are-not-displayed-in-Web-UI-tp4667832p4667841.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: ActiveMQ : Broken Pipe Exception

Thanks Ceposta, but I didnt get your question. I dont think there is any change in the network infrastructure. Also, this issue happens only after 50-60 messages has been transferred. So it connects fine, ran fine for some time and then it gave the Broken Pipe Error. -- View this message in c

ActiveMQ 5.8 : Active connections are not displayed in Web UI

Hi, I am using ActiveMQ 5.8 (latest version). In the web UI tab for connections, the active connections are not being displayed. Please let me know if I need to explicitly made this setting somewhere or is this a known bug. Thanks Manu -- View this message in context: http://activemq.228332

ActiveMQ : Broken Pipe Exception

Hi, I am using ActiveMQ 5.5.1 and publishing data on a topic. There is a SSL subscriber on that which consumes all this data. This setup was running fine for over a year, but now I am getting, 2013-06-03 12:00:32,827 | INFO | Transport failed: javax.net.ssl.SSLException: Connection has been shut

apache activemq 5.6 behaves differently on two machines

HI, I am useing Activemq 5.6.0. I have copied the same activemq folder on both the machines and enabled the priority on the queues. On one machine it works fine, with a prefetch size of 1000 but on the other machine with prefetch size 1000, all messages are not consumed, and messages are left in t

Re: Java client doesnt work with https

Tim, the same code works fine for SSL. Does this confirm that my certificates are correct. Also, for https, do I need made any other setting in activemq.xml, except the transport connector setting.All other settings for ssl are already there. Thanks Manu -- View this message in context: http://

Re: Java client doesnt work with https

Thanks Tim, I enabled the TRACE level logging. I didnt see any thing at the broker end. The log at the client end says, 455 [main] TRACE org.apache.commons.httpclient.HttpClient - enter HttpClient.executeMethod(HttpMethod) 455 [main] TRACE org.apache.commons.httpclient.HttpClient - enter Http

Re: Java client doesnt work with https

Dejan, I got http working. I havent included all the xpp libraries. So http is working now, but having same issue with the https. When I try to connect with https, the DEBUG log (at teh end) says, 351 [main] DEBUG org.apache.commons.httpclient.HttpConnection - Open connection to localhost:8443

Re: Java client doesnt work with https

Thanks Dejan. I hope my certificates are appropriate as same certificates works with ssl. So, I assume that its not a certificate issue. Also, when I used http instead of https, i got a response back from broker, but then the connection was closed. My debug log says, 533 [main] DEBUG org.apache

Java client doesnt work with https

HI, I am trying to getting java consumer work over https. In my aactivemq.xml at broker side, i have configured ssl and https transport connectors, https://localhost:8443"/> At the consumer side (java client), I am specifying the connection factory as, ActiveMQConnectionFactory factory =

Re: Configure ActiveMQ Client with a proxy

HI, Does any one found the solution for this issue. I am also having the same issue. Please let me know your inputs. Thanks Manu -- View this message in context: http://activemq.2283324.n4.nabble.com/Configure-ActiveMQ-Client-with-a-proxy-tp2360107p4200293.html Sent from the ActiveMQ - User ma

Store percent used increases even without any persistent messages

Hi, I have a network of broker setup, say with broker A and B. Only one queue and one topic is being forwarded from Broker A to broker B over network of brokers. No other message/queue/topic is forwarded to broker B. Messages are being published on Broker A over a different topic (which is not fo

Re: ActiveMQ CPP : Same message being consumed by two consumers

Thanks Ivan, That helps. I will create one consumer per session. Just to add to your argument, following link also suggests, what you have suggested, http://activemq.apache.org/multiple-consumers-on-a-queue.html Thanks, Manu -- View this message in context: http://activemq.2283324.n4.nabble.c

Re: ActiveMQ CPP : Same message being consumed by two consumers

Ivan, Each consumer is running in a different thread, though listening on the same queue. We dont see any concurrent access. Thanks Manu -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-CPP-Same-message-being-consumed-by-two-consumers-tp4096080p4096622.html Sent f

Re: ActiveMQ CPP : Same message being consumed by two consumers

Thanks Tim, We dont have a simple test case for this. We will further investigate the issue in light of your inputs. Thanks Manu -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-CPP-Same-message-being-consumed-by-two-consumers-tp4096080p4096611.html Sent from the

ActiveMQ CPP : Same message being consumed by two consumers

HI, We have used activemq cpp and created a session. The session is set in the auto acknowledge mode. Multiple threads have been launched from that code and each thread has a consumer.All consumers are listening on the same queue, and sharing the same session. It looks that a message on that queu

Re: Unable to connect to broker over ssl

Thanks Gary, I tried to make a consumer as, System.setProperty("javax.net.ssl.trustStore","/usr/local/activemq/conf/client.ts"); System.setProperty("javax.net.ssl.keyStore","/usr/local/activemq/conf/client.ks"); System.setProperty("javax.net.ssl.keyStorePassword","password"); an

Unable to connect to broker over ssl

Hi, I have setup the ssl in the broker as follows, And specified he transport connector as, With this configuraton broker starts, but when I connect to it using a java consumer as, ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("ssl://:443

Configuring Network of Brokers

Hi, I am configuring a network of broker with 2 two brokers(say brokerA and brokerB). The producer on brokerA publishes around 5 message per second on topicT, and those are forwarded to the brokerB as well on topicT. My question is, will the BrokerB act as durable consumer on BrokerA. Furt

How can I restrict durable consumers

Hi, I want my broker to not allow durable consumers. Is there an option/setting in activemq.xml such that no durable consumer can be connected to any of its topic. Kindly let me know your inputs. Thanks Manu -- View this message in context: http://activemq.2283324.n4.nabble.com/How-can-I-rest

Websocket from Chrome 14 not working with ActiveMQ

HI, I was trying to use ActiveMQ with Websocket over port 61614 and was able to do so with the previous version of Websocket protocol with Chrome. This doesnt work anymore with the latest version of Chrome (version 14+), where they have used the updated websocket protocol with security features.

How to make sure a message is fully sent/transferred.

Hi, I am using a perl consumer and for the message, building my own frame, as, my %head; $head{destination} = "/queue/Test.Request.Q"; $request{message} = "Test Message"; $request{sequence_no} = 1; my $frame= Net::Stomp::Frame->new( { command => "SEND", headers => \%head, body => to_js

Re: Activemq Perl consumer miss messages from the queu

just to add to the previous post, if the message processing takes time, it works fine.But if the message processing is fast, it misses some messages in between. -- View this message in context: http://activemq.2283324.n4.nabble.com/Activemq-Perl-consumer-miss-messages-from-the-queu-tp3875608p3875

Activemq Perl consumer miss messages from the queu

HI, I have the setup where my consumer receives a message, unsubscribe from the queue, process the message and starts another instance of the same consumer.In this process, I am losing some message in between. Is it due to the prefetch size, When the prefetch size was more, it was loosing more me

To pick pending messages, consumer should just unsubscribe/subscribe or completely disconnect/connect from broker

HI, I have activemq setup with a consumer on a queue. If the consumer hangs, there are pending messages in the queue. To consume those messages, I restart the consumer. To restart should I just unsubscribe/subscribe to the queue or should I completely disconnect from the broker and reconnect.

Re: Subscriber on a secure topic goes in unack infinite loop

Thanks Tim, will try to code for that. Thanks Manu -- View this message in context: http://activemq.2283324.n4.nabble.com/Subscriber-on-a-secure-topic-goes-in-unack-infinite-loop-tp3760584p3761108.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Is it possible to secure only one topic

HI, Is it possible to secure only one topic and rest all queues/topic will be kept as such. I used the activemq-security.xml file as the conf file, and have removed all references to /queues...still then, for connecting to any queue, it needs the log in information. It works fine if I specify th

Subscriber on a secure topic goes in unack infinite loop

HI, I have defined a secure topic in the activemq.xml, where only admin can write and user can only read. If the topic exists and subscriber is subscribed it works fine. But if the topic is not there and subscriber tries to subscribe it gets the message that user doesn't have the permissions to c

Re: Stomp over Websocket truncates the message

I have created the issue for this, https://issues.apache.org/jira/browse/AMQ-3402 Thanks, Manu -- View this message in context: http://activemq.2283324.n4.nabble.com/Stomp-over-Websocket-truncates-the-message-tp3670514p3675319.html Sent from the ActiveMQ - User mailing list archive at Nabble.co

Stomp over Websocket truncates the message

HI, I am using websocket for receiving messages over a queue using java script. This works fine for smaller messages, but for large messages the message.body truncates the message and also, JSON.parse(message.body) fails. Is there a limit for the message size in Websockets. I using java script (

Publisher stops publishing when a subscriber is attached to that topic

Hi All, I am having a activemq publisher which publishes 1000s of messages per second. Its working fine, until I place an subscriber on that topic. When the subscriber is put on the topic, it works fine for first 7-8 messages but after that the publisher stops publishing on the topic. If

Re: how to stop AMQ gracefully?

Hi Michal, assuming, you are running activemq from linux box, just go to the activemq folder and give the command, bin/activemq stop This will stop the activemq. You can also check your activemq status in the same way as, bin/activemq status. I am not sure about windows setup. Thanks, Manu

Usage memory Limit hit with Network of Brokers.

HI, I setup a network of brokers between 3 brokers as, (similarly made settings on other two brokers as well) The messages being published on one topic were distributed to all three brokers. When on of the broker went down, the memory message limit was hit on other brokers and the sy

RE: Getting Usage Manager Memory Limit reached message on the topic

Thanks Thomas. I was having a durable consumer subscribed to this topic, but after the consumer id done, I have deleted the subscriber from the Manage broker activemq page. In another setup, I have closed the consumer and deleted it, as, consumer.Close(); session.DeleteDurableConsumer("test");

Non Durable/persistent topic

HI, How can I create a non durable/persistent topic. I want my topic to discard messages after a certain limit. Even if a durable consumer tried to subscribe on this topic, the topic itself should not allow it. How this type of scenario is achievable. Thanks, Manu -- View this message in conte

Getting Usage Manager Memory Limit reached message on the topic

HI, I have a topic on which millions of messages are published and there was no subscriber on that, till that time it was working fine. I put a subscriber on that, read some messages and subscriber was killed. After some time, I got Usage Manager Memory Limit message and the system crashes. In th

Consumer on a topic dies, after ti leaves the current thread

HI, I am writing a dll which caters requests from a topic. There is a consumer, listening on a topic. When a new requests come another function is called and the response is served. But, once the control leaves the dll and go back to the application, consumer dies off.I want the consumer to keep o

Re: Is there a limit on message size in activemq cpp

HI, In addition to the previous post, I am sending a byte message and wants to know if there is a limit on max size for byte messages. Thanks, Manu -- View this message in context: http://activemq.2283324.n4.nabble.com/Is-there-a-limit-on-message-size-in-activemq-cpp-tp3437123p3437129.html Sen

Is there a limit on message size in activemq cpp

HI, I am using activemq cpp and planning to send a message of around 100 MB in size. Is there a maximum limit on the message size. If yes, how can I modify this limit. Thanks, Manu -- View this message in context: http://activemq.2283324.n4.nabble.com/Is-there-a-limit-on-message-size-in-active

Consumer is not able to pick messages from queue

Hi All, I am working on request-response system, where all the requests are posted on a single queue with different selectors. There are multiple consumers listening on the queue. When the load is low, this works fine. Each consumer is able to process the respective message. But if the load is h

Re: AMQ consumer, gives exception when executing query from mysql

Hi All, The error is solved. There was no problem from ActiveMQ, it was only catching the wrong catch block. Thanks, Manu manua wrote: > > Hi All, > > My consumer gives unknown exception at, > > mysqlpp::StoreQueryResult res = query.store()). > > ON receivin

AMQ consumer, gives exception when executing query from mysql

Hi All, My consumer gives unknown exception at, mysqlpp::StoreQueryResult res = query.store()). ON receiving the test message, I ma parsing and passing it to a function, which will dip the database on the basis of that parameter and returns the result. I am able to parse the message and pass i

Re: Error while creating object

> On Tue, 2010-07-13 at 07:02 -0700, manua wrote: >> Hi Tim, >> >> My program crashes on >> activemq::library::ActiveMQCPP::initializeLibrary(); >> >> I am using ActriveMQ 5.3 with i686 i686 i386 GNU/Linux box and >> compiler is gcc version 4.1.2

Re: Error while creating object

Hi Tim, My program crashes on activemq::library::ActiveMQCPP::initializeLibrary(); I am using ActriveMQ 5.3 with i686 i686 i386 GNU/Linux box and compiler is gcc version 4.1.2 20070925 (Red Hat 4.1.2-33). Thanks, Manu Timothy Bish wrote: > > On Tue, 2010-07-13 at 06:02 -0700,

Error while creating object

Hi All, I getting the following error while creating the object in AMQ, #0 0x002cd777 in apr_atomic_add32 (mem=0x95123ec, val=4294967295) at atomic/unix/mutex.c:78 #1 0x016208b8 in decaf::util::concurrent::atomic::AtomicInteger::decrementAndGet (this=0x95123e8) at decaf/util/conc

Re: Error while installing activemq-cpp

t works fine. Please let me now your inputs. Thanks, Manu Timothy Bish wrote: > > On Tue, 2010-06-22 at 07:46 -0700, manua wrote: >> Thanks Tim! >> >> I am able to made it work. It needed openssl-devel. >> >> Now, its working fine, but I have issue with tem

Re: Error while installing activemq-cpp

Thanks Tim! I am able to made it work. It needed openssl-devel. Now, its working fine, but I have issue with temp queue subscription/consumer. Does temporary queue ever time outs. Please let me know your views. Thanks, Manu Timothy Bish wrote: > > On Mon, 2010-06-21 at 09:02 -0700,

Error while installing activemq-cpp

Hi All, I am getting the following errors, while trying to install activemq-cpp, decaf/internal/net/ssl/openssl/OpenSSLContextSpi.cpp:42:25: error: openssl/ssl.h: No such file or directory decaf/internal/net/ssl/openssl/OpenSSLContextSpi.cpp:43:25: error: openssl/evp.h: No such file or

Objects seems to be lost when transferring in request response

Hi All, I am trying to transfer an object in response to query over temporary queue. The message is recieved by the client, but when I tries to do getObject, it looks that object is lost. Cant we transfer large objects over temporary queue or is there some other way except, getObject(). Please

Objects seems to be lost when transferring in request response

Hi All, I am trying to transfer an object in response to query over temporary queue. The message is recieved by the client, but when I tries to do getObject, it looks that object is lost. Cant we transfer large objects over temporary queue or is there some other way except, getObject(). Please

Objects seems to be lost when transferring in request response

Hi All, I am trying to transfer an object in response to query over temporary queue. The message is recieved by the client, but when I tries to do getObject, it looks that object is lost. Cant we transfer large objects over temporary queue or is there some other way except, getObject(). Please

Unable to get object from object message using getObject()

Hi All, I am trying to implement request/response using ActiveMQ. I am transferring a list in response from the server. At the client side, it shows that it has recieved the object and content is not null. But when i tries to get the object, as studysDTOs = (List) objmessage.getObject(); it

Buffer size when transferring bigger files using Blob Messages

Hi All, I am trying to transfer large files (around 100Mb) using ActiveMQ, as blob messages. For doing so, I am setting the buffer size equal to file length, as blobTransferPolicy.setBufferSize((int)inputFile.length(); My doubt is where this buffer is actually created and with large files being

How to set MessageID while transferring blobs

HI All, I am able to transfer my files as blob messages and by specifying the blobtransfer policy, i am able to set the location where these files(blob messages) should be stored. But I am getting issues with the name of the files being stored. The blob messages are stored in the fileserver with

Re: Segmentation fault while sending bytes messages

messages. So is there any other varibale, that needs to be set, or can it be something related to activemq.xml settings like some stack/heap size i have to set. Please let me know your inputs. Thanks, Manu manua wrote: > > Hi Tim, > > I am getting the error, even when my file is j

Unable to compile ProducerTool.java code for Blob Messages

Hi All, I am trying to use Blob Messages in my code, but getting following error at compile time. I have import the BlobMessage class. The same code is working fine for Text Messages. [r...@domu-12-31-38-00-35-27 example]# ant producer /usr/bin/build-classpath: error: Could not find xml-comm

Re: Segmentation fault while sending bytes messages

best approach. It will be very nice if you could share some code snippet, explaining this. Thanks, Manu Timothy Bish wrote: > > On Fri, 2009-04-24 at 17:31 -0700, manua wrote: >> Hi Tim, >> >> Thanks for your reply. >> >> PLease find below the part of my co

Re: Segmentation fault while sending bytes messages

ow your inputs. Thanks, Manu Timothy Bish wrote: > > On Wed, 2009-04-22 at 07:40 -0700, manua wrote: >> Hi All, >> >> I am trying to send large bytes messages. From the producer end, I ma >> able >> to send the messages, but at the consumer end, after recieving

Re: Sending Image Files through ActiveMQ-CPP

Hi Tim, Thanks for your reply, When using the bytes messages, I got stuckup with segmentation fault. I have already opened another thread for that issue. So, will continue in that. Thanks, Manu Timothy Bish wrote: > > On Tue, 2009-04-21 at 20:02 -0700, manua wrote: >> Hi All,

Unable to create Blob messages

Hi All, I am trying to use Blob Messages in my code, but getting following error at compile time. I have import the BlobMessage class. The same code is working fine for Text Messages. [r...@domu-12-31-38-00-35-27 example]# ant producer /usr/bin/build-classpath: error: Could not find xml-commons-

Libraries to include while compiling my activemq-cpp code

Hi All, I am writing my own producer and consumer code, but getting issues when compiling my code. If I refer my cpp files in Makefile.am in the same format as the example code, able to compile my code with make check. Kindly tell me which libraries to include while compiling my own code. Thanks

Re: Sending Image Files through ActiveMQ-CPP

mothy Bish wrote: > > On Tue, 2009-04-21 at 20:02 -0700, manua wrote: >> Hi All, >> >> I am trying to transfer image files/continous data streams using >> ActiveMQ-CPP. I tried to use Bytes Messages but was not successful. Could >> any obe share a sample code for

Segmentation fault while sending bytes messages

Hi All, I am trying to send large bytes messages. From the producer end, I ma able to send the messages, but at the consumer end, after recieving some messages, I am getting Segmentation fault. Please find below the output, I recieved at the consumer end. Kindly help me with this. ===

Sending Image Files through ActiveMQ-CPP

Hi All, I am trying to transfer image files/continous data streams using ActiveMQ-CPP. I tried to use Bytes Messages but was not successful. Could any obe share a sample code for the same or guide mw if there is any other better way through which I can transfer files from my local machines using

Real time market data publisher

Hi All, I am writing a real time market data publisher and publisher will publish data for more than 5000 scripts. I am thinking of using 5000 topics, one each for each script and subscriber will listens to these topics; but this approach seems to consume lot of memory. I just want to know if t

How to send blob messages using ActiveMQ-CPP

Hi All, I want to sent blob messages in request response fashion. My client will send the request and server will respond back with the continous data streams/blob messages (images). I am new to this and looking for guidelines that from where to start. It will be nice if you could please point m

Write a Servlet that subscribes to activemq broker

Hi All, I am trying to write a servlet that subscribes to activemq broker and updates the ajax client, whenever any message is recieved by it, ie the servlet will act as a subscriber as well and will send data to the ajax clien on onMessage. Is it possible. I am thinking the Servelt should imp

Java publisher communicate through servlet to Ajax client

Hi All, I want my Servlet to consume messages from a broker and then transfer them to a ajax client. I am new to this, so require your help in doing this. I want to know, how to write a servlet for this. I am trying to achieve this using PortfolioPublishServlet.java. Any help in this regard wil

How to send/recieve map messages through Java publisher/subscriber

Hi All, I want to send map messages through Jva Publisher/Subscriber. I am able to achieve this using cpp but need help on Java part. Could you please help me, how to send a Map Message/ Objects through Java publisher. Thanks, Manu -- View this message in context: http://www.nabble.com/How-to

Re: How to integrate Ajax client with ActiveMQ CPP publisher

manua wrote: > > HI Tim, > > I have tried that part. With this publisher, I am able to publish messages > and consume them throgh another Java consumer or cpp consumer. The problem > comes in consuming the data through ajax client. I need your advice on > that part. &g

Re: How to integrate Ajax client with ActiveMQ CPP publisher

doing any thing wrong or I ahve to use some other procedure. Hope for an early reply. Thanks, Manu Timothy Bish wrote: > > On Tue, 2009-03-31 at 04:45 -0700, manua wrote: >> Hi Tim, >> >> I am using the sample webapps/demo. I am running the ajax >>

Re: How to integrate Ajax client with ActiveMQ CPP publisher

ay in real tiem. PLease let me know if I am doing any thing wrong or I ahve to use some other procedure. Hope for an early reply. Thanks, Manu Timothy Bish wrote: > > On Mon, 2009-03-30 at 11:21 -0700, manua wrote: >> Hi All, >> >> I am trying to run the Market data exa

How to integrate Ajax client with ActiveMQ CPP publisher

Hi All, I am trying to run the Market data example of webapps/demo. I am able to run the example with portfolio in one window and publisher in another window. I wan to run the same portfolio client, but instead of getting data from publisher class I want portfolio to pick data sent by a CPP pub

Re: Unable to run Unit test for ActiveMQ NMS

Thanks, Manu manua wrote: > > > Hi Tim, > > Thanks for your suggestion. I am able to run the Unit test. > > Thanks, > Manu > > > Timothy Bish wrote: >> >> On Fri, 2009-03-20 at 06:50 -0700, manua wrote: >>> Hi, >>> >>>

Re: Unable to run Unit test for ActiveMQ NMS

Hi Tim, Thanks for your suggestion. I am able to run the Unit test. Thanks, Manu Timothy Bish wrote: > > On Fri, 2009-03-20 at 06:50 -0700, manua wrote: >> Hi, >> >> I am trying to use NMS on windows. I tried to run the Unit tests through >> NUnit, but unable

Unable to run Unit test for ActiveMQ NMS

Hi, I am trying to use NMS on windows. I tried to run the Unit tests through NUnit, but unable to do so. Out of the total 85 test cases, 61 have failed.tests pertaining to Apache.NMS.ActiveMQ.Test.dll have passed, but all the tests for Apache.NMS.Test.dll have failed. The error, I got is, Apache

Re: how to implement multiple message producers in activemq cpp

cout << "Finished with the example." << std::endl; std::cout << "=\n"; } Timothy Bish wrote: > > The file you posted appears to be corrupted, you may want to tr

Re: how to implement multiple message producers in activemq cpp

views.Thanks for your help. Regards, Manu Timothy Bish wrote: > > On Mon, 2009-03-16 at 13:02 -0700, manua wrote: >> I tried to implement multiple topics in activemq cpp. I modified the >> example, >> simpleProducer.cpp to have multiple producers and then created

how to implement multiple message producers in activemq cpp

I tried to implement multiple topics in activemq cpp. I modified the example, simpleProducer.cpp to have multiple producers and then created multiple destinations (multiple topics). With each producer,pointing to a different topic, I am trying to send a diferent message.It compiles fine, but at ru