[camel] branch master updated: "CAMEL-14948:Slack consumer uses deprecated channels.list API"

[ramu12]

This is an automated email from the ASF dual-hosted git repository.

ramu12 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/master by this push:
     new f4d19e2  "CAMEL-14948:Slack consumer uses deprecated channels.list API"
f4d19e2 is described below

commit f4d19e21f0fb818f075213f351cdbf163ea9a985
Author: Kodanda Ramu Kakarla <kkaka...@kkakarla.pnq.csb>
AuthorDate: Fri May 1 10:53:50 2020 +0530

    "CAMEL-14948:Slack consumer uses deprecated channels.list API"
---
 .../camel/component/slack/SlackComponentVerifierExtension.java      | 2 +-
 .../main/java/org/apache/camel/component/slack/SlackConsumer.java   | 6 +++---
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/components/camel-slack/src/main/java/org/apache/camel/component/slack/SlackComponentVerifierExtension.java
 
b/components/camel-slack/src/main/java/org/apache/camel/component/slack/SlackComponentVerifierExtension.java
index 0e394c6..a33c4e6 100644
--- 
a/components/camel-slack/src/main/java/org/apache/camel/component/slack/SlackComponentVerifierExtension.java
+++ 
b/components/camel-slack/src/main/java/org/apache/camel/component/slack/SlackComponentVerifierExtension.java
@@ -112,7 +112,7 @@ public class SlackComponentVerifierExtension extends 
DefaultComponentVerifierExt
 
             try {
                 HttpClient client = 
HttpClientBuilder.create().useSystemProperties().build();
-                HttpPost httpPost = new HttpPost(parameters.get("serverUrl") + 
"/api/channels.list");
+                HttpPost httpPost = new HttpPost(parameters.get("serverUrl") + 
"/api/conversations.list");
 
                 List<BasicNameValuePair> params = new ArrayList<>();
                 params.add(new BasicNameValuePair("token", token));
diff --git 
a/components/camel-slack/src/main/java/org/apache/camel/component/slack/SlackConsumer.java
 
b/components/camel-slack/src/main/java/org/apache/camel/component/slack/SlackConsumer.java
index 4d52d05..18dfbaf 100644
--- 
a/components/camel-slack/src/main/java/org/apache/camel/component/slack/SlackConsumer.java
+++ 
b/components/camel-slack/src/main/java/org/apache/camel/component/slack/SlackConsumer.java
@@ -59,7 +59,7 @@ public class SlackConsumer extends 
ScheduledBatchPollingConsumer {
         Queue<Exchange> exchanges;
 
         HttpClient client = 
HttpClientBuilder.create().useSystemProperties().build();
-        HttpPost httpPost = new HttpPost(slackEndpoint.getServerUrl() + 
"/api/channels.history");
+        HttpPost httpPost = new HttpPost(slackEndpoint.getServerUrl() + 
"/api/conversations.history");
         List<BasicNameValuePair> params = new ArrayList<>();
         params.add(new BasicNameValuePair(SlackConstants.SLACK_CHANNEL_FIELD, 
channelId));
         if (ObjectHelper.isNotEmpty(timestamp)) {
@@ -123,8 +123,8 @@ public class SlackConsumer extends 
ScheduledBatchPollingConsumer {
 
     private String getChannelId(String channel) throws IOException, 
DeserializationException {
         HttpClient client = 
HttpClientBuilder.create().useSystemProperties().build();
-        HttpPost httpPost = new HttpPost(slackEndpoint.getServerUrl() + 
"/api/channels.list");
-
+        HttpPost httpPost = new HttpPost(slackEndpoint.getServerUrl() + 
"/api/conversations.list");
+        
         List<BasicNameValuePair> params = new ArrayList<>();
         params.add(new BasicNameValuePair("token", slackEndpoint.getToken()));
         httpPost.setEntity(new UrlEncodedFormEntity(params));