ducer
don't have to consider how to save the messages itself.
On Thu, Jun 26, 2014 at 8:35 PM, Christian Posta
wrote:
> Just curious why you have producer flow control off if you expect it to
> honor memory limits?
>
> On Wednesday, June 25, 2014, Li Li wrote:
>
>>
I gave 3GB total heap space of activemq, the XX:NewRatio=2. So
new generation 1GB and old generation 2GB. And I also config
memoryUsage limit="1 gb"
ACTIVEMQ_OPTS_MEMORY="-Xms1G -Xmx3G -XX:+UseConcMarkSweepGC
-XX:+UseParNewGC -XX:CMSInitiatingOccupancyFraction=70 -XX:NewRatio=2"
There are on
>
>
>> 在 2014年6月18日，11:55，"Li Li [via ActiveMQ]"
>> 写道：
>>
>> the messages of the queue are all consumed. But the store percent is
>> not zero. How can I free the disk space?(the messages are persistent)
>>
>>
>> If you reply to thi
the messages of the queue are all consumed. But the store percent is
not zero. How can I free the disk space?(the messages are persistent)
there are 400 consumers on a queue, and in the web ui, it says there
are 526 messages.
I clicked the message and it shows Messages(0)
Sequence Codec Persistent Expires Prefetched Acquirer Size
17370 openwire true no false 217.78 kb
what's wrong with it?
I remeber activemq 5.9 support it.
thanks. but why the latest version don't support newer version, what's
new in v9 and v10?
On Fri, Apr 11, 2014 at 10:06 PM, Timothy Bish wrote:
> On 04/11/2014 08:01 AM, Li Li wrote:
>>
>> I am using activemq 5.9's jar files. how to let server support highe
I am using activemq 5.9's jar files. how to let server support higher
version such as v9 or v10?
Exception in thread "main" javax.jms.JMSException: Invalid version: 8,
could not load org.apache.activemq.openwire.v8.MarshallerFactory
at
org.apache.activemq.util.JMSExceptionSupport.create(J
I used to use activemq 5.9 and now want to switch to apollo. but I
used to use Statistics Plugin to get queue size.
the server can't work. it says:
2014-04-11 11:53:49,591 | WARN | Transport Connection to:
tcp://192.168.11.172:45734 failed: java.net.SocketException: Broken
pipe | org.apache.activemq.broker.TransportConnection.Transport |
ActiveMQ InactivityMonitor Worker
even I stop the server and restart it.
in the server's log, only one line message is printed.
2014-04-09 10:03:17,222 | WARN | Transport Connection to:
tcp://172.19.34.88:51245 failed: java.io.EOFException |
org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ
Transport: tcp:///172.19.34.88:51245@61616
the exception sta
very strange. the orginal pid is 11639. after stop. this pid not exist.
but there is another activemq progress with different pid.
it can still be visited by client
$ ./bin/activemq stop
INFO: Using default configuration
(you can configure options in one of these file: /etc/default/activemq
/home/
I found the problem. the queue not yet exist so the program hangs
On Thu, Apr 3, 2014 at 6:40 PM, Li Li wrote:
> suddenly, the statisticsBrokerPlugin do not work(I have restarted the
> sever today). I can send and receive messages. but I can't get queue
> size from it. and t
suddenly, the statisticsBrokerPlugin do not work(I have restarted the
sever today). I can send and receive messages. but I can't get queue
size from it. and there is a warn:
Queue ActiveMQ.Statistics.Destination.fetch_queue2 has no consumers
fetch_queue2 is my queue
from hawtio
Percentage blocked
hen it "hanged"? And what constituted
> hanging? Couldn't send more messages, couldn't receive messages?
>
> On Fri, Mar 28, 2014 at 12:23 AM, Li Li wrote:
>> I am using the default configuration(maximum 4G heap) and > percentOfJvmHeap="70" />
>
I found the localhost directory's size is about 20GB
>du -sh *
4.0K activemq-DC-TEST-1.pid
1.0M activemq.log
0 audit.log
89M kahadb
20G localhost
why the disk space is not freed by activemq?
On Fri, Mar 28, 2014 at 5:41 PM, Li Li wrote:
> I found this log:
> 2014-03-28 17:37
I found this log:
2014-03-28 17:37:38,918 | INFO |
Usage(default:temp:queue://TEST1:temp) percentUsage=99%,
usage=21500083502, limit=21474836480,
percentUsageMinDelta=1%;Parent:Usage(default:temp) percentUsage=100%,
usage=21500083502, limit=21474836480, percentUsageMinDelta=1%: Temp
Store is Full
sorry max heap is 1G, not 4G
On Fri, Mar 28, 2014 at 3:23 PM, Li Li wrote:
> I am using the default configuration(maximum 4G heap) and percentOfJvmHeap="70" />
> I send many small size TextMessages to server and it hangs
>
> I use jmap -heap and found that the free memo
I am using the default configuration(maximum 4G heap) and
I send many small size TextMessages to server and it hangs
I use jmap -heap and found that the free memory is less than 100MB and
the server can do nothing but do gc. but gc can't free anything.
client can't even connect to server.
I use .
is it possible to implement fork and join pattern in activemq? in
request/reply scenario, one request may product more than one message,
so complete response is the aggregation of many individual response.
Also, we have to deal with timeout of some response and aggregate
partial responses.
e.g.
R
hostname is the ip? where should I add this?
On Tue, Mar 11, 2014 at 7:02 PM, Gary Tully wrote:
> java.rmi.server.hostname may be the missing piece
> On 10 Mar 2014 02:35, "Li Li" wrote:
>
>> I have successfully configure activemq to support jmx before. But in
>>
by using ./configure --with-openssl=/usr/local/ssl --with-apr=/usr/local/apr/
I have successfully make it.
thanks.
On Tue, Mar 11, 2014 at 8:57 AM, Li Li wrote:
> openssl version
> OpenSSL 0.9.8e-fips-rhel5 01 Jul 2008
> I am not a expert of linux, so how do I "remove" old ve
openssl version
OpenSSL 0.9.8e-fips-rhel5 01 Jul 2008
I am not a expert of linux, so how do I "remove" old version and
install new version?
On Mon, Mar 10, 2014 at 9:34 PM, Timothy Bish wrote:
> On 03/10/2014 07:41 AM, Li Li wrote:
>>
>> 7. after I use ./configure --with
c/main'
make[1]: *** [all-recursive] 错误 1
make[1]: Leaving directory `/home/lili/activemqcpp/activemq-cpp-library-3.8.2'
make: *** [all] 错误 2
On Mon, Mar 10, 2014 at 6:35 PM, Li Li wrote:
> my environment:
> 1. lsb_release -a
> LSB Version:
> :core-3.1-amd64:core-3.1-ia32:core-
my environment:
1. lsb_release -a
LSB Version:
:core-3.1-amd64:core-3.1-ia32:core-3.1-noarch:graphics-3.1-amd64:graphics-3.1-ia32:graphics-3.1-noarch
Distributor ID: RedHatEnterpriseServer
Description:Red Hat Enterprise Linux Server release 5.5 (Tikanga)
Release:5.5
Codename: Tika
I have successfully configure activemq to support jmx before. But in
the new server machine, I can't get jmx working now.
I follow all the instructions of http://activemq.apache.org/jmx.html
1. http://activemq.apache.org/schema/core";
useJmx="true" brokerName="localhost"
dataDirectory="${activemq.
thanks.
On Mon, Mar 10, 2014 at 9:52 AM, Timothy Bish wrote:
> On 03/09/2014 09:19 PM, Li Li wrote:
>>
>> hi all,
>> I know how to get queue size by jmx in java, but how to get it by
>> c++ client?
>>
> Try this:
> http://activemq.apache.org/stati
hi all,
I know how to get queue size by jmx in java, but how to get it by
c++ client?
I think I should deal with something like thread pool. I am familiar
with java thread api such as ThreadPoolExecutor, Future,
CompletionService. but is there any equivalence library in CMS?
On Fri, Mar 7, 2014 at 10:40 AM, Li Li wrote:
> hi all,
> I want to wrapper a high level l
hi all,
I want to wrapper a high level library using activemq to
implement a request-reply service. the user of this library have 2
kind of api --synchronized blocking and asynchronized callback.
usage1:
MainThread:
RequestResponseWrapper wrapper=new RequestRespon
Wed, Mar 5, 2014 at 6:09 PM, Noel OConnor wrote:
> Be careful according to the JMS 1.02 spec JMS sessions aren't thread safe
> so I don't recommend taking that approach.
> I haven't used the individual acknowledge so you'll have to check that
> yourself.
>
>
&
IDUAL_ACKNOWLEDGE
>
>
> On Wed, Mar 5, 2014 at 6:48 PM, Li Li wrote:
>
>> hi all,
>> I want to process a batch of message using my own priority
>> algorithm. But in JMS, I can't acknowledge a single message and can
>> only acknowledge a session. So I decid
e JMS spec
On Wed, Mar 5, 2014 at 5:08 PM, Noel OConnor wrote:
> have you seen ActiveMQSession.INDIVIDUAL_ACKNOWLEDGE
>
> see
> http://activemq.apache.org/maven/apidocs/org/apache/activemq/ActiveMQSession.html#INDIVIDUAL_ACKNOWLEDGE
>
>
> On Wed, Mar 5, 2014 at 6:48 PM, Li Li
hi all,
I want to process a batch of message using my own priority
algorithm. But in JMS, I can't acknowledge a single message and can
only acknowledge a session. So I decide to do it like this:
1. Create N(=1) sessions
2. using a thread to manage session acknowledge like:
, 2014 at 11:57 AM, Li Li wrote:
>
>> I am using the following code snippet to send messages to a queue. How
>> to make priority queue enabled?
>> class Producer{
>> private ActiveMQConnection conn;
>> private QueueSender sender;
>> private QueueSessio
[ERROR] Failed to execute goal on project activemq-leveldb-store:
Could not resolve dependencies for project
org.apache.activemq:activemq-leveldb-store:jar:5.9.0: Failed to
collect dependencies at org.apache.hadoop:hadoop-test:jar:1.0.0 ->
org.apache.mina:mina-core:jar:2.0.0-M5: Failed to read arti
ts
> get resent to the queue.
>
>
> On 3 March 2014 09:54, Li Li wrote:
>> thank you very much. is it possible for client to send a message back
>> to the front of the queue? I mean if consumer A can't process this
>> message, it create a new message(the new message
y.
>
> Is that what you're asking? Otherwise you set the priority on a
> message by using the JMS APIs.
>
> On Mon, Mar 3, 2014 at 3:39 AM, Li Li wrote:
>> as in http://activemq.apache.org/how-can-i-support-priority-queues.html,
>> I should enable queue priority
as in http://activemq.apache.org/how-can-i-support-priority-queues.html,
I should enable queue priority by xml configuration. is it possible to
use java api to configure this?
. I know I can set message priority. But I don't know
whether it's performant.
On Mon, Mar 3, 2014 at 5:47 PM, Rob Davies wrote:
> Beanstalkd might be a better fit for your use case - it's job based - and
> iirc allows the client to reject jobs
>
>
>> On 3 Mar 20
f stated it wouldn't be a simple solution.
>
>
> On Mon, Mar 3, 2014 at 6:41 PM, Li Li wrote:
>
>> sorry to hear that. I need this feature very much. is it possible to
>> "extend" activemq to achive this? is it difficult to modify the
>> dispatch logic of
from my iPhone
>
>> On Mar 2, 2014, at 9:36 PM, "Li Li [via ActiveMQ]"
>> wrote:
>>
>> hi all,
>> can a queue message consumer "refuse" a message after receive a message?
>> because a client don't know the message in advan
uld try rolling it back. If not (I
> think) the message should be redelivered if you throw a runtime exception
> from within the MDB.
>
>
> On Mon, Mar 3, 2014 at 3:35 PM, Li Li wrote:
>
>> hi all,
>> can a queue message consumer "refuse" a message after re
hi all,
can a queue message consumer "refuse" a message after receive a message?
because a client don't know the message in advance.
onMessage(Message msg){
if(CannotProcess(msg)){
//refuse this message
}
}
what I need is: if the message can't be
what's the status of this sub project? is there any real world use
case? what's the desgin difference compared to non-realtime version?
thanks. Since JMS can't guarantee only once, it's the client's
responsibility to make things correct. it should either using
idempotent processing(running a task twice is no harm) or using other
tools(such as zookeeper or database to make data consistent). So I
think there is still many dirty work
for your consumers so that your consumer
> can pull real task message from broker one by one.
> Fast consumers can have a chance to pull more messages than slow consumers.
> If consumers still can not process real tasks in time, increase consumers
> or tune performance for consumers.
>
&
I've read the jms specification and questions by google such as
http://stackoverflow.com/questions/2991412/anyone-know-exactly-which-jms-messages-will-be-redelivered-in-client-acknowledge
. But I still confused about it.
Another question is: how can a consumer tell the broker to
redelevery a mes
I found the problem. I have only 160 messages and all are dispatched
to a single worker.
how to avoid this?
On Thu, Jan 23, 2014 at 11:27 AM, Li Li wrote:
> I modified it to use multithreads, but still only one work.
> I use jstack and find other threads are blocked by Messa
I modified it to use multithreads, but still only one work.
I use jstack and find other threads are blocked by Message msg =
receiver.receive();
public class Worker extends Thread{
public Worker() throws Exception{
recvConnFactory = new ActiveMQConnectionFactory(
queueC
public class Worker implements MessageListener{
public Worker() throws Exception{
recvConnFactory = new ActiveMQConnectionFactory(
queueConnString);
recvQConn = recvConnFactory.createQueueConnection();
recvQConn.start();
recvSession = recvQConn.cr
hi all
I want to share a session among many threads and after do real work
the message is acknowledged:
class Dispatcher implements MessageListener{
Thread[] workers;
public void init(){
session = connection.createQueueSession(false,
Session.CLIENT_ACKNOWLEDGE);
I am using activemq to implement the producer and consumer model. the
producer simply dispatch jobs to queue and consumer do the hard job.
How can I config the queue's max size? That is, if size of message not
consumed exceed this value, then producer will be blocked(or faied
with some exception in
in-activemq.html
>
> On Thu, Dec 26, 2013 at 11:52 PM, Li Li wrote:
>> hi all,
>> activemq ensure a message sent to a queue will be consumed by
>> exactly one consumer. But what happens when the consumer receive this
>> message and crash and don't do anything
hi all,
activemq ensure a message sent to a queue will be consumed by
exactly one consumer. But what happens when the consumer receive this
message and crash and don't do anything with this message. How can I
ensure the consumer really did his job? how to ensure if the consumer
crashed, the mes
55 matches
Mail list logo
