我遇到一个奇怪的问题。
我的配置是:
- activeMQ 5.15.1
- atomikos交易JMS 4.0.6
- Spring boot 2.1.7.RELEASE
我的应用程序正在通过Spring JmsTemplate.convertAndSend
方法发送消息。这些调用没有捕获任何异常,一切似乎都还可以。
但是在AMQ控制台上,队列上没有消息。
下面是成功发送AMQ日志:
2019-11-22 09:37:29,647 | INFO | Sending message: activeMQTextMessage {commandId = 8,responseRequired = false,messageId = ID:nmI16510-60675-1574375565048-1:23:2:1:1,originalDestination = null,originalTransactionId = null,producerId = ID:nmI16510-60675-1574375565048-1:23:2:1,destination = queue://testportail,transactionId = XID:[1096044365,globalId=3137322e31372e36352e37372e746d313537343337353834383839343030343731,branchId=3137322e31372e36352e37372e746d343732],expiration = 1574375885026,timestamp = 1574375849026,arrival = 0,brokerInTime = 0,brokerOutTime = 0,correlationId = null,replyTo = null,persistent =
true,type = null,priority = 9,groupID = null,groupSequence = 0,targetconsumerId = null,compressed = false,userID = null,content = org.apache.activemq.util.ByteSequence@15d17509,marshalledProperties = org.apache.activemq.util.ByteSequence@34beb533,dataStructure = null,redeliveryCounter = 0,size = 1122,properties = {VERSION=2.0,AMQ_SCHEDULED_DELAY=2000},readOnlyProperties = false,readOnlyBody = false,droppable = false,jmsXGroupFirstForConsumer = false,text = {
"type" : "MAJ_CONTact","id" : 124
}} | org.apache.activemq.broker.util.LoggingBrokerPlugin | activeMQ Transport: tcp:///172.17.65.77:61220@61611
2019-11-22 09:37:32,001 | DEBUG | Firing: Job [id=ID:nmI16510-60675-1574375565048-1:23:2:1:1,startTime=Fri Nov 22 09:37:30 NCT 2019,delay=2000,period=0,repeat=0,nextTime=Fri Nov 22 09:37:32 NCT 2019,executionCount = 1] | org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl
| JobScheduler:JMS
2019-11-22 09:37:32,002 | DEBUG | Set message ID:nmI16510-60675-1574375565048-1:23:2:1:1 timestamp from 1574375849026 to 1574375852002
| org.apache.activemq.broker.scheduler.SchedulerBroker | JobScheduler:JMS
2019-11-22 09:37:32,003 | DEBUG | actIVEMQ-DEV1 Message ID:nmI16510-60675-1574375565048-1:23:2:1:1 sent to queue://testportail
| org.apache.activemq.broker.region.Queue | JobScheduler:JMS
就我而言,我只得到第一条日志Sending message
,但没有工作被解雇。而且AMQ日志上没有错误或警告消息。其他队列不受此问题影响,并且运行良好。
要使其在队列上工作,我必须删除以下文件夹:/apache-activemq-5.15.1/data/actIVEMQ-INT/scheduler
并重新启动代理。
这是调度程序AMQ的已知问题吗?