[
https://issues.apache.org/jira/browse/ARTEMIS-5254?focusedWorklogId=964542&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-964542
]
ASF GitHub Bot logged work on ARTEMIS-5254:
-------------------------------------------
Author: ASF GitHub Bot
Created on: 02/Apr/25 20:12
Start Date: 02/Apr/25 20:12
Worklog Time Spent: 10m
Work Description: jbertram opened a new pull request, #5598:
URL: https://github.com/apache/activemq-artemis/pull/5598
(no comment)
Issue Time Tracking
-------------------
Worklog Id: (was: 964542)
Remaining Estimate: 0h
Time Spent: 10m
> MQTTSession.stop failure: Parameters not enabled.
> -------------------------------------------------
>
> Key: ARTEMIS-5254
> URL: https://issues.apache.org/jira/browse/ARTEMIS-5254
> Project: ActiveMQ Artemis
> Issue Type: Bug
> Affects Versions: 2.38.0
> Environment: when lwt occued MQTTSession.stop failure Parameters not
> enabled for
> ActiveMQServerSessionPlugin beforeCloseSession methd,it alway false;
> Reporter: gongping.zhu
> Assignee: Justin Bertram
> Priority: Major
> Labels: pull-request-available
> Time Spent: 10m
> Remaining Estimate: 0h
>
> void stop(boolean failure) throws Exception {
> state.setFailed(failure);
> if (!stopped) {
> protocolHandler.stop();
> subscriptionManager.stop();
> mqttPublishManager.stop();
> if (serverSession != null) {
> serverSession.stop();
> serverSession.close(false);//need replace
> }
> if (internalServerSession != null) {
> internalServerSession.stop();
> internalServerSession.close(false);//need replace
> }
> state.setAttached(false);//need replace
> state.setDisconnectedTime(System.currentTimeMillis());
> state.clearTopicAliases();
> if (getVersion() == MQTTVersion.MQTT_5) {
> if (state.getClientSessionExpiryInterval() == 0) {
> if (state.isWill() && failure) {
> // If the session expires the will message must be sent no matter the will
> delay
> sendWillMessage();
> }
> clean(false);
> stateManager.removeSessionState(connection.getClientID());
> }
> } else {
> if (state.isWill() && failure) {
> sendWillMessage();
> }
> if (isClean()) {
> clean(false);
> stateManager.removeSessionState(connection.getClientID());
> }
> }
> }
> stopped = true;
> }
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact
