If your using spring make sure you enable consumer caching. Otherwise
consumers are getting created a destroyed on each message received.
On Jan 21, 2008 12:23 PM, Datacom - Marcelo <[EMAIL PROTECTED]> wrote:
> We are having a problem with our sender and consumers being slowling
> down. I realize
Here are snippets from my Java code. Please let me know if this is enough.
/*
-*/
/* Code used to send the message
*/
/*
---
It sounds like your embedded client broker connects to the server, but not
the other way around? Each of the embedded brokers must have a network
connector to the other (forwarding bridge) if you expect both to
produce/forward messages to one another. In 4.1, connections between brokers
are one-wa
That sounds wonky - whats your Java code look like?
On 22/01/2008, Fady <[EMAIL PROTECTED]> wrote:
>
> Thanks for your reply James,
>
> I am not seing any exceptions coming out of onMessage.
>
> I ran more tests and things are more complicated than I first thought.
>
> When I run 100 sends/receive
Hi !
I'm new with ActiveMQ
I succeeded in implementing a kind of Question/Answers protocol between a
client and a server, using JNDI-defined queues and temporary queues
(setJMSReplyTo, in the question JMS message and one temporary queue by
client thread) for the answer.
I have two different ser
Thanks for your reply James,
I am not seing any exceptions coming out of onMessage.
I ran more tests and things are more complicated than I first thought.
When I run 100 sends/receives, JMX shows a QueueSize=100 and
DispatchCount=100 after the test has run, where I was expecting QueueSize=0
(s
Below is the source for MessageConsumer.java
package ss.integration.util;
import javax.jms.TopicConnectionFactory;
import javax.jms.TopicConnection;
import javax.jms.Topic;
import javax.jms.TopicSession;
import javax.jms.TopicSubscriber;
import javax.jms.MessageListener;
import javax.jms
Below is the complete stack trace.
<2008/01/10 10:43:23.127><21621663><> ExceptionListener receives a
JMS exception
<2008/01/10 10:43:23.127><21621663><> Unregistering Message
Listener...
<2008/01/10 10:43:23.127><21621663><> Notifying/signaling a waiting
thread...
<2008/01/10 10:43:23.144><2
Below is the source for MessageConsumer.java
package ss.integration.util;
import javax.jms.TopicConnectionFactory;
import javax.jms.TopicConnection;
import javax.jms.Topic;
import javax.jms.TopicSession;
import javax.jms.TopicSubscriber;
import javax.jms.MessageListener;
import javax.jms.JMSExc
On 22/01/2008, activemqnewbie <[EMAIL PROTECTED]> wrote:
>
>
> As specified in previous posting,
> Below is the stack trace.
> <2008/01/10 10:43:23.127><21621663><> ExceptionListener receives a
> JMS exception <2008/01/10 10:43:23.127><21621663><> Unregistering
> Message Listener... <2008/01/10 10:
As specified in previous posting,
Below is the stack trace.
<2008/01/10 10:43:23.127><21621663><> ExceptionListener receives a
JMS exception <2008/01/10 10:43:23.127><21621663><> Unregistering
Message Listener... <2008/01/10 10:43:23.127><21621663><>
Notifying/signaling a waiting thread... <2008
The exception is being generated from the code in this package :
ss.integration.util
I've no idea what that is - got the source?
On 22/01/2008, activemqnewbie <[EMAIL PROTECTED]> wrote:
>
> We are getting NullpointerException and the consumer shuts off.
> Consumer after receiving certain number o
On 22/01/2008, activemqnewbie <[EMAIL PROTECTED]> wrote:
>
> Subscriber closes with an exception(below)after consuming certain
> messages.This happens at different intervals.
> Appreciate if someone could let me know the reason and solution for this.
Looks like someone is closing the connection/se
Subscriber closes with an exception(below)after consuming certain
messages.This happens at different intervals.
Appreciate if someone could let me know the reason and solution for this.
Am using activemq 5.0,java 5.
Is there any property/setting that i need to do ?
Below is the stack trace.
<
We are using 4.1.1. I will give a try to
Session.DUPS_OK_ACKNOWLEDGE as sugested.
James Strachan escreveu:
On 21/01/2008, Datacom - Marcelo <[EMAIL PROTECTED]> wrote:
We are having a problem with our sender and consumers being slowling
down. I realize if I put down some consumers
I think I finally found a solution. In the ProviderURL of the appender
adding "?wireFormat.cacheEnabled=false" let the log4j JMSAppender talk to an
ActiveMQ topic.
I.e.
log4j.appender.JMS.ProviderURL=tcp://localhost:61616?wireFormat.cacheEnabled=false
--
View this message in context:
http://
You can point your broker to an xml configuration file, which includes a
simpleAuthenticationPlugin as follows.
Also see http://activemq.apache.org/security.html
Joe
Rudi23 wrote:
>
> Hello,
>
> in my application I start an embedded broker as follows:
>
> B
We solved the problem.
A known issue in Solaris tar causes files of typeflag 'L' to be truncated.
This appears to affect most files in the WEB-INF directory.
To fix, we used GNU tar to unpack.
x apache-activemq-5.0.0/webapps/admin/js/plotkit/SVG.js, 25177 bytes, 50
tape blocks
tar: ././@LongLink
We are getting NullpointerException and the consumer shuts off.
Consumer after receiving certain number of messages consumer automatically
closes throwing a null pointer exception.
Activemq 5
Oracle10g
Below is the stack trace.
<2008/01/22 09:52:56.470><23459640><> ExceptionListener receive
We are getting NullpointerException and the consumer shuts off.
Consumer after receiving certain number of messages consumer automatically
closes throwing a null pointer exception.
Activemq 5
Oracle10g
Below is the stack trace.
<2008/01/22 09:52:56.470><23459640><> ExceptionListener receives a
J
On 22/01/2008, b_w <[EMAIL PROTECTED]> wrote:
>
> At the bottom of this page under the BACKGROUND section:
> http://activemq.apache.org/version-5-xml-configuration.html
>
> So we use the Spring XML configuration file format
>
> The link from Spring XML gives a 404.
Link now fixed
http://cwiki.apac
We dont use this multicast, we are in control of the clients as well as the
broker as its an "in-house" standalone client application that connects to
the broker/server. "Random" clients cannot connect
James.Strachan wrote:
>
> On 22/01/2008, James Strachan <[EMAIL PROTECTED]> wrote:
>> Ar
Pretty sure yeah, not trying to be smart, both are apache-activemq-4.1.1.jar,
size is 4532261 on both. I thought it might be something to do with the fact
that we use a Future to cancel a task that may be sending data. We use
future.cancel(true) allowing the thread to be interruped, maybe its not
ApplicationContextFilter is deployed as part of the 'admin' web application,
so you can find it in .../webapps/admin/WEB-INF/classes
FWIW, I don't set CLASSPATH when I launch the standalone broker via
.../bin/activemq
Joe
DaveKant wrote:
>
> I have a problem starting ActiveMQ (5.0.0) on th
At the bottom of this page under the BACKGROUND section:
http://activemq.apache.org/version-5-xml-configuration.html
So we use the Spring XML configuration file format
The link from Spring XML gives a 404.
Thanks for the feedback and I'll let you know if we make any progress with
the Spring 2.5
On 22/01/2008, Fady <[EMAIL PROTECTED]> wrote:
>
> Hello,
>
> I am new to JMS and ActiveMQ so I am probably doing something stupid but
> can't figure out what it is:
>
> I am running ActiveMQ 5.0.0 imbedded in a Tomcat application. I have a
> non-persistent producer, from a non-transacted and autoa
Hello,
I am new to JMS and ActiveMQ so I am probably doing something stupid but
can't figure out what it is:
I am running ActiveMQ 5.0.0 imbedded in a Tomcat application. I have a
non-persistent producer, from a non-transacted and autoacknowledge session,
creating messages in a queue and a Messa
On 22/01/2008, b_w <[EMAIL PROTECTED]> wrote:
>
> Thanks James.
>
> If you don't mind, a couple more questions. The builds we are using are:
> AMQ 5.0.0
> Spring 2.5.1
> Tomcat 5.5.25
> Java 1.5.0
> Hibernate 3.2.5 (any risk of conflicting libs?)
We've not yet tried Spring 2.5.x with ActiveMQ/xbe
Hello,
in my application I start an embedded broker as follows:
BrokerService broker = new BrokerService();
broker.addConnector("tcp://localhost:61616");
broker.start();
The broker starts up and I can use it both on localhost and remote.
Everything is fine so far.
Now I would like to enforce a
Thanks James.
If you don't mind, a couple more questions. The builds we are using are:
AMQ 5.0.0
Spring 2.5.1
Tomcat 5.5.25
Java 1.5.0
Hibernate 3.2.5 (any risk of conflicting libs?)
Does this jive?
And, the url in the documentation linking to a sample Spring 2 XML is http
404. Believe it was
I have a problem starting ActiveMQ (5.0.0) on the Solaris 10 platform with a
ClassNotFoundException thrown. The problem is related to the admin console
so that when the section below is commented, the server starts up fine.
Where is org.apache.activemq.web.filter.ApplicationContextFilter?
We set
On 16/01/2008, LeeZ01 <[EMAIL PROTECTED]> wrote:
>
> I need to send email with attachment from producer server to a consumer
> server. On the producer server, a file (PDF, MS Doc, etc.) is loaded as
> attachment, together with addressTo, addressFrom, subject, etc. are sent to
> ActiveMQ. The cons
On 22/01/2008, James Strachan <[EMAIL PROTECTED]> wrote:
> Are you positive you are using exactly the same jars on the client
> side and broker?
Bear in mind with multicast discovery, someone on your network could
be running a different version of ActiveMQ...
>
> On 17/01/2008, TOPPER_HARLEY <[E
Are you positive you are using exactly the same jars on the client
side and broker?
On 17/01/2008, TOPPER_HARLEY <[EMAIL PROTECTED]> wrote:
>
> Thanks for the reply, but I dont think thats our issue. We are still on 4.1.1
> and dont use persistent messaging at all.
>
> Thanks for the input though.
On 17/01/2008, Rob Bugh <[EMAIL PROTECTED]> wrote:
>
>
> What is the best way to determine (to the extent that this makes sense) a
> message's position in a queue?
>
> Assuming messages represents a long running tasks and so the queue is
> depleted at a rather slow pace and the messages are removed
On 18/01/2008, activemqnewbie <[EMAIL PROTECTED]> wrote:
>
> Is there any document that lists all the configuration properties description
> that can be set in activemq.xml.
> I looked at http://activemq.apache.org/jndi-support.html and the activemq
> tutorial. but couldn't find one.
See
http://
On 20/01/2008, nanik <[EMAIL PROTECTED]> wrote:
>
> Ok I managed to get it working, all that was left out was the following line
> of code
>
> connection.start();
Thats a common JMS spec gotcha - we've all falled on that one.
http://activemq.apache.org/i-am-not-receiving-any-messages-what-is-wron
I'm not sure - but there's no real point using failover with the vm
transport and specifying maxInactivityDuration. If you are using VM
then the broker is always in RAM and there's no chance of sockets
failing. So change your URL to just
vm://localhost?brokerConfig=xbean:/activemq.xml
On 22/01/20
On 21/01/2008, Datacom - Marcelo <[EMAIL PROTECTED]> wrote:
> We are having a problem with our sender and consumers being slowling
> down. I realize if I put down some consumers, the server increase its
> performance and so the consumers. We took a look via JMX when the whole
> system was very slow
On 22/01/2008, Bruce Snyder <[EMAIL PROTECTED]> wrote:
> On Jan 21, 2008 5:00 PM, emcee21 <[EMAIL PROTECTED]> wrote:
> >
> >
> >
> > James.Strachan wrote:
> > >
> > > Which pom.xml is using the snapshot of activeio?
> > >
> > > FWIW its no longer required for working with ActiveMQ. e.g. you could
>
On 21/01/2008, cmagoyrk <[EMAIL PROTECTED]> wrote:
>
> First I would like to thank Rob for solving that specific issue, I have not
> yet had time to grab the latest release but once I do I will most definitely
> be using that feature.
>
> James - I appreciate your quick response to my concerns. Yo
41 matches
Mail list logo
