Re: message time-stamp missing (send from statisticsBrokerPlugin)

[Timothy Bish]

On 01/31/2014 04:36 AM, nader wrote:

Hi

Here is the simplified code I use

# With assumption of below settings in activemq.xml
#    <broker ....>
#        ....
#        <plugins>
#             <statisticsBrokerPlugin/>
#        </plugins>
#        ....
#    </broker>

from stompest.config import StompConfig
from stompest.protocol import StompSpec
from stompest.sync import Stomp
import time

STOMP_URI='tcp://192.168.0.52:61620'

CONFIG = StompConfig(STOMP_URI)

QUEUE = '/queue/testMon'
StatQ = '/queue/ActiveMQ.Statistics.Destination.testMon'

if __name__ == '__main__':
     clientMon = Stomp(CONFIG)
     clientMon.connect()

#subscription is really not necessary, just for output format

     clientMon.subscribe(QUEUE,
{'transformation':'jms-map-xml',StompSpec.ACK_HEADER:
StompSpec.ACK_CLIENT_INDIVIDUAL})

     print 'Sending a message ...'
     clientMon.send(QUEUE, body='Some data', headers={'persistent':'true'})
     time.sleep(5)
     print "Sending stat message ..."
     clientMon.send(StatQ, headers={'reply-to':QUEUE})
     frame = clientMon.receiveFrame()
     clientMon.ack(frame)
     print frame
     clientMon.disconnect()

and the result is:

Sending a message ...
Sending stat message ...
MESSAGE
message-id:ID:XXXXXXXXX-1635-1391159088566-2:1:0:0:1
type:Advisory
transformation:jms-map-xml
destination:/queue/testMon
timestamp:0
expires:0
priority:0

<map>
   <entry>
     <string>memoryUsage</string>
     <long>0</long>
   </entry>
   <entry>
     <string>dequeueCount</string>
     <long>0</long>
   </entry>
   <entry>
     <string>inflightCount</string>
     <long>0</long>
   </entry>
   <entry>
     <string>messagesCached</string>
     <long>0</long>
   </entry>
   <entry>
     <string>averageEnqueueTime</string>
     <double>0.0</double>
   </entry>
   <entry>
     <string>destinationName</string>
     <string>queue://testMon</string>
   </entry>
   <entry>
     <string>averageMessageSize</string>
     <double>0.0</double>
   </entry>
   <entry>
     <string>memoryPercentUsage</string>
     <int>0</int>
   </entry>
   <entry>
     <string>size</string>
     <long>0</long>
   </entry>
   <entry>
     <string>producerCount</string>
     <long>0</long>
   </entry>
   <entry>
     <string>consumerCount</string>
     <long>1</long>
   </entry>
   <entry>
     <string>minEnqueueTime</string>
     <double>0.0</double>
   </entry>
   <entry>
     <string>expiredCount</string>
     <long>0</long>
   </entry>
   <entry>
     <string>dispatchCount</string>
     <long>0</long>
   </entry>
   <entry>
     <string>maxEnqueueTime</string>
     <double>0.0</double>
   </entry>
   <entry>
     <string>enqueueCount</string>
     <long>0</long>
   </entry>
   <entry>
     <string>memoryLimit</string>
     <long>726571418</long>
   </entry>
</map>


As you can see, the message property 'timestamp at the top is '0'.

If I use administration console, the value of "1970-01-01T01:00:00+01:00"
(Unix time 0).

Secondly, the priority is '0' which I cannot change.

Tried many permutation of above code with no avail.





--
View this message in context: 
http://activemq.2283324.n4.nabble.com/message-time-stamp-missing-send-from-statisticsBrokerPlugin-tp4677124p4677152.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Fixed it for you:
https://issues.apache.org/jira/browse/AMQ-5011

You'll need to wait for a 5.10 snapshot to build with the fix in it.

--
Tim Bish
Sr Software Engineer | RedHat Inc.
tim.b...@redhat.com | www.fusesource.com | www.redhat.com
skype: tabish121 | twitter: @tabish121
blog: http://timbish.blogspot.com/