|
13 | 13 | * See the License for the specific language governing permissions and |
14 | 14 | * limitations under the License. |
15 | 15 | */ |
16 | | -package com.hivemq.extensions.mqtt.message.log.config; |
| 16 | +package com.hivemq.extensions.log.mqtt.config; |
17 | 17 |
|
18 | 18 | import com.hivemq.extension.sdk.api.annotations.NotNull; |
19 | 19 | import org.slf4j.Logger; |
|
24 | 24 | import java.io.InputStream; |
25 | 25 | import java.util.Properties; |
26 | 26 |
|
27 | | -import static com.hivemq.extensions.mqtt.message.log.config.MqttMessageLogConfig.CLIENT_CONNECT; |
28 | | -import static com.hivemq.extensions.mqtt.message.log.config.MqttMessageLogConfig.CLIENT_DISCONNECT; |
29 | | -import static com.hivemq.extensions.mqtt.message.log.config.MqttMessageLogConfig.CONNACK_SEND; |
30 | | -import static com.hivemq.extensions.mqtt.message.log.config.MqttMessageLogConfig.FALSE; |
31 | | -import static com.hivemq.extensions.mqtt.message.log.config.MqttMessageLogConfig.PING_REQ_RECEIVED; |
32 | | -import static com.hivemq.extensions.mqtt.message.log.config.MqttMessageLogConfig.PING_RESP_SEND; |
33 | | -import static com.hivemq.extensions.mqtt.message.log.config.MqttMessageLogConfig.PUBACK_RECEIVED; |
34 | | -import static com.hivemq.extensions.mqtt.message.log.config.MqttMessageLogConfig.PUBACK_SEND; |
35 | | -import static com.hivemq.extensions.mqtt.message.log.config.MqttMessageLogConfig.PUBCOMP_RECEIVED; |
36 | | -import static com.hivemq.extensions.mqtt.message.log.config.MqttMessageLogConfig.PUBCOMP_SEND; |
37 | | -import static com.hivemq.extensions.mqtt.message.log.config.MqttMessageLogConfig.PUBLISH_RECEIVED; |
38 | | -import static com.hivemq.extensions.mqtt.message.log.config.MqttMessageLogConfig.PUBLISH_SEND; |
39 | | -import static com.hivemq.extensions.mqtt.message.log.config.MqttMessageLogConfig.PUBREC_RECEIVED; |
40 | | -import static com.hivemq.extensions.mqtt.message.log.config.MqttMessageLogConfig.PUBREC_SEND; |
41 | | -import static com.hivemq.extensions.mqtt.message.log.config.MqttMessageLogConfig.PUBREL_RECEIVED; |
42 | | -import static com.hivemq.extensions.mqtt.message.log.config.MqttMessageLogConfig.PUBREL_SEND; |
43 | | -import static com.hivemq.extensions.mqtt.message.log.config.MqttMessageLogConfig.SUBACK_SEND; |
44 | | -import static com.hivemq.extensions.mqtt.message.log.config.MqttMessageLogConfig.SUBSCRIBE_RECEIVED; |
45 | | -import static com.hivemq.extensions.mqtt.message.log.config.MqttMessageLogConfig.TRUE; |
46 | | -import static com.hivemq.extensions.mqtt.message.log.config.MqttMessageLogConfig.UNSUBACK_SEND; |
47 | | -import static com.hivemq.extensions.mqtt.message.log.config.MqttMessageLogConfig.UNSUBSCRIBE_RECEIVED; |
48 | | -import static com.hivemq.extensions.mqtt.message.log.config.MqttMessageLogConfig.VERBOSE; |
| 27 | +import static com.hivemq.extensions.log.mqtt.config.MqttMessageLogConfig.CLIENT_CONNECT; |
| 28 | +import static com.hivemq.extensions.log.mqtt.config.MqttMessageLogConfig.CLIENT_DISCONNECT; |
| 29 | +import static com.hivemq.extensions.log.mqtt.config.MqttMessageLogConfig.CONNACK_SEND; |
| 30 | +import static com.hivemq.extensions.log.mqtt.config.MqttMessageLogConfig.FALSE; |
| 31 | +import static com.hivemq.extensions.log.mqtt.config.MqttMessageLogConfig.PING_REQ_RECEIVED; |
| 32 | +import static com.hivemq.extensions.log.mqtt.config.MqttMessageLogConfig.PING_RESP_SEND; |
| 33 | +import static com.hivemq.extensions.log.mqtt.config.MqttMessageLogConfig.PUBACK_RECEIVED; |
| 34 | +import static com.hivemq.extensions.log.mqtt.config.MqttMessageLogConfig.PUBACK_SEND; |
| 35 | +import static com.hivemq.extensions.log.mqtt.config.MqttMessageLogConfig.PUBCOMP_RECEIVED; |
| 36 | +import static com.hivemq.extensions.log.mqtt.config.MqttMessageLogConfig.PUBCOMP_SEND; |
| 37 | +import static com.hivemq.extensions.log.mqtt.config.MqttMessageLogConfig.PUBLISH_RECEIVED; |
| 38 | +import static com.hivemq.extensions.log.mqtt.config.MqttMessageLogConfig.PUBLISH_SEND; |
| 39 | +import static com.hivemq.extensions.log.mqtt.config.MqttMessageLogConfig.PUBREC_RECEIVED; |
| 40 | +import static com.hivemq.extensions.log.mqtt.config.MqttMessageLogConfig.PUBREC_SEND; |
| 41 | +import static com.hivemq.extensions.log.mqtt.config.MqttMessageLogConfig.PUBREL_RECEIVED; |
| 42 | +import static com.hivemq.extensions.log.mqtt.config.MqttMessageLogConfig.PUBREL_SEND; |
| 43 | +import static com.hivemq.extensions.log.mqtt.config.MqttMessageLogConfig.SUBACK_SEND; |
| 44 | +import static com.hivemq.extensions.log.mqtt.config.MqttMessageLogConfig.SUBSCRIBE_RECEIVED; |
| 45 | +import static com.hivemq.extensions.log.mqtt.config.MqttMessageLogConfig.TRUE; |
| 46 | +import static com.hivemq.extensions.log.mqtt.config.MqttMessageLogConfig.UNSUBACK_SEND; |
| 47 | +import static com.hivemq.extensions.log.mqtt.config.MqttMessageLogConfig.UNSUBSCRIBE_RECEIVED; |
| 48 | +import static com.hivemq.extensions.log.mqtt.config.MqttMessageLogConfig.VERBOSE; |
49 | 49 |
|
50 | 50 | public class MqttMessageLogConfigReader { |
51 | 51 |
|
|
0 commit comments