Ok, I went and installed the activemq package for ubuntu. It might not
be the latest, but does run. However, I can't seem to get into the console:
thufir@doge:~$
thufir@doge:~$
thufir@doge:~$ java -jar NetBeansProjects/ActiveMQ/dist/ActiveMQ.jar
SLF4J: Failed to load class "org.slf4j.impl.Sta
I'm just trying to use activemq as here:
http://java.dzone.com/articles/java-message-service-jms
where is the JAR for resolving:
error: cannot find symbol ActiveMQConnectionFactor
I downloaded the .tar.gz from apache, just not sure which of the many
JAR's in that download are needed to run
sorry. wrong list :-P
On Fri, Mar 6, 2015 at 2:25 PM, Kevin Burton wrote:
> What’s the best way to monitor nodetool status being down? IE if a
> specific server things a node is down (DN).
>
> Does this just use JMX? IS there an API we can call?
>
> We want to tie it into our zabbix server so w
What’s the best way to monitor nodetool status being down? IE if a specific
server things a node is down (DN).
Does this just use JMX? IS there an API we can call?
We want to tie it into our zabbix server so we can detect if here is
failure.
--
Founder/CEO Spinn3r.com
Location: *San Francisco
How do you guys feel about me contributing unit tests with hard coded
timeouts?
Some of my code tests to verify locks aren’t causing massive latency but
the only way I can really do this is to have a hard coded timeout of say
50-100ms.
The problem is that this can lead to flakey tests.
The new s
> If the stat is right, you'd see the # bytes used in the store climbing as
> well. (That stat is available in JMX, but I'm not sure it's on the web
> console.)
Except I've got a couple dozen queues and they all end up writing to disk
(overflowing in-memory limits). So aggregate disk (or store)
The SlowAckConsumerAbortStrategy is definitely still live code. But it
won't interrupt the client code; the broker will ask the client to abort,
but the client will finish processing the current message before honoring
the abort request.
On Mar 6, 2015 12:25 PM, "James A. Robinson" wrote:
> On F
If the stat is right, you'd see the # bytes used in the store climbing as
well. (That stat is available in JMX, but I'm not sure it's on the web
console.)
On Mar 6, 2015 11:52 AM, "Matthew Patton" wrote:
> For all the documentation out there I can't find any mention as to parse
> order of active
Hey Gary. Thanks for the feedback.
I feel very confident about the quality of the fix as we discussed it in
another thread. I can post that thread to the JIRA if it helps.
I can create tests for this but it would have to be in a separate branch
that would land first (I would think) . That bran
On Fri, Mar 6, 2015 at 8:37 AM, arun196 wrote:
> I have a consumer that processes orders from messages received from activemq.
> I would like to set a timeout in case the order processing takes over 5
> minutes.
I'm sorry, it's not clear to me from your description what
it is that you are intendi
For all the documentation out there I can't find any mention as to parse order
of activeMQ.xml as it relates to policy entries.
Is it first match? Last match? Most specific match? For example:
...
Thanks James!
--
View this message in context:
http://activemq.2283324.n4.nabble.com/java-lang-IllegalArgumentException-Invalid-connect-parameters-connectionTimeout-1000-tp4692572p4692669.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
I have a consumer that processes orders from messages received from activemq.
I would like to set a timeout in case the order processing takes over 5
minutes.
I have property 'timeout' set in brokerURL. Looks like its not the one for
the requirement. Any ideas please?
--
View this message in c
UPDATE:
I upgraded to ActiveMQ 5.11.1 and the exception is no longer thrown.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Cannot-set-consumer-option-exception-thrown-tp4692614p4692648.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
When messages are transmitted via ActiveMQ presumably there is some form of
queuing (pun definitely intended) of messages behind the scenes to provide
the greatest likelihood that messages will make it to their destinations
(the degree of which is controlled by various configuration settings). I
a
I had a quick peek at #65 and it seems a little complicated at first glance :-(
The solution seems elegant enough but I wonder if the problem is somewhere else.
gc should not have to stop the world and could also be two stage -
removing and purging
so that the contention with producers/consumers is
not really. the exception is the solution - telling you that the
transaction rolled back and it has no idea if it was a success or
failure.
This is the commit reply lost scenario. The client can't distinguish a
missing reply from a remote request that did not complete.
This is a situation where yo
I'm using ActiveMQ 5.8.0 and Java 1.7.
I tried to set a consumer option to make the consumer retroactive by
appending the option to the topic name when creating the topic destination:
destination =
session.createTopic("topicName?consumer.retroactive=true");
This is how we are instructed to
karcel wrote
> Exception in thread "main" java.lang.NoClassDefFoundError:
> org/fusesource/mqtt/codec/PINGRESP
> at org.apache.activemq.transport.mqtt.MQTTProtocolConverter.
>
> (MQTTProtocolConverter.java:87)
> at org.apache.activemq.transport.mqtt.MQTTTransportFilter.
>
> (MQTTTrans
19 matches
Mail list logo
