CCH0124 opened a new issue, #5107:
URL: https://github.com/apache/camel-quarkus/issues/5107

   ### Bug description
   
   My routed defined below
   
   ```java
   @Override
       public void configure() throws UnknownHostException {
   
           final PahoMqtt5EndpointBuilderFactory.PahoMqtt5EndpointBuilder 
endpoint = pahoMqtt5("test/1/2")
                   .brokerUrl(brokerUrl)
                   .sslClientProps(properties)
                   .clientId(InetAddress.getLocalHost().getHostName())
                   .userName("123456");
   
           log.infof("endpoint: %s", endpoint.getRawUri());
   
           from(direct("sendMqtt"))
                   .marshal().json(JsonLibrary.Jsonb)
                   .log("${body}")
                   .to(endpoint);
       }
   ```
   I defined `userName` 123456, but the EMQX server message shows username as 
undefined.
   
   EMQX Server message:
   
   ```bash
   ...
   2023-07-20T10:59:40.420785+08:00 [debug] msg: mqtt_packet_received, mfa: 
emqx_channel:handle_in/2, line: 338, peername: 172.10.0.2:40048, clientid: 
camel-paho-a2f84a1f-14a5-47f2-b4bd-c32a8354f012, packet: CONNECT(Q0, R0, D0, 
ClientId=camel-paho-a2f84a1f-14a5-47f2-b4bd-c32a8354f012, ProtoName=MQTT, 
ProtoVsn=5, CleanStart=true, KeepAlive=60, Username=undefined, Password=), tag: 
MQTT
   ...
   ```
   
   The EMQX authentication field is defined as `username`.
   
   It caused paho5 to have an authentication failure message.
   ```
   Caused by: org.apache.camel.RuntimeCamelException: Not authorized. (135)
   ```
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Reply via email to