?
Second question -- assuming that duplex works, and I initiate the
connection from the _authenticating_ broker to the non-authenticating
one, why does AMQ still try to check the other broker's credentials ?
--
Regards,
Oleg Dulin
http://www.olegdulin.com
en
-
Red Hat, Inc.
Email: cib...@redhat.com
Twitter: davsclaus
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
--
Regards,
Oleg Dulin
http://www.olegdulin.com
to try building from latest source code and
try with a SNAPSHOT of 5.10.
On Tue, Mar 25, 2014 at 5:55 PM, Oleg Dulin
wrote:
I am running a similar test.
Replicated LevelDB, 3 Zookepers, 3 AMQ brokers with local_mem sync, I am
publishing messages on a queue using one thread, and taking them of
n the 5.10
branch. So you may want to try building from latest source code and
try with a SNAPSHOT of 5.10.
On Tue, Mar 25, 2014 at 5:55 PM, Oleg Dulin
wrote:
I am running a similar test.
Replicated LevelDB, 3 Zookepers, 3 AMQ brokers with local_mem sync, I am
publishing messages on a queue usin
(pub / sub running normally, keeping up with
each other)
--
Regards,
Oleg Dulin
http://www.olegdulin.com
I am trying to come up with a staged upgrade plan.
I need to upgrade the broker to take advantage of replicated LevelDB.
My clients use 5.8 amq libs. It seems to work.
Should I be on the look out for any incompatibilities ?
--
Regards,
Oleg Dulin
http://www.olegdulin.com
s.
>
> On Sat, Mar 22, 2014 at 8:20 AM, Oleg Dulin
> wrote:
>
> Dear Distinguished Colleagues:
>
> I need some sort of a redundancy mechanism, and need to brain storm.
>
> I am using AMQ 5.8, here is my problem.
>
> I wanted to set up RDS with multi-zone
appreciated.
--
Regards,
Oleg Dulin
http://www.olegdulin.com
leg
On 2013-11-03 15:00:43 +, Timothy Bish said:
On 11/03/2013 08:25 AM, Oleg Dulin wrote:
I believe my issue is related to this:
https://issues.apache.org/jira/browse/AMQ-3422
I got this exception:
java.lang.RuntimeException: java.io.IOException: Invalid location:
more
I couldn't restart no matter what. It's silly that kahadb got corrupted
because of a crash, defeats the whole purpose of a disk journal.
I ended up clearing out data directory and restarting, but that is suboptimal.
Any thoughts ?
--
Regards,
Oleg Dulin
http://www.olegdulin.com
it w/o an ack. So you need lots of messages. that
is why the new abort policy was introduced. I wonder if that is the
problem? Or would it be that the
prefetchRatePendingMessageLimitStrategy is doing an effective ack. Try
without that.
On 18 September 2013 11:41, Oleg Dulin
wrote:
Here are my
is that Z.> policy would kick
in and after some time I get an advisory message on
ActiveMQ.Advisory.SlowConsumers.Topic.Z.FOO.BAR -- but I don't.
The same test works with simple Java program….
What am I doing wrong ?
--
Regards,
Oleg Dulin
http://www.olegdulin.com
ep 12, 2013 at 1:26 PM, Oleg Dulin
wrote:
> Dear Distinguished Colleagues:
>
> I would like to be able to drop slow consumers . If a slow consumer is
> detected, I want it gone, and I want an advisory message to say "this
> consumer was dropped". I can't fi
Dear Distinguished Colleagues:
I would like to be able to drop slow consumers . If a slow consumer is
detected, I want it gone, and I want an advisory message to say "this
consumer was dropped". I can't find good documentation for this. Any
ideas ?
--
Regards,
Another factoid -- if I don't use "duplex" then all seems to be well.
On 2013-08-14 19:03:36 +0000, Oleg Dulin said:
One more note -- here is a kicker.
If I change the consumers to producer's IP, comment out hte producer,
and restart the program -- they get all their
One more note -- here is a kicker.
If I change the consumers to producer's IP, comment out hte producer,
and restart the program -- they get all their messages!
This is driving me nuts!
On 2013-08-14 18:59:55 +0000, Oleg Dulin said:
17595334911828795876
Content-Type:
catch(Exception exp)
{
exp.printStackTrace();
}
}
});
}
}
--
Regards,
Oleg Dulin
http://www.olegdulin.com
Perfect, thank you sir.
On 2013-08-06 15:25:16 +, Gary Tully said:
a temp destination is tied to the lifecycle of a connection, unless it
is destroyed via javax.jms.TemporaryQueue#delete it will be deleted
when the connection closes
On 6 August 2013 14:52, Oleg Dulin
wrote:
I do a
I do a number of request/response type operations where I send a
request and I create a temporary queue.
What is the lifecyle of a temporary queue ? At what point does it get
destroyed ?
Any advice is greatly appreciated.
--
Regards,
Oleg Dulin
http://www.olegdulin.com
it depends on the complexity of the app, the number of
consumers/producers, message throughput requirements, etc.
One connection can support lots of sessions and each session can support
lots of producers and consumers...
On Thu, Jul 25, 2013 at 5:14 PM, Oleg Dulin
wrote:
> Ca
Can I have a single connection for the entire application ?
Is there an argument for multiple ?
What's the right approach ?
--
Regards,
Oleg Dulin
http://www.olegdulin.com
when it gets into that state?
On Fri, Jul 19, 2013 at 12:26 PM, Oleg Dulin
wrote:
> I have two brokers set up on two servers. One is 10.194.2.1, the other is
> 10.194.2.2 .
>
> One of them has this i
t to expire after a couple of minutes which works OK for 99%
of the time. But once or twice a month we hit the 100% temp storage limit
and the server goes South.
Ralf
--
Regards,
Oleg Dulin
http://www.olegdulin.com
o connections
as opposed to duplex ?
Any thoughts are greatly appreciated.
--
Regards,
Oleg Dulin
http://www.olegdulin.com
However, now the broker restart becomes really slow because it seems to
do recovery sequentially on each journal.
Is there a way to speed this up ?
Help is greatly appreciated.
--
Regards,
Oleg Dulin
http://www.olegdulin.com
?
--
Regards,
Oleg Dulin
NYC Java Big Data Engineer
http://www.olegdulin.com/
validate ur use case on 5.8.
On 3 April 2013 22:33, Oleg Dulin
wrote:
> I am operating a cluster of brokers. Each broker connects to its neighbor=
s
> as follows (configuration from one of them):
>
>
> uri
ly to me.
The interesting thing is that when I run the client on my laptop,
everything works great. When I run the client on the server box -- I
start having issues.
--
Regards,
Oleg Dulin
NYC Java Big Data Engineer
http://www.olegdulin.com/
I need queue browser hasMoreElements method to return true/false and
not wait for messages to show up on the queue. Is there any way to
accomplish that ?
--
Regards,
Oleg Dulin
NYC Java Big Data Engineer
http://www.olegdulin.com/
seems to work.
Any thoughts and suggestions are greatly appreciated.
--
Regards,
Oleg Dulin
NYC Java Big Data Engineer
http://www.olegdulin.com/
September 2012 13:33, Oleg Dulin
wrote:
Gary - I am getting a 404 not found on your link, can you check ?
Gary Tully wrote:
This seems to be a match:
http://mail-archives.apache.org/mod_mbox/activemq-users/201108.mbox/%3ccah+vqmnhs7wwbzfqxbk151gocngbfmpzvxgqbgbdbzq1rzl...@mail.gmail.com%3E
On
012 12:44, Oleg Dulin
> wrote:
>> P.S.: I posted a ticket for this:
>>
>> https://issues.apache.org/jira/browse/AMQ-4077
>>
>>
>> --
>> Regards,
>> Oleg Dulin
>> NYC Java Big Data Engineer
>> http://www.olegdulin.com/
>
>
P.S.: I posted a ticket for this:
https://issues.apache.org/jira/browse/AMQ-4077
--
Regards,
Oleg Dulin
NYC Java Big Data Engineer
http://www.olegdulin.com/
line
that says this:
nextEntry = new
KeyValueEntry(current.keys[nextIndex], current.values[nextIndex]);
(that happens to be line 110)…
Any help is greatly appreciated.
--
Regards,
Oleg Dulin
NYC Java Big Data Engineer
http://www.olegdulin.com/
ng freed up.
Why ? This has got to be a misconfiguration...
--
Regards,
Oleg Dulin
NYC Java Big Data Engineer
http://www.olegdulin.com/
single JMS message need ?
--
Regards,
Oleg Dulin
NYC Java Big Data Engineer
http://www.olegdulin.com/
This seems to be related to the 2000 limit on the linkedblockingqueue
inside of VMTransport…
Where is this configured ?
On 2012-09-11 18:23:56 +, Oleg Dulin said:
Here is the stack trace:
One thread:
Name: LS:IndexItemQueue:2
State: BLOCKED on java.lang.Object@699b7e6 owned by
ontrol="false"
memoryLimit="512mb">
…
directory="${ac
this, it might shed some light
http://fusesource.com/docs/esb/4.3/amq_persistence/FuseMBPersistCursorsTypes.html#FuseMBPersistCursorsFile
http://activemq.apache.org/message-cursors.html
--
Regards,
Oleg Dulin
NYC Java Big Data Engineer
http://www.olegdulin.com/
ursor.
If I do this:
What is the cursor ?
--
Regards,
Oleg Dulin
NYC Java Big Data Engineer
http://www.olegdulin.com/
messages got all consumed.
--
Regards,
Oleg Dulin
NYC Java Big Data Engineer
http://www.olegdulin.com/
this helps,
Torsten Mielke
tors...@fusesource.com
tmie...@blogspot.com
On Sep 9, 2012, at 1:45 PM, Oleg Dulin wrote:
Dear Distinguished Colleagues:
Here is my use case.
For the most part my consumers are able to keep up with the workload,
but once a week or so there is a huge burst of messages
Dear Distinguished Colleagues:
Here is my use case.
For the most part my consumers are able to keep up with the workload,
but once a week or so there is a huge burst of messages (millions) that
need to be queued up for processing. We don't want producers blocked,
so we want all the messages g
43 matches
Mail list logo
