查看本类的 API文档回源码主页

   /*
    * Copyright 2014 The Netty Project
    *
    * The Netty Project licenses this file to you under the Apache License,
    * version 2.0 (the "License"); you may not use this file except in compliance
    * with the License. You may obtain a copy of the License at:
    *
    *   https://www.apache.org/licenses/LICENSE-2.0
    *
   * Unless required by applicable law or agreed to in writing, software
   * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
   * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
   * License for the specific language governing permissions and limitations
   * under the License.
   */
  
  package io.netty.handler.codec.mqtt;
  
  import java.util.Arrays;
  
  import io.netty.util.CharsetUtil;
  import io.netty.util.internal.StringUtil;
  
  /**
   * Payload of {@link MqttConnectMessage}
   */
  public final class MqttConnectPayload {
  
      private final String clientIdentifier;
      private final MqttProperties willProperties;
      private final String willTopic;
      private final byte[] willMessage;
      private final String userName;
      private final byte[] password;
  
      /**
       * @deprecated use {@link MqttConnectPayload#MqttConnectPayload(String,
       * MqttProperties, String, byte[], String, byte[])} instead
       */
      @Deprecated
      public MqttConnectPayload(
              String clientIdentifier,
              String willTopic,
              String willMessage,
              String userName,
              String password) {
          this(
            clientIdentifier,
            MqttProperties.NO_PROPERTIES,
            willTopic,
            willMessage.getBytes(CharsetUtil.UTF_8),
            userName,
            password.getBytes(CharsetUtil.UTF_8));
      }
  
      public MqttConnectPayload(
              String clientIdentifier,
              String willTopic,
              byte[] willMessage,
              String userName,
              byte[] password) {
          this(clientIdentifier,
                  MqttProperties.NO_PROPERTIES,
                  willTopic,
                  willMessage,
                  userName,
                  password);
      }
  
      public MqttConnectPayload(
              String clientIdentifier,
              MqttProperties willProperties,
              String willTopic,
              byte[] willMessage,
              String userName,
              byte[] password) {
          this.clientIdentifier = clientIdentifier;
          this.willProperties = MqttProperties.withEmptyDefaults(willProperties);
          this.willTopic = willTopic;
          this.willMessage = willMessage;
          this.userName = userName;
          this.password = password;
      }
  
      public String clientIdentifier() {
          return clientIdentifier;
      }
  
      public MqttProperties willProperties() {
          return willProperties;
      }
  
      public String willTopic() {
          return willTopic;
      }
  
      /**
       * @deprecated use {@link MqttConnectPayload#willMessageInBytes()} instead
       */
     @Deprecated
     public String willMessage() {
         return willMessage == null ? null : new String(willMessage, CharsetUtil.UTF_8);
     }
 
     public byte[] willMessageInBytes() {
         return willMessage;
     }
 
     public String userName() {
         return userName;
     }
 
     /**
      * @deprecated use {@link MqttConnectPayload#passwordInBytes()} instead
      */
     @Deprecated
     public String password() {
         return password == null ? null : new String(password, CharsetUtil.UTF_8);
     }
 
     public byte[] passwordInBytes() {
         return password;
     }
 
     @Override
     public String toString() {
         return new StringBuilder(StringUtil.simpleClassName(this))
             .append('[')
             .append("clientIdentifier=").append(clientIdentifier)
             .append(", willTopic=").append(willTopic)
             .append(", willMessage=").append(Arrays.toString(willMessage))
             .append(", userName=").append(userName)
             .append(", password=").append(Arrays.toString(password))
             .append(']')
             .toString();
     }
 }