Hey all,
I'm trying to subscribe to a msg queue via STOMP and I'm getting the
following error ...
ERROR TransportConnector - Could not accept connection : Channel
was inactive for too long: /127.0.0.1:48781
Can anyone give me a hand with this error?
--
View this message in context:
I've seen the same behaviour today with an ActiveMQ 5.1.0 (JDBC-only
storage) and Java consumers (transactional).
The cause in my case was the AMQ-1838 bug which resulted in a huge
number of messages being paged in and the fetcher from the queue had
it's AtomicLong-lastMessageId set to a number sli
Ok, I'll give that a shot. I just set my prefetch size to 1 in production.
I'm going to monitor that for a bit and see what happens, but it already
stopped once. I had not restarted the ActiveMQ process, so I restarted
everything.
Also, I'm planning to downgrade to the 4.x builds of ActiveMQ to
Waiting in Reader from binary stream: that's expected. Another thread
in dispatcher is normal too.
I think you need to turn on debugging on the client side. See my
article on how to do it:
http://vchekan.blogspot.com/2008/08/tracing-in-nms-it-easy-to-turn-protocol.html
Vadim.
On Fri, Aug 29, 200
I had something similar recently. My exception though was at the client side.
What this exception says is that some operation was requested by the
client which involves connection (as in JMS Connection) which is not
currently registered with activemq.
So I'd take look first at the client and profil
Thanks Gary! That was what I needed!
M@
Have not tried this but it looks promising
http://activemq.apache.org/logging-interceptor.html
also, with log4j it is possible to specify the logging level on a per
class or package basis. see the examples in conf/log4j.configuration.
--
View this m
Hi,
I am getting the following exceptions in my ActiveMQ console:
ERROR Service- Async error occurred:
java.lang.IllegalStateException: Cannot lookup a connection that had not
been registered: ID:om3-1128-1219997369375-0:1
java.lang.IllegalStateException: Cannot lookup a
More information...
There were ~ 4,000 messages still pending in the queue. I took a closer
look at the two active consumers under jconsole, the consumer that was
running had approximately 800 messages in it's
MessageCountAwaitingAcknowledge, the consumer that was idle had 0.
I put a few new mess
I changed my consumers to use client-acknowledge and immediately acknowledge
the message upon receipt. My handler does the following:
void Handle(IMessage message)
{
log message
acknowledge message
Thread.Sleep(random amount of time);
}
I bound the handler to consumer.Listen. I started tw
Unfortunately i have no time to do this things (i don't know JUnit :-/)...
I'm trying with Virtual Topics: i forward packets from a Vitual Topic to two
physical each with only one consumer.
I'll post with news...
Gary Tully wrote:
>
> best to thing to do is build a junit test case with an e
The issue is arising because you are consuming messages but never
acknowledging them (because you never commit your transaction).
See
http://activemq.apache.org/what-is-the-prefetch-limit-for.html
2008/8/29 Jigar Naik <[EMAIL PROTECTED]>:
>
>
>
> Yeah true i will be using auto_ack now onwards
Yeah true i will be using auto_ack now onwards,
one more thing...Is the issue arising because of following pattern of method
calls... ???
util.startConsume(queueName,connectionFactory);
//startConsume(); will be called only in the beginning of the Thread's life.
startConsume
Have raised a JIRA to fail faster to avoid others hitting this one
https://issues.apache.org/activemq/browse/AMQ-1919
but basically if you use a transacted session, you have to commit() at
some point :)
2008/8/29 James Strachan <[EMAIL PROTECTED]>:
> 2008/8/29 Jigar Naik <[EMAIL PROTECTED]>:
>>
>
2008/8/29 Jigar Naik <[EMAIL PROTECTED]>:
>
> I am using ActiveMQ version 5.1.0 with JDK 1.5
>
> "are you using transactions?"
>
> I didn't really get your quesion.
Are you using JMS transactions to consume
> but after consuming each messages from
> activeMQ i am inserting it into oracle databas
I am using ActiveMQ version 5.1.0 with JDK 1.5
"are you using transactions?"
I didn't really get your quesion. but after consuming each messages from
activeMQ i am inserting it into oracle database table
I am not acknowledging the messages and i have only one consumer.
which continuously read
2008/8/29 Jigar Naik <[EMAIL PROTECTED]>:
>
> hi ,
>
> my producer is producing 1 messages on a queue (TestQueue).
>
> after my producer completes producing 1 messages. I am starting my
> consumer for consumer 10 messages.
>
> My consumer consumes around 6000 messages and than throws ex
hi ,
my producer is producing 1 messages on a queue (TestQueue).
after my producer completes producing 1 messages. I am starting my
consumer for consumer 10 messages.
My consumer consumes around 6000 messages and than throws exception
indicating no message on ActiveMQ
what could b
best to thing to do is build a junit test case with an embedded derby
datastore ([1] may be a good starting point), open a jira[2] and
attach your test case.
[1]
http://svn.apache.org/repos/asf/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/ft/JDBCQueueMasterSlaveTest.java
I think it is not a journal problem: it happens also with non-journaled JDBC
persistence adapter with MySQL datasource.
I've tried both AUTO and CLIENT acnowledge methods in session's consumer but
after about ten minutes... infinite resends :(
I've also downloaded the 5.2-...-39 SNAPSHOT: same t
Hi Jim,
semog wrote:
>
> First, I would like to keep the default TcpNoDelayEnabled setting as
> false, rather than changing it to true. Without knowing how it will
> impact other users, I think this is safer, and for those who want to tune
> their connection, they can do so. If you can clarif
20 matches
Mail list logo
