MQTT Connector を使用したクライアント ID の設定

    <modelVersion>4.0.0</modelVersion>
    <groupId>org.example</groupId>
    <artifactId>mqtt3-extended-connector</artifactId>
    <version>1.0.0-SNAPSHOT</version>
    <packaging>mule-extension</packaging>
    <name>MQTT Extended Connector</name>

    <parent>
        <groupId>org.mule.extensions</groupId>
        <artifactId>mule-ee-core-modules-parent</artifactId>
    </parent>

    <dependencies>
        <dependency>
            <groupId>com.mulesoft.connectors</groupId>
            <artifactId>mule4-mqtt3-connector</artifactId>
            <version>1.0.0</version>
            <classifier>mule-plugin</classifier>
        </dependency>
    </dependencies>
xml✓ コピー済み

@Xml(prefix = "mqtt3-extended")
@Extension(name = "MQTT3Extended", category = SELECT)
public class MQTT3ExtendedConnector {
}
java✓ コピー済み

@Xml(prefix = "mqtt3-extended")
@Extension(name = "MQTT3Extended", category = SELECT)
@Import(type = ClientIDGenerator.class)
public class MQTT3ExtendedConnector {

}
java✓ コピー済み

@Alias("custom-client-id")
public class MyClientIdGenerator implements ClientIDGenerator {

  /**
   * Client id to be used to identify the connection to the MQTT broker.
   */
  @Parameter
  @DisplayName("Client ID")
  @Optional(defaultValue = "")
  @Expression(NOT_SUPPORTED)
  @ClientId
  protected String clientId;

  private String suffix = "my-custom-suffix";

  /**
   * @return a client ID that results from concatenating the clientId and a randomly generated UUID string.
   */
  @Override
  public String generateClientID() {
    return clientId + (clientId.isEmpty() ? "" : "-") + suffix;
  }
}
java✓ コピー済み

@Xml(prefix = "mqtt3-extended")
@Extension(name = "MQTT3Extended", category = SELECT)
@Import(type = ClientIDGenerator.class)
@Export(classes = {MyClientIdGenerator.class})
@SubTypeMapping(baseType = ClientIDGenerator.class, subTypes = {MyClientIdGenerator.class})
public class MQTT3ExtendedConnector {

}
java✓ コピー済み

	<groupId>com.mycompany</groupId>
	<artifactId>mqtt-custom-id-generator</artifactId>
	<version>1.0.0-SNAPSHOT</version>
	<packaging>mule-application</packaging>

	<name>mqtt-custom-id-generator</name>

	<properties>
		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
		<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>

		<app.runtime>4.3.0-20210719</app.runtime>
		<mule.maven.plugin.version>3.5.2</mule.maven.plugin.version>
	</properties>

	<build>
		<plugins>
			<plugin>
				<groupId>org.apache.maven.plugins</groupId>
				<artifactId>maven-clean-plugin</artifactId>
				<version>3.0.0</version>
			</plugin>
			<plugin>
				<groupId>org.mule.tools.maven</groupId>
				<artifactId>mule-maven-plugin</artifactId>
				<version>${mule.maven.plugin.version}</version>
				<extensions>true</extensions>
				<configuration>
					<sharedLibraries>
						<sharedLibrary>
							<groupId>org.eclipse.paho</groupId>
							<artifactId>org.eclipse.paho.client.mqttv3</artifactId>
						</sharedLibrary>
					</sharedLibraries>
				</configuration>
			</plugin>
		</plugins>
	</build>

	<dependencies>
		<dependency>
			<groupId>org.mule.connectors</groupId>
			<artifactId>mule-http-connector</artifactId>
			<version>1.5.25</version>
			<classifier>mule-plugin</classifier>
		</dependency>
		<dependency>
			<groupId>org.mule.connectors</groupId>
			<artifactId>mule-sockets-connector</artifactId>
			<version>1.2.1</version>
			<classifier>mule-plugin</classifier>
		</dependency>
		<dependency>
			<groupId>org.eclipse.paho</groupId>
			<artifactId>org.eclipse.paho.client.mqttv3</artifactId>
			<version>1.2.5</version>
		</dependency>
		<dependency>
		    <groupId>org.example</groupId>
		    <artifactId>mqtt3-extended-connector</artifactId>
		    <version>1.0.0-SNAPSHOT</version>
		    <classifier>mule-plugin</classifier>
		</dependency>
		<dependency>
		    <groupId>com.mulesoft.connectors</groupId>
		    <artifactId>mule4-mqtt3-connector</artifactId>
		    <version>1.0.0</version>
		    <classifier>mule-plugin</classifier>
		</dependency>
	</dependencies>
</project>
xml✓ コピー済み
コンテンツを展開する