So anyhow, I finally got it working so that now I can see the messages on the consumer side with only one broker running. That is what I wanted.
Thanks for your help. Now i am on to the persistence option. I have a question about that. I am using the cpp client. I am setting persistent = true in the broker configuration. I also have deliverymode set to PERSISTENT on the producer side. I am using topics. So i have created a durable consumer . does that seem like I am on the right path. Also, what does the persistenceAdapter do? is it where the messages are stored? is there a limit on how much can you store in there? tabish121 wrote: > > See this article > http://activemq.apache.org/networks-of-brokers.html > > On Tue, 2007-10-23 at 10:36 -0700, appi03 wrote: >> No i am using topics. >> >> Another question regarding the broker configuration. I know transport >> connector is tcp://localhost:61616 but what goes in the network >> connector? >> >> >> >> tabish121 wrote: >> > >> > Are you using Topics, or Queues? If you are using Queues and happen >> to >> > have another consumer running on that queue then it could explain why >> > you see only half the messages. >> > >> > See this FAQ entry >> > http://activemq.apache.org/how-does-a-queue-compare-to-a-topic.html >> > >> > Regards >> > Tim >> > >> > On Tue, 2007-10-23 at 10:25 -0700, appi03 wrote: >> >> Thanks for the reply. >> >> >> >> I just couldn't get all the messages on the consumer side so I thought >> >> something might be wrong in my configuration. Let me try this again >> and >> >> see >> >> what happens, I know I had it working before. >> >> >> >> It's so weird, i get exactly half of the messages produced. It's >> almost >> >> like >> >> someone else is consuming the other half. >> >> >> >> >> >> >> >> >> >> tabish121 wrote: >> >> > >> >> > You don't need to run two brokers to have a producer and consumer >> one >> >> > different machines. Is there a reason you are doing that? >> >> > >> >> > All you really need is one broker and then point the uri of each two >> >> > that broker. So for instance if the broker is on a box whose IP is >> >> > 172.21.46.3 then the broker URI would look like this. >> >> > >> >> > std::string brokerURI = "tcp://172.21.46.3:61616"; >> >> > >> >> > You don't need the explicit wireFormat option for openwire as its >> the >> >> > default. If you do something like this in both the consumer and >> >> > producer client code, then they should both connect to the same >> broker. >> >> > Then run your tests and see what happens. >> >> > >> >> > Regards >> >> > Tim. >> >> > >> >> > On Tue, 2007-10-23 at 10:11 -0700, appi03 wrote: >> >> >> Here is what I have so far. Btw, I am using activemq-cpp >> >> >> >> >> >> Producer Broker: >> >> >> >> >> >> <transportConnectors> >> >> >> <transportConnector name="openwire" >> uri="tcp://localhost:61616" >> >> /> >> >> >> <transportConnector name="ssl" >> uri="ssl://localhost:61617"/> >> >> >> <transportConnector name="stomp" >> >> uri="stomp://localhost:61613"/> >> >> >> </transportConnectors> >> >> >> >> >> >> <networkConnectors> >> >> >> <networkConnector name="host1" >> >> >> uri="static://(tcp://157.185.37.184:61616)" /> >> >> >> </networkConnectors> >> >> >> >> >> >> Producer App (This is what goes into my connection factory): >> >> >> >> >> >> std::string brokerURI = >> >> >> "tcp://localhost:61616" >> >> >> "?wireFormat=openwire"; >> >> >> >> >> >> >> >> >> Consumer Broker: >> >> >> </persistenceAdapter> >> >> >> >> >> >> <transportConnectors> >> >> >> <transportConnector name="openwire" >> uri="tcp://localhost:61616" >> >> /> >> >> >> <transportConnector name="ssl" >> uri="ssl://localhost:61617"/> >> >> >> <transportConnector name="stomp" >> >> uri="stomp://localhost:61613"/> >> >> >> </transportConnectors> >> >> >> >> >> >> <networkConnectors> >> >> >> >> >> >> <networkConnector name="host1" >> >> >> uri="static://(tcp://157.185.37.131:61616)" /> >> >> >> >> >> >> </networkConnectors> >> >> >> >> >> >> Consumer App (This is what goes into my connection factory): >> >> >> >> >> >> std::string brokerURI = >> >> >> "tcp://localhost:61616" >> >> >> "?wireFormat=openwire"; >> >> >> >> >> >> I guess the first question would be; am I configuring them right? >> Is >> >> >> there a >> >> >> better way of doing this? >> >> >> >> >> >> Currently with this configuration I can consume messages but only >> half >> >> of >> >> >> them. I am not sure why. >> >> >> >> >> >> Thanks for the help in advance. >> >> >> >> >> >> >> >> >> tabish121 wrote: >> >> >> > >> >> >> > Can you tell us a little about what you are doing, possible >> posting >> >> >> some >> >> >> > code showing your producer and consumer. >> >> >> > >> >> >> > One thing to keep in mind is that unless you are using a >> retroactive >> >> >> > consumer your producer shouldn't start producing until you've >> >> started >> >> >> > your consumer. >> >> >> > >> >> >> > If you have specific questions that you need help with please >> ask, >> >> we >> >> >> > try and answer them as quickly as possible. >> >> >> > >> >> >> > Documentation like anything else on this project grows faster >> when >> >> >> > people participate and contribute. Feel free to jump in. >> >> >> > >> >> >> > Regards >> >> >> > Tim. >> >> >> > >> >> >> > On Tue, 2007-10-23 at 09:27 -0700, appi03 wrote: >> >> >> >> Hey thanks for that example. >> >> >> >> >> >> >> >> How does your broker configuration look? Currently, i this is >> what >> >> I >> >> >> have >> >> >> >> on >> >> >> >> both computers >> >> >> >> >> >> >> >> <transportConnector name="openwire" uri="tcp://localhost:61616" >> /> >> >> >> >> >> >> >> >> <networkConnector name="host1" >> >> >> >> uri="static://(tcp://157.185.37.184:61616)" >> >> >> >> failover="true" dynamicOnly="true" networkTTL="2" /> >> >> >> >> >> >> >> >> But for some reason I am only receiving half of the messages. I >> am >> >> >> >> thinking >> >> >> >> something might be wrong in the way I configure my broker. >> >> >> >> >> >> >> >> >> >> >> >> >> >> >> >> OB40 wrote: >> >> >> >> > >> >> >> >> > Hi, >> >> >> >> > >> >> >> >> > You need only one broker on one of the computers. I have >> learnt >> >> most >> >> >> of >> >> >> >> > activemq-cpp from the online example which is decent >> >> >> >> > (http://activemq.apache.org/cms/example.html). I am also >> >> attaching a >> >> >> >> > couple of noddies I wrote, one is a transmitter (producer) and >> >> the >> >> >> >> other >> >> >> >> > is a consumer. I have built them on Ubuntu. To run them you >> will >> >> be >> >> >> >> need >> >> >> >> > to set you LD_LIBRARY_PATH to /usr/local/lib/ and to compile >> them >> >> >> you >> >> >> >> will >> >> >> >> > need to add /usr/local/include/activemq-cpp-2.1/ as the >> include >> >> path >> >> >> in >> >> >> >> > you g++ command. >> >> >> >> > >> >> >> >> > Best of luck. >> >> >> >> > >> >> >> >> > >> >> >> >> > appi03 wrote: >> >> >> >> >> >> >> >> >> >> I started learning activemq-cpp about a week ago. Right now I >> >> feel >> >> >> >> like i >> >> >> >> >> haven't gotten anywhere. I wonder why? There is no solid >> >> >> documentation >> >> >> >> on >> >> >> >> >> anything so to the new user, it's pretty confusing. >> >> >> >> >> >> >> >> >> >> Anyhow, I will stop my complaints. but, i need some serious >> >> help. >> >> >> >> >> >> >> >> >> >> I just want to set up two computers; one producing messages >> and >> >> the >> >> >> >> other >> >> >> >> >> one consuming messages. Now, do I need to run an activemq >> broker >> >> on >> >> >> >> both >> >> >> >> >> computers? I believe the answer is no. So then, does anyone >> have >> >> an >> >> >> >> >> example that I can look at to use it in this scenario. >> >> >> >> >> >> >> >> >> >> If i need to run a broker on both machines, is that embedded >> >> >> broker? >> >> >> >> in >> >> >> >> >> that case does anyone have a configuration example for that >> as >> >> >> well? >> >> >> >> >> >> >> >> >> >> Also, when I run the producer and consumer application. How >> do i >> >> >> >> >> configure the connection factory? I have looked and I guess i >> am >> >> >> just >> >> >> >> >> tired of looking now because i haven't found any pages on >> >> >> connection >> >> >> >> >> factory. I am not sure how all that ties in together. >> >> >> >> >> >> >> >> >> >> Please help. So i can move on to bigger and better things >> like >> >> >> >> >> persistence. I have something running right now but it just >> >> doesn't >> >> >> >> make >> >> >> >> >> sense anymore. >> >> >> >> >> >> >> >> >> >> help would be appreciated. >> >> >> >> >> >> >> >> >> > http://www.nabble.com/file/p13367353/CppQueueReceiver.cpp >> >> >> >> > CppQueueReceiver.cpp >> >> >> >> > http://www.nabble.com/file/p13367353/CppQueueTransmitter.cpp >> >> >> >> > CppQueueTransmitter.cpp >> >> >> >> > >> >> >> >> >> >> >> > >> >> >> > >> >> >> >> >> > >> >> > >> >> >> > >> > >> > > -- View this message in context: http://www.nabble.com/Help-tf4678118s2354.html#a13371330 Sent from the ActiveMQ - User mailing list archive at Nabble.com.
