Re: Using Apollo with LDAP/Active Directory

Excellent! Thanks for posting back your results. On Mon, Nov 5, 2012 at 2:49 PM, Luis Gonzalez wrote: > Chirino, thank you very much! > > With your confirmation and help from Wireshark, Apache Directory Studio and > JAAS LDAP Authentication Plugin > < > http://fusesource.com/docs/broker/5.3/secur

Re: Using Apollo with LDAP/Active Directory

Chirino, thank you very much! With your confirmation and help from Wireshark, Apache Directory Studio and JAAS LDAP Authentication Plugin , org.apache.activemq.jaas.LDAPLoginModule is finally working. The critica

Re: Async error occurred Can not remove a consumer from a session not regd

Unfortunately we didn't receive any replies. We ended up moving to Kafka (http://incubator.apache.org/kafka/) which suited our throughput and availability use cases better. -Jonathan -- View this message in context: http://activemq.2283324.n4.nabble.com/Async-error-occurred-Can-not-remove-a-

Re: how to detect end-of-dataset ?

On Mon, Nov 5, 2012 at 10:27 AM, Christian Posta wrote: > So looks like destinationName is the 6th element in the "entry" array > > Not too familiar with perl, but i bet there are json libs ( > http://search.cpan.org/~makamaka/JSON-2.53/lib/JSON.pm ??) that should > help > easily parse these resul

Re: how to detect end-of-dataset ?

So looks like destinationName is the 6th element in the "entry" array Not too familiar with perl, but i bet there are json libs ( http://search.cpan.org/~makamaka/JSON-2.53/lib/JSON.pm ??) that should help easily parse these results and navigate the object then you can keep track of which destina

Re: how to detect end-of-dataset ?

On Mon, Nov 5, 2012 at 9:21 AM, Christian Posta wrote: > Can you post a snippet of the response you're getting from ActiveMQ? > It should be in JSON format, and if it is, it shouldn't be too difficult to > deal with in terms of delimiting objects and determining where you are in > the object. > S

Corrupt scheduler (kahadb) - recovery?

Hi, we maybe got a corrupt scheduler after running activemq under high load a while. The symptom is: 0) ls -l scheduler/ total 181652 -rw-r--r-- 1 root root 33554516 2012-11-01 20:20 db-1.log -rw-r--r-- 1 root root 33554677 2012-11-02 13:24 db-2.log -rw-r--r-- 1 root root 33554541 2012-11-02 1

Re: how to detect end-of-dataset ?

Can you post a snippet of the response you're getting from ActiveMQ? It should be in JSON format, and if it is, it shouldn't be too difficult to deal with in terms of delimiting objects and determining where you are in the object. On Mon, Nov 5, 2012 at 7:01 AM, Fulko Hew wrote: > This may be

Re: Just a quick one

> > as soon as I separate the code into a 'client' and 'server' portion > (each running with its own main method) synchronous mode times out (ie the > sender that waits times out, though receiver does appear to write back) - What do you mean "synchronous" mode? What is the sender waiting for? An

Re: ActiveMQ multiple instances: start problems when passing config file

> > Maybe it would be an idea to improve the description about running multiple > instances > in the shell script web page > (http://activemq.apache.org/unix-shell-script.html). > - "create" command (is currently not even mentioned) > - "start" command e.g. ./INSTANCE1/bin/INSTANCE1 start Done.

Re: Pending messages on queue is stale or wrong

Hi James, Theoretically the prefetch should not cause such problem. If it does, its a bug. On Nov 5, 2012, at 11:29 AM, James Green wrote: > Torsten, All our brokers are on 5.7.0. > > I'm wondering if this is to do with a Stomp client which specifies a > prefetch limit of 200 which processes

Re: Pending messages on queue is stale or wrong

Torsten, All our brokers are on 5.7.0. I'm wondering if this is to do with a Stomp client which specifies a prefetch limit of 200 which processes 200 msgs then disconnects. It is invoked by a scheduled job manager. I've changed this prefetch limit 1 now to see if it makes a difference under load t

Re: Pending messages on queue is stale or wrong

What version of ActiveMQ are you using? There have been a number of bug fixes around duplicate detection in the past few releases. Perhaps you got some duplicate messages in your store that the cursor would not dispatch because it detected them as duplicates. This should generally not happen,

Just a quick one

Hi Guys I have a standalone ActiveMq install that I start in its own process (ie I double click activemq.bat) and I have two command line test programs (one sender and the other receiver, both spring based) connection factory for both is set to "tcp://localhost:61616" I am trying to send and recei

Re: Variable/dynamic prefetch size

You can setup per consumer prefetch sizes. If you can send to a different queue based on how long each message will take to process (for example fastqueue and slowqueue) Then you can setup consumers on fastqueue with a large prefetch and consumer on slowqueue with a small prefetch. On Mon, Nov

AMQ 5.6.0 - Random URI/Port assignment

I'm upgrading Active MQ from 5.4.2 to 5.6.0 (latest available in Maven repository) All our Unit test cases and Build goes well, however, ... on deployment we find it creating Random URL connections to tcp://127.0.0.1: We create a ConnectionFactory in Spring that uses the following adapter where

Re: AMQ 5.6.0 - Random URI/Port assignment

ok,. .. turns out this is generated by the Borker ..and is not the URL the client is sending on but the Broker indicating the connection was abruptly broken by the client. See: https://issues.apache.org/jira/browse/AMQ-2730 ..however am still not sure how to Mute this? The messages are sent usi

Re: AMQ 5.6.0 - Random URI/Port assignment

..we had a Check to test i a Connection is available before allowing the user to enter a message. In earlier verison (and yet to verify) , "con = template.getConnectionFactory().createConnection();" was not relibale to state if the Broker was up or not. ... not sure if there is a better way for the

Variable/dynamic prefetch size

We're trying to use ActiveMQ as the queue for a distributed set of calculation servers (think many machines with 64-cores on-board). Imagine a single queue with N consumers. The only efficient way to scale is to use consumer prefetch. However. Each of our messages can take between 3ms and minut

Re: ActiveMQ multiple instances: start problems when passing config file

Thanks for the feedback. That suits me fine. I'll just start each instance with the command: ./INSTANCE1/bin/INSTANCE1 start This also means that the only necessary step is the "create" command % bin/activemq create INSTANCE1 and the other two steps are not required: % bin/activemq setup /export/