Mulesoft Custom Connector с использованием Mule SDK для Mule 4

Это очень важно, так как мы используем Mule HTTP Client, а не Apache HTTP Client. Мы вводим HTTP-клиент Mule в наш соединитель, используя аннотацию @Inject.

WeatherConnection.java

package org.mule.connect.internal.connection;

/**
 * This class represents an extension connection just as example (there is no real connection with anything here c:).
 */
public class WeatherConnection {

      private WeatherGenConfig genConfig;
      private int connectionTimeout;
      private HttpClient httpClient;
      private HttpRequestBuilder httpRequestBuilder;

      /**
       * 
       * @param gConfig
       * @param pConfig
       * @param cTimeout
       */
      public WeatherConnection(HttpService httpService, WeatherGenConfig gConfig, int cTimeout) {
            genConfig = gConfig;
            connectionTimeout = cTimeout;

            initHttpClient(httpService);
      }

      /**
       * 
       * @param httpService
       */

      public void initHttpClient(HttpService httpService){
            HttpClientConfiguration.Builder builder = new HttpClientConfiguration.Builder();
            builder.setName("AnupamUsWeather");
            httpClient = httpService.getClientFactory().create(builder.build());

            httpRequestBuilder = HttpRequest.builder();

            httpClient.start();
      }

      /**
       * 
       */
   public void invalidate() {
       httpClient.stop();
   }

   public boolean isConnected() throws Exception{

     String wChannel = genConfig.getWChannel();
     String strUri = WeatherConstants.getUrl(wChannel);
     MultiMap<String, String> qParams = WeatherConstants.getQueryForZip(wChannel,30328);

            HttpRequest request = httpRequestBuilder
                          .method(Method.GET) 
                          .uri(strUri)
                          .queryParams(qParams)
                          .build();

            HttpResponse httpResponse = httpClient.send(request,connectionTimeout,false,null);

            if (httpResponse.getStatusCode() >= 200 && httpResponse.getStatusCode() < 300)
                   return true;
            else
                   throw new ConnectionException("Error connecting to the server: Error Code " + httpResponse.getStatusCode()
                   + "~" + httpResponse);
      }

   /**
    * 
    * @param Zip
    * @return
    */
      public InputStream callHttpZIP(int iZip){
            HttpResponse httpResponse = null;
            String strUri = WeatherConstants.getUrl(genConfig.getWChannel());
            System.out.println("URL is: " + strUri);
            MultiMap<String, String> qParams = WeatherConstants.getQueryForZip(genConfig.getWChannel(),iZip);

            HttpRequest request = httpRequestBuilder
                          .method(Method.GET) 
                          .uri(strUri)
                          .queryParams(qParams)
                          .build();

            System.out.println("Request is: " + request);

            try {

                   httpResponse = httpClient.send(request,connectionTimeout,false,null);
                   System.out.println(httpResponse);
                   return httpResponse.getEntity().getContent();

            } catch (IOException e) {
                   // TODO Auto-generated catch block
                   e.printStackTrace();
            } catch (TimeoutException e) {
                   // TODO Auto-generated catch block
                   e.printStackTrace();
            } catch (Exception e) {
                   // TODO Auto-generated catch block
                   e.printStackTrace();
            }
            return null;
      }     
}

package org.mule.connect.internal.operations;

/**
 * This class is a container for operations, every public method in this class will be taken as an extension operation.
 */
public class WeatherZipOperations {

     @Parameter
     @Example("30303")
     @DisplayName("ZIP Code")
     private int zipCode;

     @MediaType(value = ANY, strict = false)
     @DisplayName(WeatherConstants.ZIP)
     public InputStream getWeatherByZip(@Connection WeatherConnection connection){
           return connection.callHttpZIP(zipCode);
     }    
}

mvn clean install

mvn clean install -DskipTests

<dependency>
     <groupId>us.anupam.muleConnector</groupId>
    <artifactId>mule-weather-connector</artifactId>
     <version>1.0.0</version>
     <classifier>mule-plugin</classifier>
</dependency>

<?xml version="1.0" encoding="UTF-8"?>

<mule xmlns:weather="http://www.mulesoft.org/schema/mule/weather" xmlns:http="http://www.mulesoft.org/schema/mule/http"
      xmlns="http://www.mulesoft.org/schema/mule/core"
      xmlns:doc="http://www.mulesoft.org/schema/mule/documentation" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd
http://www.mulesoft.org/schema/mule/http http://www.mulesoft.org/schema/mule/http/current/mule-http.xsd
http://www.mulesoft.org/schema/mule/weather http://www.mulesoft.org/schema/mule/weather/current/mule-weather.xsd">
      <http:listener-config name="HTTP_Listener_config" doc:name="HTTP Listener config" doc:id="fe0a0ccb-0c9c-4f0f-a3ff-bbef06b0d209" >
            <http:listener-connection host="0.0.0.0" port="8081" />
      </http:listener-config>
      <weather:config name="Weather_Config" doc:name="Weather Config" doc:id="55ac533e-25e1-43fe-b9c9-bc262f15cfd3" >
            <weather:connection wChannel="Yahoo" />
      </weather:config>
      <flow name="weathertestFlow" doc:id="baf6323b-0ea4-4694-9440-2f1512a5c02f" >
            <http:listener doc:name="Listener" doc:id="e6d130ee-4a5d-400a-88c5-ce0414073823" config-ref="HTTP_Listener_config" path="zip" allowedMethods="GET"/>
            <weather:get-weather-by-zip zipCode="30328" doc:name="Get weather by ZIP" doc:id="f044ecd9-2048-4bbc-9cd2-cdb932b4f496" config-ref="Weather_Config"/>
      </flow>
</mule>