Mailing-List: contact commits-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@activemq.apache.org
Date: Mon, 23 Apr 2012 08:07:52 +0000 (UTC)
From: "Torben Fitschen (JIRA)" <jira@apache.org>
To: commits@activemq.apache.org
Message-ID: <36651471.4055.1335168472432.JavaMail.tomcat@hel.zones.apache.org>
Subject: [jira] [Created] (APLO-197) Negative queue metrics (queue size:
 -1.838 / enqueued: 1.000 / dequeued: 2.838)
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit

Torben Fitschen created APLO-197:
------------------------------------

             Summary: Negative queue metrics (queue size: -1.838 / enqueued: 1.000 / dequeued: 2.838)
                 Key: APLO-197
                 URL: https://issues.apache.org/jira/browse/APLO-197
             Project: ActiveMQ Apollo
          Issue Type: Bug
    Affects Versions: 1.2
         Environment: 1.2 release, 99-trunk-20120421.031307-21
            Reporter: Torben Fitschen


Metrics:

{
	"id" : "Foo",
	"state" : "STARTED",
	"state_since" : 1335163351974,
	"config" : {
		"full_policy" : "block",
		"other" : [],
		"auto_delete_after" : 10
	},
	"binding" : {
		"@class" : "queue_destination",
		"name" : "Foo",
		"path" : []
	},
	"metrics" : {
		"current_time" : 1335168324251,
		"enqueue_item_counter" : 1000,
		"enqueue_size_counter" : 228770,
		"enqueue_ts" : 1335164951528,
		"dequeue_item_counter" : 2838,
		"dequeue_size_counter" : 649441,
		"dequeue_ts" : 1335168238561,
		"producer_counter" : 1,
		"consumer_counter" : 5830,
		"producer_count" : 0,
		"consumer_count" : 0,
		"expired_item_counter" : 0,
		"expired_size_counter" : 0,
		"expired_ts" : 1335163351972,
		"nack_item_counter" : 486,
		"nack_size_counter" : 111233,
		"nack_ts" : 1335166069831,
		"queue_size" : -420671,
		"queue_items" : -1838,
		"swapped_in_size_max" : 655360,
		"swapped_in_size" : 0,
		"swapped_in_items" : 0,
		"swapping_in_size" : 0,
		"swapping_out_size" : 0,
		"swap_out_item_counter" : 251,
		"swap_out_size_counter" : 57388,
		"swap_in_item_counter" : 1195318,
		"swap_in_size_counter" : 273567320
	},
	"entries" : [],
	"producers" : [],
	"consumers" : []
}
---------------------------------------------------------------------------------
Log:

WARN  | java.lang.AssertionError: Node is not linked | org.apache.activemq.apollo.broker.Broker | hawtdispatch-DEFAULT-1
DEBUG | java.lang.AssertionError: Node is not linked | org.apache.activemq.apollo.broker.Broker | hawtdispatch-DEFAULT-1
java.lang.AssertionError: Node is not linked
        at org.apache.activemq.apollo.util.list.LinkedNode.assertLinked(LinkedNode.java:64)
        at org.apache.activemq.apollo.util.list.LinkedNode.isTailNode(LinkedNode.java:73)
        at org.apache.activemq.apollo.util.list.LinkedNode.getNext(LinkedNode.java:48)
        at org.apache.activemq.apollo.broker.QueueEntry.nextOrTail(Queue.scala:1333)
        at org.apache.activemq.apollo.broker.Subscription$AcquiredQueueEntry.ack(Queue.scala:2427)
        at org.apache.activemq.apollo.broker.Queue$$anonfun$drain_acks$1$$anonfun$apply$mcV$sp$8.apply(Queue.scala:1019)
        at org.apache.activemq.apollo.broker.Queue$$anonfun$drain_acks$1$$anonfun$apply$mcV$sp$8.apply(Queue.scala:1014)
        at scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:59)
        at scala.collection.immutable.List.foreach(List.scala:45)
        at scala.collection.generic.TraversableForwarder$class.foreach(TraversableForwarder.scala:30)
        at scala.collection.mutable.ListBuffer.foreach(ListBuffer.scala:42)
        at org.apache.activemq.apollo.broker.Queue$$anonfun$drain_acks$1.apply$mcV$sp(Queue.scala:1014)
        at org.apache.activemq.apollo.broker.Queue$$anonfun$drain_acks$1.apply(Queue.scala:1014)
        at org.apache.activemq.apollo.broker.Queue$$anonfun$drain_acks$1.apply(Queue.scala:1014)
        at org.apache.activemq.apollo.broker.Queue.might_unfill(Queue.scala:515)
        at org.apache.activemq.apollo.broker.Queue.drain_acks(Queue.scala:1013)
        at org.apache.activemq.apollo.broker.Queue$$anonfun$1.apply$mcV$sp(Queue.scala:98)
        at org.fusesource.hawtdispatch.package$$anon$3.run(hawtdispatch.scala:358)
        at org.fusesource.hawtdispatch.internal.HawtCustomDispatchSource$1.run(HawtCustomDispatchSource.java:125)
        at org.fusesource.hawtdispatch.internal.SerialDispatchQueue.run(SerialDispatchQueue.java:96)
        at org.fusesource.hawtdispatch.internal.pool.SimpleThread.run(SimpleThread.java:77)

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira