I'm completely new to the activemq, so I guess my question is basic.
I am using activemq for JUnit testing. Therefore, I set to run it in vm mode
since JUnit is ran by third party product that executes unit tests for
entire application on separate machine regulary. So, there is no need to
keep qu
I want to implement a priority queue (message delivery ordered by priority)
and am trying to figure out what consumer priority means.
After looking over the documentation (
http://activemq.apache.org/consumer-priority.html) and these email threads,
the semantics of consumer priority are still not
I'm also getting these errors. Has anyone found a solution?
[EMAIL PROTECTED] wrote:
>
> Hi,
>
> I tried to compile the C++ client on VC++ 2003. I had to change the
> version of VC++ in .sln and .vcproj to make it loaded by VC++ 2003. When I
> compiled it, I got quick a few errors. Example:
>
I'd say your problem is due to the session running in auto-ack mode
(so after the onMessage method completes) and your manual ack. I think
ActiveMQ might just ignore your call to acknowledge() and wait for the
method to complete. Since the 5 second sleep is inside the
onMessage-method it'll assume
Hi,
I was wondering if anyone had any ideas on this issue?
It would be most appreciated.
Gordon.
Gordon Heydon wrote:
I keep on getting a
java.lang.NullPointerException
at
org.apache.activemq.network.DemandForwardingBridgeSupport.configureMessage(DemandForwardingBridgeSupport.java:545)
an
Hi,
I'm using the following version apache-activemq-5.1-20080208.142256-20.zip
I have like 500 messages pending in the broker and I have the following
consumer:
public void run()
{
//Create a connection
Connection conn = null;
activemqnewbie wrote:
>
> All,
> After i shutdown my broker,i see my subscriber doen't shutsdown but hangs
> and doen't consumes any messages when i restart broker and publish
> message.
> I have to manually shutdown and restart the subscriber to consume
> messages..
>
> I get below exception
All,
After i shutdown my broker,i see my subscriber doen't shutsdown but hangs
and doen't consumes any messages when i restart broker and publish message.
I have to manually shutdown and restart the subscriber to consume messages..
I get below exception
<2008/02/11 15:42:14.893><18587569><>
org.
All,
After i shutdown my broker,i see my subscriber doen't shutsdown but hangs
and doen't consumes any messages when i restart broker and publish message.
I have to manually shutdown and restart the subscriber to consume messages..
I get below exception
<2008/02/11 15:42:14.893><18587569><>
org.
I found the following information from another thread and it works:
Hi,
You can disable advisory support in your broker config file :
Regards,
Jonas
wha wrote:
>
> Hi,
>
> I'm very new to activeMQ.
>
> I can't figure out how to remove the exampleA queue or the
> ActiveMQ.Advisory.Con
Hi Joe,
I didn't pay too much attention to message size. In production our messages
are 34 bytes plus some headers. For this testing the average ended up being
26 bytes.
While testing the standalone broker, yes it was a completely default
configuration.
For the embedded brokers, I did not use
Hi,
I'm very new to activeMQ.
I can't figure out how to remove the exampleA queue or the
ActiveMQ.Advisory.Consumer.Queue.example.A topic.
Every time I delete it from the web admin interface it comes back. I don't
know where to go or look to make it stop. Something is constantly publishing
to
Check the last_acked_id column value in activemq_acks table.
Ack id might be too large for integer column.
I had similar issue with selector column,alterd the table (column size)
Stefan Arentz-2 wrote:
>
> Has anyone seen this one before? It looks like something internal to
> ActiveMQ's JDBC s
Check the last_acked_id column value in activemq_acks table.
Ack id might be too large for integer column.
I had similar issue with selector column,alterd the table (column size)
Stefan Arentz-2 wrote:
>
> Has anyone seen this one before? It looks like something internal to
> ActiveMQ's JDBC s
Hi Sean,
Curious to know the average message size used and whether you used the
default broker configuration?
Thanks,
Joe
www.ttmsolutions.com
Sean Bastille-2 wrote:
>
> I guess my first message was too long, but that's alright, I ended up
> getting the answers I needed. I figured I should l
LOL! I had just finished writing a test that uses a QueueBrowser and had
the same problem, so based on the prior issue I posted I put in a start()
connection and it worked.
On Feb 11, 2008 9:12 AM, James Strachan <[EMAIL PROTECTED]> wrote:
> On 11/02/2008, Jeroen van Bergen <[EMAIL PROTECTED]>
I guess my first message was too long, but that's alright, I ended up
getting the answers I needed. I figured I should let you guys in on the
results of my testing.
The summary of my initial write up is that my main requirement is message
throughput per host, so that is what my testing has been f
Hi
We once had the same issue (also with 4.1.1) and then discovered that
the messages were assigned to some consumer that basically crashed but
was still connected to the broker. Since 1000 messages is the default
prefetch size for a queue this might also be your problem. In JMX you
can see the con
Hi,
After reading the documentation and the pthread code, I see what's going on,
though I do think the pthread attribute and instance could be set to 0 in
the Thread constructor.
I definitely think there is a problem with my code which I'm trying to
narrow down. Is there any way to programmatica
On 11/02/2008, Jeroen van Bergen <[EMAIL PROTECTED]> wrote:
>
> I'm running a very basic instance of AMQ 5.0.0: just the supplied sample
> configuration, starting the broker with bin\activemq. My client application
> (Java SE) produces and consumes messages on a single queue. Both the
> producer an
I'm running a very basic instance of AMQ 5.0.0: just the supplied sample
configuration, starting the broker with bin\activemq. My client application
(Java SE) produces and consumes messages on a single queue. Both the
producer and the consumer use the
session.createXXX(session.createQueue(queueNam
Refer to this tutorial on pthreads attributes, our code usage is
correct: http://www.cs.cf.ac.uk/Dave/C/node30.html
Also see O'Reilly's Pthreads Programming book, pages 113-115.
On Fri, 2008-02-08 at 07:17 -0800, TheOnlyDan wrote:
> Hi,
>
> I'm fairly new to the ActiveMQ API. I have 2 C++ appl
Hi,
I'll try but my applications are a bit complex. Cutting them down to a clean
example might take some time. The pthread issue though is easy to notice
when reading the code.
Cheers,
Dan.
--
View this message in context:
http://www.nabble.com/Active-MQ-Client-crash-tp15356897s2354p15410423.h
Thanks for your fast reply, Rob.
I tried activeMQ 5.1.
The connection alive time is longer than 5.0 version that I used before.
But it still closes the connection after some while.
I attach the exception logs below.
Is there any configuration value for idle timeout?
-
18:34:04,249 DEBUG [In
I think you might have hit a real common gotcha...
http://activemq.apache.org/i-am-not-receiving-any-messages-what-is-wrong.html
On 11/02/2008, David Siefert <[EMAIL PROTECTED]> wrote:
> Hi,
>
> I am trying to use ActiveMQ to do 'quick & easy' unit testing for JMS
> message listeners. So far, no
Hi,
I am trying to use ActiveMQ to do 'quick & easy' unit testing for JMS
message listeners. So far, no luck. I've tried to reduce my problem as
small as possible to pinpoint the problem. Here is the code:
public class SimpleActiveMQTest {
private ConnectionFactory factory;
private Destinatio
26 matches
Mail list logo
