Hi ActiveMQ team,
Could somebody please help me here?
Thanks for your support!
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Query-about-ActiveMQ-connection-id-and-client-id-format-tp4671843p4671878.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com
I have a consumer client and producer client. Producer client sends message
to producer client via a queue and using request/reply message pattern. So
producer is blocked until a reply comes back from consumer. Most of the
times it works fine and I get javax.jms.TextMessage type message but
occasio
Put together a unit test that shows this and we will take a look.
On Thursday, September 26, 2013, zbc wrote:
> Thanks, but i put a message in the queue, i can see it in the console,
> then i
> run the code repeatedly, but it still there, in fact, i have been
> retrieving
> if for 1 week, i don't
Hey, thanks for the reply. We debugged this further and it actually turned
out to be an issue with a PHP stomp implementation we were using.
Apparently, when building the SEND FRAME, the PHP implementation was placing
a space after the : in the header. So the actual value appeared to have a
lead
Thanks, but i put a message in the queue, i can see it in the console, then i
run the code repeatedly, but it still there, in fact, i have been retrieving
if for 1 week, i don't believe the broke need a couple of week to dispatch
it!!
--
View this message in context:
http://activemq.2283324.n4.
Check this wiki:
http://activemq.apache.org/jdbc-support.html
On Thu, Sep 26, 2013 at 11:36 AM, Alin wrote:
> The MySQL server version I'm using is 5.6.12
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/ActiveMQ-5-8
This is not a bug.
>From the JMS API doc:
http://docs.oracle.com/javaee/1.4/api/javax/jms/MessageConsumer.html#receiveNoWait()
"Receives the next message if one is immediately available."
Could be the broker hasn't dispatched the message yet, or it's in flight,
etc, etc. so it's not "immediately
Yah, mvn clean install -Dtest=false will build everything.
Actually, i pulled out the test into my test sandbox here:
https://github.com/christian-posta/camel-sandbox/blob/master/activemq-5.8-issues/src/test/java/org/apache/activemq/usecases/TwoBrokerReqeustReplyStompTempDestTest.java
You can clo
please look at following code:
InitialContext ctx = null;
QueueConnection con = null;
QueueSession queueSession = null;
QueueReceiver receiver = null;
try {
Hashtable env = new Hashtable();
env = new Hashtable(
The MySQL server version I'm using is 5.6.12
--
View this message in context:
http://activemq.2283324.n4.nabble.com/ActiveMQ-5-8-mysql-persistency-MSG-column-type-BLOB-instead-of-LONGBLOB-tp4671864p4671865.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Hi,
I have ActiveMQ 5.8 configured to persist the messages on a MySQL db.
Everything relater to this configuration is OK, being able to run my
process, except from some situation when I'm sending very big messaged to
the queue. At the point I'm getting an error like the one below:
/Caused by: java
ceposta wrote
> "i've gone ahead and put together the unit test here:
>
> https://github.com/christian-posta/activemq/blob/someword-from-mailing-list/activemq-unit-tests/src/test/java/org/apache/activemq/usecases/TwoBrokerReqeustReplyStompTempDestTest.java";
>
> ceposta
> Thanks for putting the t
Yah, you could patch org.apache.activemq.plugin.StatisticsBroker w/ debug
or trace logging messages. Then open a jira and submit your patch and we
can include it in trunk.
On Thu, Sep 26, 2013 at 7:13 AM, johnbing wrote:
> Thanks Christian for the links. However currently I am thinking to write
I think I have found the problem. In ClassLoadingAwareObjectInputStream.java
the load() method makes a call to Class.forName().
For the primitive types (int, boolean, etc.) this would result in a call
similar to:
Class.forName("int", false, loader); //Where loader is the
Applet2ClassLoader
S
Thanks Christian for the links. However currently I am thinking to write my
own broker plugging using StatisticsBroker and instead of sending the stats,
I will dump those stats into the log file.
So is this a correct way to do this ? Any suggestions from your side.
Thanks,
John
--
View this
Hi,
I would also like to see if there are any performance/throughput benchmarks
available especially comparing ActiveMQ TCP vs ActiveMQ NIO performance. I
would presume ActiveMQ developers may have done some benchmarks -- it would
be really useful if you could share the results. I understand these
You can take a look here:
https://github.com/chirino/jms-benchmark
On Thu, Sep 26, 2013 at 3:24 AM, johnbing wrote:
> Hey,
>
> I have searched but not able to find any results or any graphs for ActiveMQ
> performance. I mean do we have any numbers for ActiveMQ performance (
> throughput, mem
Yes, if camel is deployed alongside the broker, it runs in the same JVM.
You should check out some of the example configs that ship with ActiveMQ...
you'll see an tag (example...
conf/activemq-demo.xml)
With camel you can have a route like this:
from(timer:statsLogger?period=1000).inOut().to("ac
Hey,
I have searched but not able to find any results or any graphs for ActiveMQ
performance. I mean do we have any numbers for ActiveMQ performance (
throughput, memory uses , threads etc.)
Most of the other frameworks always share performance analysis and graphs.
Thanks,
John
--
View this me
Hey,
Currently I am not using camel with my broker.
After your last post I read about camel, but got stuck with some questions.
-- Is camel uses same PID as of ActiveMQ broker ? I want to log all stats
into the same ActiveMQ log file.
-- I am not able to understand how camel can be used to extra
Hi everyone,
I am trying to implement queue/topic level authorization in Apollo.
I went through all forum posts but couldn't find any solution.
I have large number (more than 2000) of clients and queues/topics. Client
can only Pub/Sub to specified queue/topic.
One option is adding Adding and rem
Any chance you could put together a junit tests case to demonstrate
the use case?
On Wed, Sep 25, 2013 at 3:54 PM, AlexP wrote:
> We are using Apollo 1.6 placing messages on the queue and reading them on the
> client. The producer adds message headers and stomp client (via web socket)
> uses a
22 matches
Mail list logo
