Well, thank you for the insights about the PublishedAddressPolicy stuff. I
completely ignored that! Besides, I'll definitely try with "finite" ip
addresses instead of 0.0.0.0 one.
Still, I cannot understand why a client initially connected to a ssl
connector should switch to tcp just because serve
I believe there was no other errors prior to that exception, i will try to
reproduce and update you on it.
I downloaded the source yesterday form git:
parent: e57aeb3) | patch
See AMQ-4886. Updated tearDown so it can't hang, reduced timeouts, updated
to JUnit4
--
View this message in con
Well, thank you for the insights about the PublishedAddressPolicy stuff. I
completely ignored that! Besides, I'll definitely try with "finite" ip
addresses instead of 0.0.0.0 one.
Still, I cannot understand why a client initially connected to a ssl
connector should switch to tcp just because serve
> Client-side I specified a connection string that point to NIO+SSL connector.
> The point is that after a while the client switch from NIO+SSL to pure NIO.
> Is this the expected behavior for client? I would expect that a client does
> not change protocol.
Hi Matteo,
I spent a lot of time debugg
I'm debugging for days the behavior of NIO+SSL transport against the
updateClusterClients, rebalanceClusterClients and
updateClusterClientsOnRemove props.
I have a broker configured with two different transport conn: NIO and
NIO+SSL, something like
nio://0.0.0.0:61616
nio+ssl://0.0.0.0:61619
consumer.receive(poll timeout in milli)
On 15 November 2013 16:28, Ned Wolpert wrote:
> With prefetch=0, the client polls the server then, right? Is polling
> frequency a settable value? (Though as I write this, I'm assuming if so,
> it would be set on the client-side.)
>
>
> On Fri, Nov 15, 201
immediately if there are no consumers.
On Fri, Nov 15, 2013 at 9:08 AM, wrote:
> How long before they fall of the earth? :-) I see the messages still there
> from yesterday.
>
> Regards,
>
> Barry Barnett
> WMQ Enterprise Services & Solutions
> Wells Fargo
> Cell: 704-564-5501
>
>
> -Origi
With prefetch=0, the client polls the server then, right? Is polling
frequency a settable value? (Though as I write this, I'm assuming if so,
it would be set on the client-side.)
On Fri, Nov 15, 2013 at 4:55 AM, Gary Tully wrote:
> prefetch=0 will do it, so long as you don't use a messageliste
How long before they fall of the earth? :-) I see the messages still there
from yesterday.
Regards,
Barry Barnett
WMQ Enterprise Services & Solutions
Wells Fargo
Cell: 704-564-5501
-Original Message-
From: Christian Posta [mailto:christian.po...@gmail.com]
Sent: Friday, November 15,
anything that flows to a topic (including advisory topics) that
doesn't have any consumers will "fall off the face of the earth".. so
there won't be too much resource usage to be concerned about. if
you're not using the advisory messages, or not doing any network of
brokers, you can disable advisor
Not really. It's not going to be queryable like a sql database.
You can apply selection criteria on headers as a consumer, but even
that gets applied to messages that have been paged in and are in
broker memory.
What specifically are you trying to do? ie... what problem are you
solving.. why do yo
Hi that exception should have also printed out a cause. Could you
include that too? If you built it yourself, which git commit did you
build? If you downloaded a snapshot whats the file name of the
download?
On Fri, Nov 15, 2013 at 8:46 AM, kal123 wrote:
> I am using the latest changes from tr
Hi Tim
I will do that. Thanks!
Rgds
JL
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Rollback-NACK-a-single-message-tp467p4674559.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
the issue seems to happen when broker that is being stopped generated the
following exception.
Store getting corrupted due to the way the stop is handled?
2013-11-15 09:26:52,881 | WARN | Transport Connection to:
tcp://10.44.173.146:47163 failed: java.io.IOException: Connection reset by
peer | o
On 11/15/2013 09:37 AM, jlpedrosa wrote:
Hi
When I inspected the API, I thought about it, but it looks like for every
message I would need to create a session, and a consumer per message, which
sounds extremely heavy and we expect a significant amount of messages. (for
a given consumer I need
Hi
When I inspected the API, I thought about it, but it looks like for every
message I would need to create a session, and a consumer per message, which
sounds extremely heavy and we expect a significant amount of messages. (for
a given consumer I need a session to rollback that message), so thi
Hi,
I have two ActiveMQ brokers with MS SQL JDBC persistence (I use ServiceMix).
Both brokers are accessible through HTTP:
http://amq-srv1:8181/activemqweb/ ->It's alive.
http://amq-srv2:8181/activemqweb/ ->It's alive but in slave mode.
I have a load balancer setup (Cisco ACE) and all traffic pas
Dear Sir,
i have a problem and i need to be fix, therefore i will send you my
configuration for both broker A and B for different activemq running on the
same mashine:
my problem is that the queue some time from BrokerA is not to display and
also the connections. If i stop both of them and start
Hi guys,
Is it possible to find message inside queue by some criteria using JMX API?
For example, by header value or by content of the message.
Looking forward for your response.
Best regards, Evgeniy
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Is-it-possible-to-fi
On 11/15/2013 07:36 AM, jlpedrosa wrote:
Hi All,This also leads to the same problem: the execution of the event must
be done in the same thread that ActiveMQ uses, otherwise I can't throw the
exception to the listener.
When the message arrives, I just put the message on a thread pool. That is
the
I am using the latest changes from trunk and i see following error after
failover (still getting corrupted?)
2013-11-15 06:44:53,606 | INFO | jolokia-agent: Using access restrictor
classpath:/jolokia-access.xml | /hawtio | main
2013-11-15 06:44:53,743 | INFO | ActiveMQ WebConsole available at
ht
I just tried a persistent message and it ended up on the ActiveMQ.DLQ. I see
the enqueue count go up on the ActiveMQ.Advisory.Queue Topic, the
ActiveMQ.Advisory.Expired.Queue and the ActiveMQ.Advisory.MessageDLQd.Queue as
well. For these Advisory queues and topics, do they need to be cleared t
Defining the connection factory in a separate blueprint file works.
If it is not possible to access the osgi namespace inside the activemq.xml
file, how can I read properties from the osgi configuration admin service,
since this is the way to configure modules in apache karaf?
It's still necessar
that has got to be a deployment option via websphere when the RAR is
configured. The ra.xml indicates that it supports XA, but when it is
deployed this can be overridden to be Local or No - so check the
websphere doc re rar configuration
On 12 November 2013 03:53, SaniO wrote:
> I am using Active
Hi All,This also leads to the same problem: the execution of the event must
be done in the same thread that ActiveMQ uses, otherwise I can't throw the
exception to the listener.
When the message arrives, I just put the message on a thread pool. That is
the approach to implement multi thread process
prefetch=0 will do it, so long as you don't use a messagelistener
directly. via spring the listener does a receive(...) under the hood
so it will be ok with prefetch=0
On 14 November 2013 16:14, Ned Wolpert wrote:
> After I say you wrote 'prefetchExtension=false' I looked it up and found
> this b
darn formatting. I pushed that change, so you can see the mapping with:
log4j.logger.org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter=DEBUG
https://git-wip-us.apache.org/repos/asf?p=activemq.git;a=blobdiff;f=activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/Multi
you need a little enhancement to add some logging to the choice of
adapter on a per destination basis. The choice is made when the
destination is created. A mod to
org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter#getMatchingPersistenceAdapter
something like:
git diff
activemq-kahadb
Hi!
First of all, Thanks for the support.
I am not really sure how to implement what you said:
I am actively listening to messages:
/consumer.Receive();/
So AFAIK I can't throw an exception up to NMS stack:
Are you suggesting that I listen in event mode? IE:
/consumer.Listener+=new MessageListene
Hello,
You can see the descriptions of all available advisory topics there:
http://activemq.apache.org/advisory-message.html
I guess that the two that you observe are these ones:
ActiveMQ.Advisory.Expired.Queue that receives an advisory message each time
a message expires on a queue.
The advisor
Ok, issue created: AMQ-4889
I attached to the issue a couple of simple projects to reproduce the issue.
Apparently this issue affects the ProxyConnector only, not the standard
TransportConnector.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Proxy-Connector-memory-con
I tried enabling DEBUG level logging but it is not logging for destinations
in persistence store. I want to log for messages, which persistence store
they are going into.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Logging-a-message-for-Multi-kahaDB-tp4674011p4674524.
32 matches
Mail list logo
