please reply anyone, i need to fix it quickly.
Thanks in advance.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/message-clears-from-db-if-application-or-activemq-restarts-tp3491807p3494583.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
hey martin thanx for reply..
as you have mentioned in my framework i did not change the default
persistent setting of message
other configurations which i am using are:
this is my camel route:
and in readData & read
I have following setup. There are two brokers A and B and one producer P. I
want to know how I can if at all possible if I can make my producer P do
round robin writes to brokers A and B .Say I do 100 writes 50 go to broker A
and 50 to broker B
I am open to using network of brokers .
Please Sugg
On Tue, 2011-05-03 at 15:25 -0700, agujral wrote:
> Hi There,
> Thanks for your reply.I want to accomplish the following I have
> two brokers I want my producer
> to write use both the brokers equally.For example say there are two brokers
> A and B
> a)Say my producer has data to writ
Hi There,
Thanks for your reply.I want to accomplish the following I have
two brokers I want my producer
to write use both the brokers equally.For example say there are two brokers
A and B
a)Say my producer has data to write to and it writes to broker A.
b)Now again the producer has d
On Tue, 2011-05-03 at 14:34 -0700, agujral wrote:
> As per the documentation
> http://activemq.apache.org/failover-transport-reference.html randomize is
> true by default
> Then why do I need to specify it
>
I just put it on for clarity. To answer your question we'd need some
more details on you
As per the documentation
http://activemq.apache.org/failover-transport-reference.html randomize is
true by default
Then why do I need to specify it
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Failover-configuration-not-working-tp3493557p3493634.html
Sent from the Activ
On Tue, 2011-05-03 at 14:07 -0700, agujral wrote:
> Hi All,
> I am using the following configuration in my activemq setup
> failover:(tcp\://host1.com\:61616,tcp\://host2.com\:61616) for
> producers.Brokers are running on
> host1.com and host2.com . The problem is that producers always wr
Hi All,
I am using the following configuration in my activemq setup
failover:(tcp\://host1.com\:61616,tcp\://host2.com\:61616) for
producers.Brokers are running on
host1.com and host2.com . The problem is that producers always write to one
broker and the other broker is not used. As per
h
Hi Gary
Thanks alot for replying. I am not using the 'vm' protocol.
I am using the tcp protocol with the following broker url:-
tcp://localhost:61616
My application is using the Spring Framework. And i am using the
DefaultMessageListenerContainer for the listeners.
Using the 'Spring JMSTemplate'
Thanks a lot Martin. This is very helpful.
With this, I'd like to verify if my understanding is correct through the
following code snippet:
ActiveMQConnectionFactory connectionFactory = new
ActiveMQConnectionFactory(brokerURI);
Connection connection = connectionFactory.createConnection();
On Tue, 2011-05-03 at 18:10 +0100, Suneel Papineni wrote:
> Hi,
>
>
>
> I am trying to see if "isConnectionInfo() and isRemoveInfo()" methods
> are working fine. Created a consumer with a destination
> "ActiveMQ.Advisory.Connection" and implemented following code in
> onMessage() method.
>
> #
Hi,
I am trying to see if "isConnectionInfo() and isRemoveInfo()" methods
are working fine. Created a consumer with a destination
"ActiveMQ.Advisory.Connection" and implemented following code in
onMessage() method.
##
virtual void onMessage( const cms::Message* mes
are you using a vm:// brokerurl, if so you need to have it unmarshall
the properties using a url like
vm://localhost?marshal=true
have a look at the test to compare and contrast with what you are doing:
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/Me
Hello,
I am not able to get the reason of exception from the message that is in the
DLQ.
These are the steps i have followed:-
1. Message is sent to a 'Sample' Queue.
2. The Message Listener throws a Runtime Exception in the onMessage
Function.(throw new RuntimeException("Exception Reason Test")
there is a prefetchSize attribute for that on the NetworkConnector
xbean, inherited from
org.apache.activemq.network.NetworkBridgeConfiguration
On 3 May 2011 15:08, lernen.2007 wrote:
> I think the problem is that the there is no prefetchSize option for
> networkconnector and that can be the reas
Hi,
you broker's persistence settings are only used if you send your
messages as persistent and not as non-persistent. See
http://download.oracle.com/javaee/1.4/api/javax/jms/MessageProducer.html
for persistence settings. The JMS default is persistent, but I don't
know how you configured your fram
I think the problem is that the there is no prefetchSize option for
networkconnector and that can be the reason why the messages stuck.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Messages-stuck-in-queue-tp3244342p3492540.html
Sent from the ActiveMQ - User mailing list
Hey martin
as i shown my config file, i am using persistency using
jdbcpersistenceadapter in oracle.
& only undelivered messages i can see in the activemq_msgs table.
for making messages undeliver i give a wrong route address which does not
exist, so i can see that message in db. until now i think
the stop method on the network connector via JMX should do that for you.
On 3 May 2011 13:02, Martin C. wrote:
> Hi,
>
> On Tue, May 3, 2011 at 11:20 AM, Gary Tully wrote:
>> In your setup, when one of the networked brokers goes
>> down it becomes (looks like) a very slow consumer.
>
> Is there
Hi,
are you using persistent or non-persistent delivery for your messages?
Any non-persistent message will be discarded on broker restart
(however, I don't know why it would go to the storage in the first
place, though).
And are you using a time-to-live on your messages, which might have
expired
Hi,
the JMS threading model is based around the Session. Each Session is
to be used by one thread. If you are using asynchronous mode (you
register a MessageListener with the Session), every Session uses one
thread or is to be used by one thread
(http://download.oracle.com/javaee/1.4/api/javax/jms
Hi,
On Tue, May 3, 2011 at 11:20 AM, Gary Tully wrote:
> In your setup, when one of the networked brokers goes
> down it becomes (looks like) a very slow consumer.
Is there a way to "de-register" a broker in such a scenario, if it
goes down intentionally "forever"?
Best regards,
Martin
bump
On Monday, 02 May, 2011 05:50 PM, Don Santillan wrote:
Hello,
I have a basic question about message consumers that I really need to
confirm that my understanding is correct.
Do message consumers run in different threads?
Suppose I have 5 consumers assigned to a queue. Are these consume
your recovery policy will be hit N times, it is up to the query to
cache the messages as it pleases. The only concrete implementation I
see is in the tests so it looks like it is up to you.
On 30 April 2011 14:52, this.juan wrote:
> Hi,
>
> This is what I'd like to do:
>
> * Clients subscribe to
you need to use a pending message limit strategy or file pending
message cursor. In your setup, when one of the networked brokers goes
down it becomes (looks like) a very slow consumer.
Check out the options: http://activemq.apache.org/slow-consumer-handling.html
On 28 April 2011 14:29, manua wr
26 matches
Mail list logo
