I can ask the question very succinctly: I want my consumers to live forever
and not care about the comings and goings of producers. When I use the
example programs, my consumer dies when the producer quits.:confused:
--
View this message in context:
http://www.nabble.com/multiple-producers-in
if you look at the message
java.lang.OutOfMemoryError: unable to create new native thread
this will tell you that it has nothing to do with your Xmx setting.
Threads and thread stacks are allocated outside your Java heap (ie, your Xms and Xmx settings)
and you've simply run out of space to cre
Joe,
Thanks much for the reply. I have a login.config defined in the classpath. I
am using JBoss so in my exploded activemq-rar I have the login.config and
users.properties and groups.properties defined.
Thats about the only thing I am guessing to is that my users.properties is
not picked up or
We have a simple many producers making messages and sending them into 1 topic
for many consumers to consume them. All consumers must get all messages
entered.
I got example code to work good, but one problem. When one producer quits,
all the consumers quit receiving messages. I even removed all
Just for grins, I took your authorizationPlugin and deployed it onto my JAAS
test setup; everything worked fine.
I can only guess that you're somehow picking up the wrong user.properties
and/or groups.properties file.
Did you set java.security.auth.login.config ? Or are you letting the JAAS
I am using activemq-5.0-SNAPSHOT and am trying to get JAAS authentication
working.
I have the login.config and user/group property files configured as per the
example http://activemq.apache.org/security.html
I beleive others have faced this problem but I have not found a concrete
answer. I get th
You need to get then out of SVN.
See this page for accessing the code.
http://activemq.apache.org/cms/source.html
The code is in these folders
https://svn.apache.org/repos/asf/activemq/activemq-cpp/trunk/src/examples/consumers/
https://svn.apache.org/repos/asf/activemq/activemq-cpp/trunk/src/exam
I can't seem to find the link to the examples... would you mind posting it
here?
Thanks,
mrh
--
View this message in context:
http://www.nabble.com/Stop-Thread---Stop-Listening-tf4693571s2354.html#a13432796
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Was wondering if you figured this out? I am facing the very same issue. I see
the my user in the property file and has the right role...
Sandeep Chayapathi wrote:
>
> Hi,
>
> This is a followup on:
> http://www.nabble.com/-Stomp--Access-Control-List-tf2040876.html
>
> Now, I have setup AMQ
Sure thing.
I've added a SimpleAsyncConsumer and SimplProducer examples to the trunk
of ActiveMQ-CPP. You can look at these to see example of each in
separate apps.
Regards
Tim
On Fri, 2007-10-26 at 09:11 -0700, mrh wrote:
> That is exactly what I needed to know. I misunderstood what the
> do
That is exactly what I needed to know. I misunderstood what the
donelatch.await() line of code did in the activemq-example project. I could
not figure out why the entire program kept exiting when that line of code
wasn't in there. Now I see that if no other processing is taking place, the
progr
I'm running a load test that intends to throw on the order of several
thousand connections at a 2 node broker system with failover (ActiveMQ
4.1.1) configured for tcp transport only. However, I'm just using a single
broker node right now and am getting out of memory errors at about 400
connection
All you need to do is close the consuer, i.e. myConsumer.close() and it
won't receive any more messages. That is if you only want to stop that
consumer. Otherwise if you are shutting down the app then close and
delete everything.
Regards
Tim.
On Fri, 2007-10-26 at 07:51 -0700, mrh wrote:
> In o
In other words, if the asynchronous listener is listening "forever", is it
possible to neatly stop that listener by closing the connection, the
session, the consumer, etc?
--mrh
mrh wrote:
>
> Thank you for the reply, Tim.
>
> Yes, this is my primary question:
>
>
> tabish121 wrote:
>>
>>
When you use a MessageListener that listener is notified in a thread
context other than the main thread. So in you client app you can set a
MessageListener and then it will receive messages until you kill the
app, so you can just have the main waiting on a cin.get() and it will
process message unt
Thank you for the reply, Tim.
Yes, this is my primary question:
tabish121 wrote:
>
> make that it
> doesn't wait forever for messages and it stops as soon as it gets all
> the messages we told it to.
>
I would like for it to listen continuously for messages: no countdown, no
wait... just l
I'm not really sure what you are asking. The CountDownLatch is used
specifically in our example to control the consumer and make that it
doesn't wait forever for messages and it stops as soon as it gets all
the messages we told it to. This happens when the run method in the
consumer class finishe
Yup, I am using with no problem.
Can you post your complete activemq.xml?
Try commenting out your commandAgent like this
Joe
lancedv wrote:
>
> Hi Joe,
>
> Yup it solved that problem but im now gettin these errors:
>
> javax.jms.JMSException: User name or password is invalid.
>
Thanks for clarifying! :-D
--
View this message in context:
http://www.nabble.com/Is-ActiveMQ-suitable-for-this-Store-And-Forward-scenario--tf4693669s2354.html#a13427709
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
In the activemq-cpp example code, there is a countdown "latch". If I
understand it correctly, you can pass in a number of milliseconds that it is
to wait for a message or a number that it will count down to as messages are
received. With this structure, is it possible to asychronously receive
me
Hi Henning,
we are using the latest stable version: apache-activemq-4.1.1 and an oracle
database.
But in the newest unstable version (5x) the DefaultJDBCDAdapter class still
has this bug inside.
If you have the source code of 3.2.2 available you can check the method
.doSetLastAck() inside the Def
Hi Matthias,
spiiff wrote:
> Turning off the batchedStatements did not really solve the problem.
> Here is a bug description (from Jul 04, 2006 ! ):
> http://www.nabble.com/Is-this-a-bug-in-DefaultJDBCAdapter.java--tf1890445s2354.html#a5168977
> I think this was the reason for our problem..
>
> W
Hi Guys,
I just want to know how to turn on console debugging?
Thanks!
--
View this message in context:
http://www.nabble.com/console-debugging-tf4696551s2354.html#a13424883
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Hi,
I'm using the activemq-5.0-101007 snapshot. I'm using it with a web app and
everything was working fine until one day I ran a test which used the web
app numerous times and this error started to occur:
ERROR RecoveryListenerAdapter- Message id
ID:GB060300-2185-1192709598238-5:367:-1:
Turning off the batchedStatements did not really solve the problem.
Here is a bug description (from Jul 04, 2006 ! ):
http://www.nabble.com/Is-this-a-bug-in-DefaultJDBCAdapter.java--tf1890445s2354.html#a5168977
I think this was the reason for our problem..
With this correction in the DefaultJDBCA
25 matches
Mail list logo
