hello,
We have activemq 5.1.0 on linux running with a 1GB heap. When a
large flurry of messages come in (say 500) activemq runs out of memory
with the following error:
2009-01-23 10:42:43,776 [erContainer-157] ERROR
efaultMessageListenerContainer - Setup of JMS message listener invoker
failed
Thanks.
I switch to putty as a telnet client and got it working.
Roger Hoover wrote:
>
> Maybe try connecting to 127.0.0.1:61613
>
> thedude:~ rhoover$ telnet 127.0.0.1 61613
> Trying 127.0.0.1...
> Connected to localhost.
> Escape character is '^]'.
> CONNECT
>
> ^@
> CONNECTED
> session:ID:t
You only need this if you¹d like to force ActiveMQ to go through the
standard Java JMX implementation: http://activemq.apache.org/jmx.html
Good if you need authentication or you¹d like to view generic JVM stats as
well as ActiveMQ stats.
On 1/29/09 1:41 PM, "yesnid" wrote:
>
>
> Hello All,
>
Maybe try connecting to 127.0.0.1:61613
thedude:~ rhoover$ telnet 127.0.0.1 61613
Trying 127.0.0.1...
Connected to localhost.
Escape character is '^]'.
CONNECT
^@
CONNECTED
session:ID:thedude.local-49155-1233016758322-133:1
DISCONNECT
^@
Connection closed by foreign host.
On Thu, Jan 29, 200
61613
James.Strachan wrote:
>
> Which port are you connecting to?
>
> 2009/1/29 lazyeye :
>>
>> I'm trying to get started with stomp but I can't even get a telnet
>> connecting
>> working.
>> I'm using activeMQ 5.2.0, java 1.6.0_10, windows xp professional v 2002
>> service pack 2 and Microsoft
I have two brokers connected to each other and when I pass a message to one
of them it stores it and forwards it to the other broker. Great. However,
if I take one of the brokers offline (simulating a server failure/crash) and
queue up a bunch of pending messages on the broker that is still aliv
Which port are you connecting to?
2009/1/29 lazyeye :
>
> I'm trying to get started with stomp but I can't even get a telnet connecting
> working.
> I'm using activeMQ 5.2.0, java 1.6.0_10, windows xp professional v 2002
> service pack 2 and Microsoft telnet client.
> It looks like activeMQ stats
I'm trying to get started with stomp but I can't even get a telnet connecting
working.
I'm using activeMQ 5.2.0, java 1.6.0_10, windows xp professional v 2002
service pack 2 and Microsoft telnet client.
It looks like activeMQ stats up fine. The log file saids the stomp port is
listening.
The telne
Hello All,
I am working on trying to customize my broker's configuration xml file, and
I have run into this snippet:
What is the point of this? There is a comment about how this effects how
ActiveMQ is exposed in JMX, but I am not following what is meant by tha
@Joe - I set the PROVIDER_URL immediately after log4j calls the
InitialContext() constructor.
@James - Will try that first thing in the morning
Joe Fernandez wrote:
>
> Are you extending Jamie Tsao's JMSQueueAppender?
>
> Is your activateOptions() method being called prior to you setting
Are you extending Jamie Tsao's JMSQueueAppender?
Is your activateOptions() method being called prior to you setting the
PROVIDER_URL?
Joe
Free ActiveMQ user guide @ http://www.ttmsolutions.com
selezovikj wrote:
>
> I have a JmsQueueAppender that logs messages to an ActiveMQ broker on a
> giv
http://activemq.apache.org/fanout-transport-reference.html - is the
place to look to get started
On 29 Jan 2009, at 17:00, James Strachan wrote:
The fanout transport kinda has most of the implementation code to do
this; it just needs to be hacked a little so that consume start/stop
commands ar
I have a problem.
How can I have the redelevery status of a message based not on if the broker
has sent a message to the consumer, but on if the consumer has called
receive on that message.
One way might be setting prefetch size to 0, so the receive is 1 to 1 with
the broker filling the consumer
Have you tried just configuring whatever properties you need as a
Hashtable and passing them into the InitialContext() constructor?
2009/1/29 selezovikj :
>
> I have a JmsQueueAppender that logs messages to an ActiveMQ broker on a given
> queue.
> I also have a jndi.properties file in which I do N
I have a JmsQueueAppender that logs messages to an ActiveMQ broker on a given
queue.
I also have a jndi.properties file in which I do NOT specify the
provider.url value, because that value can vary depending on a flag.
In my JmsQueueAppender, the jndi context is initialized using the default
no
Hi uprooter,
I suggested using XSDObjectgen in my previous message, but it looks like you
already are. However, when using that, you should be able to serialize out
to text and use a TextMessage. No need to ObjectMessage. Try that out to
see if it works.
- Jim
On Mon, Jan 5, 2009 at 8:29 AM,
Trying to serialize objects between Java and C# is a tricky proposition. We
have been able to accomplish this through the use of automated tools that
generate Java code and C# code from an XSD file. For C# you can use
XSDObjectGen tool. I'm not sure what the Java equivalent tool is. When the
ob
The fanout transport kinda has most of the implementation code to do
this; it just needs to be hacked a little so that consume start/stop
commands are sent to multiple brokers and transactions/acks are
correctly sent to the broker that sent the original message. There
might be some fun and games wi
Hi Bryan,
I'm not sure what you mean by participating inside a transaction. Are you
talking about implementing a two-phase commit extended transaction
operation? Or are you talking about using the transaction acknowledgment
mode that is part of NMS?
- Jim
On Mon, Dec 29, 2008 at 3:02 PM, Bryan
We have been encountering similar problems, but no definitive reproducible
steps. Our analysis is pointing towards having the persistent flag turned
on for messages. If the messages are flagged as persistent, then we can
encounter non-responsive consumers. Understand that the consumer is not the
I'm interested in a variation of this for load balancing. Assume the volume
of data coming from publishers is very large, and you need N brokers (think
N is 10 or more). Furthermore, you want N+1 or N+2 redundancy so that if any
1 or 2 brokers die, there is sufficient capacity to continue handling
have you looked at the failover transport? see:
http://activemq.apache.org/failover-transport-reference.html
with the backup=true option, a connection to all listed brokers will
be created so that they are in hot standby in
the event that the first connection is dropped. In this way, failover
can b
Hi,
I am facing a problem on receiving messages by multiple blocked receivers
from a single Queue with different correlation id.
Here is what exactly I am doing.
My client thread is publishing a message ( having a unique co-relationid) to
a RequestQueue and waiting for a response (blocked)
on
This thread is old but just curious if there has been a recent update of this
w.r.t ActiveMQ 5.2 . The problem that I am trying to solve is similar where
a consumer listens to multiple brokers (as a failover redundancy issue
instead of listening to a single broker).
Stepan Koltsov wrote:
>
> I
Hi,
Sorry, I should have given more info. AMQ 5.2, Linux broker, Windows
client. JDK 1.6.0_06.
I don't always get it, about 1/2 the time. Simple echo client/echo server
application. Lots of clients and servers running. When it happens it
leaves a bunch of "ActiveMQ Transport Initiator"
I guess we should set transformation_error header in cases like this. Added
to TODO :)
Cheers
--
Dejan Bosanac
Open Source Integration - http://fusesource.com/
ActiveMQ in Action - http://www.manning.com/snyder/
Blog - http://www.nighttale.net
On Thu, Jan 29, 2009 at 3:14 PM, mjustin wrote:
>
Hi
Thanks for that, I have had a look at the documentation and attempted to
deploy the web console within tomcat. This seems to all go well, with the
console appearing to deploy succesfull within the webapps folder, I have
placed activemq-all.jar within the common/lib folder, and added amended th
Yes. Use 'duplex' forwarding bridges.
http://activemq.apache.org/networks-of-brokers.html
Joe
Free ActiveMQ user guide @ http://www.ttmsolutions.com
project2501 wrote:
>
> Thanks for the suggestion. I see now, the documentation for Camel.
>
> It would be nice, in the future, if a broker wil
Dejan Bosanac wrote:
>
> is your SamplePojo properly annotated so it can be marshaled with XStream?
>
Not yet - but I am sure this was the missing piece. The SamplePojo is just
implementing Serializable, sorry that I have not checked the XStream
documentation before - agile development is no
Could you use the Camel user forum please?
http://camel.apache.org/discussion-forums.html
2009/1/29 ejot :
>
> From the docs the line delimiters AUTO, MAC, WINDOWS and UNIX are
> supported... but mina has another one, NUL (necessary when using for example
> Flash). Is there some other way to confi
I think that advisory topics are going to solve for only some of your cases.
I¹m new to AMQ, so there is a little speculation involved here. If you set
up a standard topic subscriber in python on the ActiveMQ.Advisory.FULL
topic, you will receive a message every time a destination is ³full². I¹m
as
Thanks for the suggestion. I see now, the documentation for Camel.
It would be nice, in the future, if a broker will create a reverse bridge to
a broker that connects to it.
For example, I have broker A that I want to bridge to B,C,D,E, but doesn't
know where to find them. It cannot use multicas
Hi,
is your SamplePojo properly annotated so it can be marshaled with XStream?
Regards
--
Dejan Bosanac
Open Source Integration - http://fusesource.com/
ActiveMQ in Action - http://www.manning.com/snyder/
Blog - http://www.nighttale.net
On Thu, Jan 29, 2009 at 2:39 PM, mjustin wrote:
>
> Dea
> You are welcome to create a Jira Issue for NMS to request the addition
> of this functionality if there one already to keep that from falling off
> the radar.
Tim, again thanks for the clarification of how it works. I searched the
JIRA and did not find an existing item so I created a new one
Dear mailing list,
my STOMP client receives ObjectMessage STOMP frames with the
transformation=jms-json header set, but with an empty body.
In my test, a Java client sends object messages to the broker, specifying
jms-json transformation.
The JAR file for the SamplePojo class, jettison and xstr
>From the docs the line delimiters AUTO, MAC, WINDOWS and UNIX are
supported... but mina has another one, NUL (necessary when using for example
Flash). Is there some other way to configure the delimiter when creating the
route?
--
View this message in context:
http://www.nabble.com/camel-mina%2C
You're using tcp:// on the client side though ???
On 29 Jan 2009, at 12:35, Ricardo Clemente wrote:
I don't know why, but I'm experiencing the same problem.
I'm running on a Linux (Ubuntu) the 5.2.0 version.
regards,
Ricardo
On Thu, Jan 29, 2009 at 9:10 AM, Rob Davies
wrote:
On 28 Jan
I don't know why, but I'm experiencing the same problem.
I'm running on a Linux (Ubuntu) the 5.2.0 version.
regards,
Ricardo
On Thu, Jan 29, 2009 at 9:10 AM, Rob Davies wrote:
>
> On 28 Jan 2009, at 23:28, happyAMQ wrote:
>
>>
>> Anyone know why I would be seeing the following exception when us
sorry, have no junit test.
But I created an Issue with all information inside:
https://issues.apache.org/activemq/browse/AMQ-2090
rajdavies wrote:
>
>
> On 29 Jan 2009, at 08:37, Cybexion wrote:
>
>>
>> Hi,
>>
>> I'm running apache-activemq-5.2.0.1-fuse on jdk 1.6.
>> When I was doing a hi
On 29 Jan 2009, at 08:37, Cybexion wrote:
Hi,
I'm running apache-activemq-5.2.0.1-fuse on jdk 1.6.
When I was doing a high load 24/7 test where I produced 9505925
persistent
small message (kaha) suddenly amq stopped working with an
OutOfMemoryException.
My memory settings are
-Xmn10
On 28 Jan 2009, at 23:28, happyAMQ wrote:
Anyone know why I would be seeing the following exception when using
the NIO
transport connector. I do not see this with TCP.
[java] javax.jms.JMSException: Wire format negotiation timeout:
peer did
not send his wire format.
[java] at
On 28 Jan 2009, at 20:21, darrickc wrote:
I haven't been able to find anywhere the best practices for handling
messages
coming from ActiveMQ. When I receive a message via onMessage() I am
in an
ActiveMQ thread. Is it best to act on this message in non-ActiveMQ
thread,
or is it ok to do m
Hi,
I'm running apache-activemq-5.2.0.1-fuse on jdk 1.6.
When I was doing a high load 24/7 test where I produced 9505925 persistent
small message (kaha) suddenly amq stopped working with an
OutOfMemoryException.
My memory settings are
-Xmn100M \
-Xms500M \
-Xmx1024M
The E
43 matches
Mail list logo
