Hi,
I worked on a simple java programm which acts as the producer and the
consumer as well.Now i a want to do it with two seperate java programm, one
acting as the consumer and the other one as producer.
While executing the consumer programm i am getting this exception.
Exception occurred:
Check:
http://issues.apache.org/activemq/browse/AMQ-1796
--
View this message in context:
http://www.nabble.com/Expired-messages-not-moved-to-dead-letter-queue.-tp18608013p18627682.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
The code below is the problem in your Consumer class...
consumer.setMessageListener(this);
Message message1 = consumer.receive(1000);
With jms, you can receive messages synchronously (using the receive methods)
or asynchronously (using the MessageListener,
Hi,
i made the changes u have mentioned but i am not receiving any message. I am
putting the output of the console for the producer and the consumer as well.
Producer console window
rrr
Jul 24, 2008 2:27:38 PM SimpleProducer main
INFO: Destination name is MyQueue
Jul 24, 2008 2:27:39 PM
You will need to start the connection for receiving messages. After setting
up your receiver, call connection.start();
consumer = session.createConsumer(destination);
connection.start();
Message message1 = consumer.receive(1000);
Read the jms api/a good book.
I believe activemq is supposed to
Ramdas Sawant ha scritto:
Hi all,
I want to restrict publishing JMS messages to a topic after
certain limit is reached(may be size/number of messages). For this
particular topic i have a durable subscription from one JMS client. I want
to persist the messages when the subscriber is
Still no answer? Nobody has a clue how to configure activemq - so that it
doesn't hang up??
greetings max
buchnerm wrote:
Hi
I try to use activemq but I always get some issues:
I produce a load of 360 messages/sec on the OIconveyer Queue
and read with a camel component from this
This is plenty for me to look into! Much appreciated, Joe! I shall play with
these options a bit more and get back to the list either way (either with
more questions or explaining how I did it). Thanks!
Joe Fernandez wrote:
I have seen the InvalidClientIDException in these types of 'duplex'
There could be a bug here, could you raise a jira issue to document the
problem and your platform.
Regards
Tim
On Mon, 2008-07-21 at 14:21 -0700, FastEddie wrote:
I'm using a TextMessage, and also setting a StringProperty on it.
What is the max size of the StringProperty?
I noticed in
This is my topology:
* Broker A is outside the LAN and has no network connectors.
* Brokers B and C are running on 2 different machines inside the LAN and
have duplex set to TRUE.
* Client sends a message to queue1 on brokerA and sends another message to
queue2 on brokerA.
* Broker A receives
I'm trying to set the queueSearchMessageFormat and topicSearchMessageFormat
but when I have these properties I get a spring error to the tune of:
Caused by: org.springframework.beans.TypeMismatchException: Failed to
convert property value of type [java.lang.String] to required type
Thanks Marco!!
I will look into the java class and let you know the results.
Marco Buss wrote:
Hello,
first have a look at the test class
org.apache.activemq.blob.FTPBlobTest.java. If you have problems with this,
i will help you with a more detailed description.
regards
Marco
Hi,
Changed the version in 2005 vcproject file (vs2005-activemq.vcproj) to 7.10
and tried to compile it with VS2003.
Got errors that looked like (not posting all, just a few to keep the post
readable)
For info:
Our application which uses publish/subscribe topics for communication using
AMQ 5.1 running on Solaris x86 (5.10 Generic_127112-06) with Java 1.6 (java
version 1.6.0_06,Java(TM) SE Runtime Environment (build 1.6.0_06-b02))
causes AMQ to leak threads. A new thread seems to be created
14 matches
Mail list logo
