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.
