Hi folks,
I'm trying to transfer a 5.7 config to 5.10.0. All is well apart from
camel.xml. Even with no routes or beans defined, including camel.xml in
activemq.xml produces the error:
2014-10-23 16:23:21,647 | ERROR | Failed to load: class path resource
[activemq.xml], reason: Error creating
turned out a 3rd party jar in the lib directory was still compiled against
5.8.0. Compiling it against 5.10.0 solved the problem.
Thanks,
Alistair
-
mov eax,1
mov ebx,0
int 80
On 23/10/2014 22:20, artnaseef a...@artnaseef.com wrote:
Did the jetty.xml file get copied as-is
a broker restart is
required before it can get any messages from the route.
Is this just normal behaviour?
thanks,
Alistair
---
Alistair Young
Senior Software Engineer
UHI@Sabhal Mòr Ostaig
FWIW, the network was switching to a VPN connection after the broker had
started and the client had connected. It was also a VPN connection that
couldn't do nslookups. Not doing that and the routing from scratch seems
to be fine.
Alistair
---
Alistair Young
Senior Software
Is there a way to find a particular message in a topic, either via a header
name/value or based on message content? e.g. if I have a message I know may be
in the topic and it has a message body that would match a particular regex, or
has a header name with a particular value, is it possible to
Tully 18/07/12 1:16 PM
that feature does not exist, it would require some extension to
org.apache.activemq.broker.jmx.TopicSubscriptionView
On 18 July 2012 11:21, Alistair Young wrote:
Is there a way to find a particular message in a topic, either via a header
name/value or based on message
to find messages in there.
What is the use case here?
On 18 July 2012 14:46, Alistair Young wrote:
would I be on the right path if I implemented it in TopicSubscriptionView
and making use of PendingMessageCursor from TopicSubscription to get at the
pending messages and their content
for a topic.
Would a queue not be better for this use case? Or a virtual topic,
where each consumer gets its own queue.
On 18 July 2012 15:17, Alistair Young wrote:
Perhaps getting at the prefetch buffer would prolly be better in that case.
Would you have a pointer on how to access it?
Use case
thank you - that's been a helpful exchange. Looks like the JMX route should be
fine for my needs.
cheers,
Alistair
mov eax,1
mov ebx,0
int 80h
Gary Tully 18/07/12 4:51 PM
inline
On 18 July 2012 16:13, Alistair Young wrote:
From what I've read a durable queue keeps all the messages from
July 2012 16:43, Alistair Young wrote:
aha, seems it's already on the radar. failover uri masks out ssl uri.
Workaround is to force it to use the keystore and truststore via Java OPTS.
http://activemq.2283324.n4.nabble.com/jira-Created-AMQ-3785-ActiveMQSslConnectionFactory-does-not-detect-ssl
Not sure about this one but it's weird. If I use this code in a unit test
against an embedded SslBrokerService with client authentication enabled:
connectionFactory.setKeyStore(keystorePath);
connectionFactory.setKeyStorePassword(keystorePassword);
have to use the Java OPTS to get the connection to work.
Is this how it's meant to work?
Alistair
mov eax,1
mov ebx,0
int 80h
Alistair Young 13/07/12 1:46 PM
Not sure about this one but it's weird. If I use this code in a unit test
against an embedded SslBrokerService with client
.html
Alistair
mov eax,1
mov ebx,0
int 80h
Alistair Young 13/07/12 4:32 PM
the problem is with failover ssl. Using ssl://localhost:61617 works fine with
ActiveMQSslConnectionFactory and client auth.
failover:(ssl://localhost:61617) or failover:ssl://localhost:61617 breaks
thanks for info Tim. I'll clear out the broker and see if that settles the
consumer down.
cheers,
Alistair
--
mov eax,1
mov ebx,0
int 80
On 2 Mar 2012, at 21:25, Timothy Bish wrote:
On Fri, 2012-03-02 at 10:44 +, Alistair Young wrote:
Hi there,
Would there be any reason
Hi there,
Would there be any reason a JMS consumer would just stop reading from its
topic? It's a simple tomcat webapp and when tomcat is restarted the consumer
starts reading again, until it stops again after a day or so. After it reads a
message it sends a message to another topic on the
are they routed by camel or is it just activemq? If it's just activemq you mark
them as persistent messages when sending them. If there are no durable topic
subscribers registered for the topic activemq won't persist the messages I
don't think, I'm not sure about that though.
If the messages
I downloaded activemq 5.5.1 and can guarantee 2 out of 100 messages sent to it
are lost when using transacted routes (route A to route B below). Is this the
right place to ask for help? This is my actiemq/camel config.
beans
xmlns=http://www.springframework.org/schema/beans;
I've managed to sort it after reading around. Not really sure what the problem
was but it's fine now :)
Alistair
--
mov eax,1
mov ebx,0
int 80h
On 21 Nov 2011, at 09:06, Alistair Young wrote:
I downloaded activemq 5.5.1 and can guarantee 2 out of 100 messages sent to
it are lost when
for Spring, I use this:
broker xmlns=http://activemq.apache.org/schema/core;
id=matrixBrokerID
brokerName=matrixBroker
useJmx=true
, at 14:58, Alistair Young wrote:
I resorted to tcpdump on the broker and the consumer to track the messages
and it seems the consumer is dropping messages. Of 16 incoming identical
messages, it only acted upon 3. Also, it failed to act on another single
message. By that, it didn't pass them
is there any reason why MessageAuthorizationPolicy::isAllowedToConsume is not
called from this?
broker = new BrokerService();
broker.setMessageAuthorizationPolicy(new MessageGuard());
broker.addConnector(BROKER_URL);
broker.start();
MessageGuard::isAllowedToConsume is never called when a
eax,1
mov ebx,0
int 80h
On 26 Sep 2011, at 16:19, Alistair Young wrote:
trying to log incoming messages at the broker to narrow the problem and
another problem appears. This works on one server but adds 0x0 chars on
another so the message fails to parse:
public boolean
I use tcp://localhost:61616
Alistair
--
mov eax,1
mov ebx,0
int 80h
On 27 Sep 2011, at 11:18, Gary Tully wrote:
it is not applied to the vm transport, you would need to use tcp to
connect to your embedded broker to make use of authorization.
On 27 September 2011 08:49, Alistair Young
2011 11:16, Alistair Young alistair.yo...@uhi.ac.uk wrote:
not a lot seems to work. 8 identical messages sent to the broker in quick
succession. Three arrived, 5 just disappeared. It's complicated by the fact
MessageAuthorizationPolicy::isAllowedToConsume never seems to be called
/activemq-5.5.0/activemq-core/src/main/java/org/apache/activemq/broker/util/LoggingBrokerPlugin.java?view=markup
On 22 September 2011 10:59, Alistair Young alistair.yo...@uhi.ac.uk wrote:
would someone be kind enough to have a quick look at this code to see if it
could cause problems? The method
incoming messages from producers.
Alistair
--
mov eax,1
mov ebx,0
int 80h
On 21 Sep 2011, at 13:13, Alistair Young wrote:
I'm running ActiveMQ 5.5.0 as a spring webapp rather than the standalone
version. Would you recommend the standalone one? Not sure how to use camel
with that though
eax,1
mov ebx,0
int 80h
On 22 Sep 2011, at 10:50, Alistair Young wrote:
nothing seems to help. There are still messages just disappearing. Also the
logging doesn't seem to log anything to do with producers:
loggingBrokerPlugin logAll=true logConnectionEvents=true /
I can see lots
of it in the
kahadb data store
the producer sent 49 messages in 2 seconds.The 43rd and 46th messages
disappeared. They never reached the broker it would seem.
Alistair Young
Àrd-Innleadair air Bathar-Bog
UHI@Sabhal Mòr Ostaig
On 20 Sep 2011, at 15:50
I doubt it. In a batch of three messages sent in 2 seconds, one disappeard. Is
there a default throttle limit perhaps on the broker? But surely that would
cause the producer to error out or something?
Alistair Young
Àrd-Innleadair air Bathar-Bog
UHI@Sabhal
I should say, the messages go to a topic on the broker and are then routed by
camel to another topc. Would camel be dropping the messages? Would they not be
logged in the kahadb store no matter what though?
Alistair
--
mov eax,1
mov ebx,0
int 80h
On 21 Sep 2011, at 10:25, Alistair Young
yep, there is a durable topic consumer waiting for them
Alistair
--
mov eax,1
mov ebx,0
int 80h
On 21 Sep 2011, at 12:20, Gary Tully wrote:
topic messages are only persisted to the store if there are durable
consumers/subscriptions
On 21 September 2011 11:04, Alistair Young
On 21 Sep 2011, at 12:26, Alistair Young wrote:
yep, there is a durable topic consumer waiting for them
Alistair
--
mov eax,1
mov ebx,0
int 80h
On 21 Sep 2011, at 12:20, Gary Tully wrote:
topic messages are only persisted to the store if there are durable
consumers
version used on your side?
In case its not the latest released version, can you try the latest version?
Do you set any particular headers on the Topic message in your producer?
On Sep 21, 2011, at 1:54 PM, Alistair Young wrote:
I can't explain this at all. It's almost like the opposite
Is there anything that might cause a message to go missing? A producer sends a
persistent message to a topic but now and then, although no error is returned
from the broker, the message just disappears. It's not logged in the data store
and it's as if it never reached the broker but that would
If I try to connect to a dead broker:
failover:tcp://localhost:61617
it blocks forever on:
ActiveMQConnectionFactory connectionFactory::setClientID
if I force it to not block:
failover:tcp://localhost:61617?startupMaxReconnectAttempts=1initialReconnectDelay=10
it still blocks.
Am I missing
Transport. Reason:
java.lang.IllegalArgumentException: Invalid connect parameters:
{startupMaxReconnectAttempts=1}
Alistair
--
mov eax,1
mov ebx,0
int 80h
On 11 Aug 2011, at 10:33, Alistair Young wrote:
If I try to connect to a dead broker:
failover:tcp://localhost:61617
it blocks
Young
Àrd Innleadair air Bathair-bog
UHI@Sabhal Mòr Ostaig
On 11 Aug 2011, at 17:08, Gary Tully wrote:
use failover:(urls)failoveroptions
so:
failover:(tcp://localhost:61617)?maxReconnectAttempts=1
What version you using?
On 11 August 2011 10:42, Alistair Young alistair.yo...@uhi.ac.uk
When I create a new ActiveMQConnectionFactory and use:
javax.jms.Connection connection = connectionFactory.createConnection()
and set autoacknowledge on the connection session:
javax.jms.Session.AUTO_ACKNOWLEDGE
when using jconsole the dequeue count is always 0, suggesting the messages are
I noticed the InFlightCount decrements correctly as the consumer picks up and
acknowledges the messages so not sure why DequeueCount is always 0
Alistair
--
mov eax,1
mov ebx,0
int 80h
On 27 Jul 2011, at 12:03, Alistair Young wrote:
When I create a new ActiveMQConnectionFactory and use
Hi there,
I have a durable topic consumer that was killed by a power outage while
consuming messages. It was down for 3 days and when it reconnected, all the
remaining messages on the topic had disappeared. It only received messages on
the topic after it reconnected. I've since shut it down,
, at 15:04, Gary Tully wrote:
what version and what sort of message rate. So how many messages would
have accumulated?
On 27 May 2011 13:00, Alistair Young alistair.yo...@uhi.ac.uk wrote:
Hi there,
I have a durable topic consumer that was killed by a power outage while
consuming messages
thanks for that - they weren't in the path for the exe. Works now.
cheers,
Alistair
--
mov eax,1
mov ebx,0
int 80h
On 19 Aug 2009, at 17:09, Timothy Bish wrote:
On Wed, 2009-08-19 at 15:59 +0100, Alistair Young wrote:
Hi there,
I've downloaded the NMS and ActiveMQ binary assemblies
I know the topic has persistent messages as the ActiveMQCPP stuff
works ok, picking up messages it's missed. The NMS one doesn't though:
Uri connectURI = new Uri(activemq:tcp://host.com:61613?
transport.wireformat=stomp);
IConnectionFactory factory = new ConnectionFactory(connectURI, test-
ActiveMQCPP. So it seems the C# version doesn't work?
Alistair
--
mov eax,1
mov ebx,0
int 80h
On 20 Aug 2009, at 10:24, Alistair Young wrote:
I know the topic has persistent messages as the ActiveMQCPP stuff
works ok, picking up messages it's missed. The NMS one doesn't though:
Uri
ok thanks - it's specifically the STOMP that breaks. Works ok with
normal.
Alistair
--
mov eax,1
mov ebx,0
int 80h
On 20 Aug 2009, at 14:36, Timothy Bish wrote:
On Thu, 2009-08-20 at 14:32 +0100, Alistair Young wrote:
Looking at this with jconsole:
IMessageConsumer consumer
Hi there,
I've downloaded the NMS and ActiveMQ binary assemblies 1.1.0, as well
as building them from source but I keep getting this error:
No IConnectionFactory implementation found for connection URI:
activemq:tcp://host.com:61613?transport.wireformat=stomp
from this code:
using
46 matches
Mail list logo
