Found the culprit. The issue was in the TestCode
The prefetch limit was not getting set correctly. Setting it through the
props file was not happening.
I tried with explicit setting of this property through the following, and
the concurrency worked as expected
*((ActiveMQConnectionFactory)connect
Hi all,
I have just noted that for AMQ 5.5 no desionations are present on web
console or jconsole expect for an active producer or consumer are present at
first.
The storage of broker is based on jdbc, oracle in fact, I find the sql sentence
used to fetch all desionations from the db differ
When broker is starting up with existing JVM (non-ActiveMQ created)
MBeanServer, and isSlave gets called by a scheduled job, I get
InstanceNotFoundException on the client side. Nothing declares this checked
exception will get thrown so compiler won't let me catch it. Once ActiveMQ
is fully up, same
Can you let me see your working example of temp queues with stomp? I am not
able to make them.
Thanks,
Mario
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Stomp-Temp-Queues-tp3458356p4267597.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
On Thu, 2012-01-05 at 15:28 -0800, mrdiesel wrote:
> I m getting the following exception. and not sure what s causing it.
>
> any ideas?
>
> here is my connection string:
>
> std::string brokerURI = "tcp://127.0.0.1:61613?wireFormat=stomp";
>
> and this is the error:
>
> E 05-150926.792540
I m getting the following exception. and not sure what s causing it.
any ideas?
here is my connection string:
std::string brokerURI = "tcp://127.0.0.1:61613?wireFormat=stomp";
and this is the error:
E 05-150926.792540 4680 yfor_lookup4: invalid hostname: <(null)>
Invalid argument
F
Got it working from the doco on this site
http://fusesource.com/docs/esb/4.4.1/amq_clustering/Failover-MasterSlave-Pure.html
(I think that's a bit simpler)
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Pure-Master-Slave-tp4264249p4267485.html
Sent from the ActiveMQ - User
And to learn it:
http://www.sonatype.com/books/mvnex-book/reference/public-book.html
;)
--Allen
> -Original Message-
> From: Johan Edstrom [mailto:seij...@gmail.com]
> Sent: Thursday, January 05, 2012 10:45 AM
> To: users@activemq.apache.org
> Subject: Re: good ebooks for learning active
On Jan 5, 2012, at 2:58 AM, Dejan Bosanac wrote:
>> Why then do the NIO[SSL]* bits even have methods with *SocketFactory bits,
>> is this due to extending the TCP bits?
>
> It's used on the client side to create socket.
I thought the client-side was expected to use the regular ssl transport?
>
Maven is a build tool that is used quite frequently throughout Java projects
nowadays,
All IDE's will have integration for it as well as good CLI support, I'd suggest
just learning
it if you want to work as a Java developer, you'll encounter it pretty much any
place you
go nowadays.
/je
On J
I think it's covered in the fuse docs here:
http://fusesource.com/wiki/display/ProdInfo/Understanding+the+Threads+Allocated+in+ActiveMQ
1 thread per session.
--Allen Reese
Yahoo! Inc.
> -Original Message-
> From: techbuddy [mailto:santo...@yahoo-inc.com]
> Sent: Sunday, January 01, 2012
Yes, one group is tied to a single consumer no matter how many of those are
there.
Regards
--
Dejan Bosanac - http://twitter.com/dejanb
-
The experts in open source integration and messaging - http://fusesource.com
ActiveMQ in Action - http://www.manning.com/snyder/
Blog - http://
Is it also guaranteed with the Spring DefaultMessageListenerContainer when
the number of active consumer can vary over the time?
Regards
--
View this message in context:
http://activemq.2283324.n4.nabble.com/JMSXGroupID-timeout-tp3934661p4265945.html
Sent from the ActiveMQ - User mailing list ar
Found a bug related to this https://issues.apache.org/jira/browse/AMQ-3653
It's fixed on the trunk now. On the current version of broker, just avoid
having content-length header in your acks.
Regards
--
Dejan Bosanac - http://twitter.com/dejanb
-
The experts in open source integr
Found docs/site to be wrong on this one, default kahadb storage directory
location is "${activemq.base}/data/kahadb".
Thank you very much Dejan for the clarifications!
Regards,
Stevo.
2012/1/4 Stevo Slavić
> Dejan,
>
> You stated "By default kahaDB uses dataDir/kahadb". I guess by dataDir you
Great, thank you very much Dejan!
This property is not listed on the ActiveMQ JMX Reference page:
http://activemq.apache.org/jmx.html#JMX-ActiveMQMBeansReference
Found more info in the source and contributed fix for javadoc typo ( see
https://issues.apache.org/jira/browse/AMQ-3652 ). FOSS rulz!
Trunk should be pretty stable at the moment. You can test the latest
snapshot for starters (
https://repository.apache.org/content/repositories/snapshots/org/apache/activemq/apache-activemq/)
and see how it goes.
Regards
--
Dejan Bosanac - http://twitter.com/dejanb
-
The experts i
It does, and you have "Slave" JMX attribute on broker object.
Regards
--
Dejan Bosanac - http://twitter.com/dejanb
-
The experts in open source integration and messaging - http://fusesource.com
ActiveMQ in Action - http://www.manning.com/snyder/
Blog - http://www.nighttale.net
O
>
>
> Why then do the NIO[SSL]* bits even have methods with *SocketFactory bits,
> is this due to extending the TCP bits?
>
It's used on the client side to create socket.
>
> What is the NIO version of the SslSocketFactory muck? (I know jack about
> nio, only that it exists and uses buffers an
19 matches
Mail list logo
