[
https://issues.apache.org/jira/browse/AMQ-6346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15364064#comment-15364064
]
Sylvain Maucourt commented on AMQ-6346:
---------------------------------------
{code}
device/456736a4-a32a-4eca-be21-b6d10ae4649c::06270219-c703-4575-86ee-842e7cf44d93/ping
{"version":1,"state":2,"timestamp":1467798091.606}
device/456736a4-a32a-4eca-be21-b6d10ae4649c::06270219-c703-4575-86ee-842e7cf44d93/ping
{"version":1,"state":0}
device/456736a4-a32a-4eca-be21-b6d10ae4649c::06270219-c703-4575-86ee-842e7cf44d93/ping
(null)
{code}
{code}
2016-07-06 11:44:03,537 | INFO | send() clientId:
06270219-c703-4575-86ee-842e7cf44d93 userName:
456736a4-a32a-4eca-be21-b6d10ae4649c::06270219-c703-4575-86ee-842e7cf44d93
send: ActiveMQBytesMessage {commandId = 7, responseRequired = false, messageId
= ID:deverylight-all-snapshot-39700-1467796619118-3:30:-1:1:2,
originalDestination = null, originalTransactionId = null, producerId =
ID:deverylight-all-snapshot-39700-1467796619118-3:30:-1:1, destination =
topic://device.456736a4-a32a-4eca-be21-b6d10ae4649c::06270219-c703-4575-86ee-842e7cf44d93.ping,
transactionId = null, expiration = 0, timestamp = 1467798243536, arrival = 0,
brokerInTime = 0, brokerOutTime = 0, correlationId = null, replyTo = null,
persistent = false, type = null, priority = 4, groupID = null, groupSequence =
0, targetConsumerId = null, compressed = false, userID = null, content =
org.apache.activemq.util.ByteSequence@27666d7e, marshalledProperties = null,
dataStructure = null, redeliveryCounter = 0, size = 0, properties =
{ActiveMQ.MQTT.QoS=1, ActiveMQ.Retain=true}, readOnlyProperties = true,
readOnlyBody = true, droppable = false, jmsXGroupFirstForConsumer = false}
ActiveMQBytesMessage{ bytesOut = null, dataOut = null, dataIn = null } payload:
{"version":1,"state":0} |
com.deveryware.deverylight.activemq.TokenAuthenticationBroker |
MQTTInactivityMonitor Async Task:
java.util.concurrent.ThreadPoolExecutor$Worker@1e217f8f[State = -1, empty queue]
2016-07-06 11:44:03,544 | INFO | removeConnection() clientId:
06270219-c703-4575-86ee-842e7cf44d93 userName:
456736a4-a32a-4eca-be21-b6d10ae4649c::06270219-c703-4575-86ee-842e7cf44d93
info: ConnectionInfo {commandId = 0, responseRequired = true, connectionId =
ID:deverylight-all-snapshot-39700-1467796619118-3:30, clientId =
06270219-c703-4575-86ee-842e7cf44d93, clientIp = ws://192.168.0.2:55942,
userName =
456736a4-a32a-4eca-be21-b6d10ae4649c::06270219-c703-4575-86ee-842e7cf44d93,
password = *****, brokerPath = null, brokerMasterConnector = false, manageable
= false, clientMaster = true, faultTolerant = false, failoverReconnect = false}
| com.deveryware.deverylight.activemq.TokenAuthenticationBroker |
MQTTInactivityMonitor Async Task:
java.util.concurrent.ThreadPoolExecutor$Worker@1e217f8f[State = -1, empty queue]
2016-07-06 11:44:03,544 | WARN | Transport Connection to:
ws://192.168.0.2:55942 failed:
org.apache.activemq.transport.InactivityIOException: Channel was inactive for
too (>30000) long: ws://192.168.0.2:55942 |
org.apache.activemq.broker.TransportConnection.Transport |
MQTTInactivityMonitor Async Task:
java.util.concurrent.ThreadPoolExecutor$Worker@1e217f8f[State = -1, empty queue]
{code}
works fine thanks!
> Concurrent access to a MQTT Transport from WebSocket client can deadlock
> ------------------------------------------------------------------------
>
> Key: AMQ-6346
> URL: https://issues.apache.org/jira/browse/AMQ-6346
> Project: ActiveMQ
> Issue Type: Bug
> Components: Broker
> Affects Versions: 5.13.3
> Reporter: Christopher L. Shannon
> Assignee: Christopher L. Shannon
> Fix For: 5.14.0, 5.13.4
>
>
> Just like in AMQ-6046, WebSocket connections can encounter a deadlock when
> the Jetty side allows for concurrent access to the Transport instance that
> forwards commands onto the broker core.
> This was fixed for Stomp in AMQ-6046 but also needs to be fixed for MQTT.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
