File tree Expand file tree Collapse file tree 1 file changed +7
-3
lines changed Expand file tree Collapse file tree 1 file changed +7
-3
lines changed Original file line number Diff line number Diff line change @@ -82,6 +82,7 @@ - (void) connect {
82
82
}
83
83
if (!self.manager ) {
84
84
dispatch_queue_t queue = dispatch_queue_create (" com.hawking.app.anchor.mqtt" , NULL );
85
+
85
86
self.manager = [[MQTTSessionManager alloc ] initWithPersistence: NO maxWindowSize: MQTT_MAX_WINDOW_SIZE maxMessages: MQTT_MAX_MESSAGES maxSize: MQTT_MAX_SIZE maxConnectionRetryInterval: 60.0 connectInForeground: NO streamSSLLevel: nil queue: queue];
86
87
self.manager .delegate = self;
87
88
MQTTCFSocketTransport *transport = [[MQTTCFSocketTransport alloc ] init ];
@@ -147,13 +148,16 @@ - (void)sessionManager:(MQTTSessionManager *)sessonManager didChangeState:(MQTTS
147
148
@" message" : @" connecting"
148
149
}];
149
150
break ;
150
- case MQTTSessionManagerStateError:
151
+ case MQTTSessionManagerStateError: {
152
+ NSError *lastError = self.manager .lastErrorCode ;
153
+ NSString *errorMsg = [NSString stringWithFormat: @" error: %@ " , [lastError localizedDescription ]];
151
154
[self .emitter sendEventWithName: @" mqtt_events"
152
155
body: @{@" event" : @" error" ,
153
156
@" clientRef" : self.clientRef ,
154
- @" message" : @" error "
157
+ @" message" : errorMsg
155
158
}];
156
159
break ;
160
+ }
157
161
case MQTTSessionManagerStateStarting:
158
162
default :
159
163
break ;
@@ -215,4 +219,4 @@ - (void)dealloc
215
219
[self disconnect ];
216
220
}
217
221
218
- @end
222
+ @end
You can’t perform that action at this time.
0 commit comments