What steps will reproduce the problem?
execute "mvn clean package".
it will throw exception like:
java.lang.RuntimeException: Can't find a ConnectionDescriptor for client Subscri
ber in cache {TestClient=org.dna.mqtt.moquette.server.ConnectionDescriptor@39f96
84}
at org.dna.mqtt.moquette.messaging.spi.impl.ProtocolProcessor.sendPublis
h(ProtocolProcessor.java:290)
at org.dna.mqtt.moquette.messaging.spi.impl.ProtocolProcessor.sendPublis
h(ProtocolProcessor.java:268)
at org.dna.mqtt.moquette.messaging.spi.impl.ProtocolProcessor.publish2Su
bscribers(ProtocolProcessor.java:245)
at org.dna.mqtt.moquette.messaging.spi.impl.ProtocolProcessor.processPub
lish(ProtocolProcessor.java:219)
at org.dna.mqtt.moquette.messaging.spi.impl.SimpleMessaging.onEvent(Simp
leMessaging.java:123)
at org.dna.mqtt.moquette.messaging.spi.impl.SimpleMessaging.onEvent(Simp
leMessaging.java:28)
at com.lmax.disruptor.BatchEventProcessor.run(BatchEventProcessor.java:1
13)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:47
1)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:334)
at java.util.concurrent.FutureTask.run(FutureTask.java:166)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.
java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor
.java:615)
at java.lang.Thread.run(Thread.java:722)
and
org.fusesource.hawtdb.api.IOPagingException: Invalid extent read request. The r
equested page was not an extent: 8
at org.fusesource.hawtdb.internal.page.Extent.readHeader(Extent.java:85)
at org.fusesource.hawtdb.internal.page.Extent.readOpen(Extent.java:94)
at org.fusesource.hawtdb.internal.page.ExtentInputStream.<init>(ExtentIn
putStream.java:45)
at org.fusesource.hawtdb.api.PageFileFactory.open(PageFileFactory.java:1
10)
at org.dna.mqtt.moquette.messaging.spi.impl.HawtDBStorageService.<init>(
HawtDBStorageService.java:82)
at org.dna.mqtt.moquette.messaging.spi.impl.SimpleMessaging.processInit(
SimpleMessaging.java:168)
at org.dna.mqtt.moquette.messaging.spi.impl.SimpleMessaging.onEvent(Simp
leMessaging.java:160)
at org.dna.mqtt.moquette.messaging.spi.impl.SimpleMessaging.onEvent(Simp
leMessaging.java:28)
at com.lmax.disruptor.BatchEventProcessor.run(BatchEventProcessor.java:1
13)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:47
1)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:334)
at java.util.concurrent.FutureTask.run(FutureTask.java:166)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.
java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor
.java:615)
at java.lang.Thread.run(Thread.java:722)
What is the expected output? What do you see instead?
What version of the product are you using? On what operating system?
version 0.4, windows7 64bit.
Please provide any additional information below.
Original issue reported on code.google.com by 575762...@qq.com on 13 Dec 2013 at 12:22
Original issue reported on code.google.com by
575762...@qq.com
on 13 Dec 2013 at 12:22