I experienced similar issues using the same classes. I couldn't get around
them, so I upgraded to the tentative 5.2 activemq release candidate (
http://www.nabble.com/-VOTE--ActiveMQ-5.2.0---RC1-td19411389.html), which
fixed a number of bugs that might have caused this behavior (
http://issues.apa
I've seen this behaviour w/4.1, but on the consumer side. If you use failover
and disable maxInactivityDuration, you disable the underlying keep alive
heart beat feature, which periodically checks the connection. Therefore, if
the network goes down the underlying failover transport hangs indefinit
My producer uses Spring's JmsTemplate with PooledConnectionFactory. The
Spring configuration is below. Then I send 10 messages every second. And I
notice that the producer doesn't send message smoothly. Every so often it
would hang for a couple of seconds and then a huge spike of load would come
i
Joe,
Thanks for the response.
Joe Fernandez wrote:
>
> By any chance, do you have 'maxInactivityDuration' turned off?
>
We do indeed have set the maxInactivityDuration=0. The exact URL looks like:
failover:(tcp://server:54663?wireFormat.maxInactivityDuration=0)?maxReconnectAttempts=10
ok. thanx !
--
View this message in context:
http://www.nabble.com/producer-%3Esend-blocks-%28-ActiveMQ-CPP-%29-tp19718849p19732422.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
In order to resolve the issues that were being seen with failures on the
client end because of producer flow control the CPP client doesn't
currently have a fully functional async send mechanism. It is planned
to be working again in the next release. There are several other pieces
that have to be
Hi,
I'm trying to use ActiveMQ to connect with an ESB from websphere suite.
The problem I have it's I only can connect to an Local Queue in Websphere
MQ, when you connect 2 MQ in websphere you create a "remote queue", and you
connect both MQ using channels "receiver and sender", but if I use Acti
On Mon, Sep 29, 2008 at 2:28 AM, James Strachan
<[EMAIL PROTECTED]> wrote:
> Everything Bruce just said plus...
>
> 2008/9/28 Andres Rangel <[EMAIL PROTECTED]>:
>> Hi,
>> I am writting my on jms libraary for an internal application using java, and
>> would like to know what should I cache, connect
Can someone help me?
On Fri, Sep 26, 2008 at 3:10 PM, Mick Knutson <[EMAIL PROTECTED]>wrote:
> The funny thing is, when I have an error with the message coming from this
> queue, which I do because process(Exchange) does not expect my message body,
> the message gets routed to the proper deadLett
Hello,
I use a network of two master/slave brokers with ActiveMQ 5.1.
Both masters have the following network configuration :
My problem comes from the « store and forward » mechanism. Here is my test :
- I send messages on a queue of master broker A.
- I consume those messages con
Guys,
could anyone give me an example of usage message selectors with Message
Driven beans?
I want to process my messages by priority so I think using selectors will be
a correct choice.
Has somebody implemented messages processing by priority using MDBs?
Thanks in advance!
--
View this message
2008/9/23 kumarchill <[EMAIL PROTECTED]>:
>
> Hey,
> I'm new to ActiveMQ.
>
> I have a situation where there are many publishers publishing messages and
> many subscribers that subscribes these messages.
> Assume
> ->For every subscriber there is one ActiveMQ instance that it listens.
> ->ActiveMQ
2008/9/22 Janesh S <[EMAIL PROTECTED]>:
>
> Hi,
>
> Is there a tool/code with which we can do health check of ActiveMQ. This is
> needed to make sure that ActiveMQ connection is fine and the queue/topic is
> ALIVE. Thanks.
If you use the Failover transport then ActiveMQ client will
automatically r
found :)
the problem was that every sent message wasn't persistent, now
it's working. i didn't know i had to enable persistance for every
message to be able to be retrieved by a durable subscription.
I think that i missed the documentation on that!
thanks again,
yari
James Strachan ha scritto:
>
ok, it actually does send async, sort of...
I am sending 30 msgs, and with a roundtrip latency of 100 ms
it will take approx 3 seconds to send, since it wont send the next
msg until it has gotten a ack from the previous.
Sodan wrote:
>
> Hi there
>
> Have been integrating ActiveMQ CPP client
2008/9/29 Yari Marchetti <[EMAIL PROTECTED]>:
> oki, this makes sense indeed, and now i understand why
> i keep on getting always the same message every time.
>
> But now my problem is on durable subscription because
> if i can't get messages that were delivered while i was
> disconnected. For exam
oki, this makes sense indeed, and now i understand why
i keep on getting always the same message every time.
But now my problem is on durable subscription because
if i can't get messages that were delivered while i was
disconnected. For example:
1) 'A' makes a durable subscription to 'test' topic
What versions of ActiveMQ and the JDK are you using? If you're using JDK 1.4,
try bumping it up to 1.5.
Joe
Get a free ActiveMQ user guide @ http://www.ttmsolutions.com
MonaTakle wrote:
>
> I've installed activemq. but after starting activemq encountered the
> following error :
> Exception in
subscription recovery policy is for non-durable topic subscribers
2008/9/26 Yari Marchetti <[EMAIL PROTECTED]>:
> Hi everyone,
> i was playing with durable subscriptions and observed a
> behavior that seems strange to me. I configured ActiveMQ
> with
>
>
>
> for every topic, and then created a du
Reading the link you provided, i found that:
"So we support a timed or fixed size recovery buffer so that
if you reconnect to another broker within some time period
(...), then *any messages you missed during the downtime*
are redelivered before new messages are delivered to you."
so i tried this
Sorry, I had to leave this issue for a while, but am now on it again.
I've made a simple test to restart the broker, but get the same exception as
previously; BrokerStoppedException.
import org.apache.activemq.broker.BrokerService;
public static void main(String[] args) {
try {
Broke
Everything Bruce just said plus...
2008/9/28 Andres Rangel <[EMAIL PROTECTED]>:
> Hi,
> I am writting my on jms libraary for an internal application using java, and
> would like to know what should I cache, connections or sessions (all from the
> same connection)?
>
> Also, would like to know if
22 matches
Mail list logo
