You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2020/10/14 08:33:48 UTC
[camel] 01/08: CAMEL-15684 - Remove Camel-Hipchat
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 570d86140bbb3d0c35b7521841064ac28710f921
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Oct 14 09:32:55 2020 +0200
CAMEL-15684 - Remove Camel-Hipchat
---
components/camel-hipchat/pom.xml | 99 ---------
.../hipchat/HipchatComponentConfigurer.java | 60 -----
.../hipchat/HipchatEndpointConfigurer.java | 165 --------------
.../hipchat/HipchatEndpointUriFactory.java | 90 --------
.../services/org/apache/camel/component.properties | 7 -
.../services/org/apache/camel/component/hipchat | 2 -
.../org/apache/camel/configurer/hipchat-component | 2 -
.../org/apache/camel/configurer/hipchat-endpoint | 2 -
.../org/apache/camel/urifactory/hipchat-endpoint | 2 -
.../apache/camel/component/hipchat/hipchat.json | 59 -----
.../src/main/docs/hipchat-component.adoc | 246 ---------------------
.../component/hipchat/HipchatApiConstants.java | 34 ---
.../camel/component/hipchat/HipchatComponent.java | 79 -------
.../component/hipchat/HipchatConfiguration.java | 120 ----------
.../camel/component/hipchat/HipchatConstants.java | 34 ---
.../camel/component/hipchat/HipchatConsumer.java | 128 -----------
.../camel/component/hipchat/HipchatEndpoint.java | 75 -------
.../camel/component/hipchat/HipchatException.java | 28 ---
.../camel/component/hipchat/HipchatProducer.java | 137 ------------
.../hipchat/HipchatComponentConsumerTest.java | 212 ------------------
.../HipchatComponentCustomHttpClientTest.java | 97 --------
.../hipchat/HipchatComponentMultipleUsersTest.java | 134 -----------
.../hipchat/HipchatComponentProducerTest.java | 218 ------------------
.../hipchat/HipchatEPSuccessTestSupport.java | 65 ------
.../component/hipchat/HipchatEndpointTest.java | 41 ----
.../component/hipchat/HipchatTestComponent.java | 48 ----
.../HipchatXmlDefinedComponentProducerTest.java | 67 ------
.../HipchatConsumerIntegrationTest.java | 68 ------
.../HipchatProducerIntegrationTest.java | 113 ----------
.../src/test/resources/log4j2.properties | 28 ---
...ipchatXmlDefinedComponentProducerTest-route.xml | 30 ---
components/pom.xml | 1 -
32 files changed, 2491 deletions(-)
diff --git a/components/camel-hipchat/pom.xml b/components/camel-hipchat/pom.xml
deleted file mode 100644
index de77b7d..0000000
--- a/components/camel-hipchat/pom.xml
+++ /dev/null
@@ -1,99 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!--
-
- Licensed to the Apache Software Foundation (ASF) under one or more
- contributor license agreements. See the NOTICE file distributed with
- this work for additional information regarding copyright ownership.
- The ASF 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
-
- http://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.
-
--->
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
-
- <modelVersion>4.0.0</modelVersion>
-
- <parent>
- <groupId>org.apache.camel</groupId>
- <artifactId>components</artifactId>
- <version>3.6.0-SNAPSHOT</version>
- </parent>
-
- <artifactId>camel-hipchat</artifactId>
- <packaging>jar</packaging>
-
- <name>Camel :: Hipchat</name>
- <description>Camel Hipchat Component</description>
-
- <properties>
- </properties>
-
- <dependencies>
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-support</artifactId>
- </dependency>
- <dependency>
- <groupId>org.apache.httpcomponents</groupId>
- <artifactId>httpclient</artifactId>
- </dependency>
- <dependency>
- <groupId>com.fasterxml.jackson.core</groupId>
- <artifactId>jackson-core</artifactId>
- </dependency>
- <dependency>
- <groupId>com.fasterxml.jackson.core</groupId>
- <artifactId>jackson-databind</artifactId>
- </dependency>
-
- <!-- logging -->
- <dependency>
- <groupId>org.apache.logging.log4j</groupId>
- <artifactId>log4j-slf4j-impl</artifactId>
- <scope>test</scope>
- </dependency>
-
- <!-- testing -->
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-test-junit5</artifactId>
- <scope>test</scope>
- <exclusions>
- <exclusion>
- <artifactId>hamcrest-core</artifactId>
- <groupId>org.hamcrest</groupId>
- </exclusion>
- </exclusions>
- </dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-test-spring-junit5</artifactId>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-xml-jaxb</artifactId>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.mockito</groupId>
- <artifactId>mockito-junit-jupiter</artifactId>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.hamcrest</groupId>
- <artifactId>hamcrest</artifactId>
- <scope>test</scope>
- </dependency>
-
- </dependencies>
-
-</project>
diff --git a/components/camel-hipchat/src/generated/java/org/apache/camel/component/hipchat/HipchatComponentConfigurer.java b/components/camel-hipchat/src/generated/java/org/apache/camel/component/hipchat/HipchatComponentConfigurer.java
deleted file mode 100644
index fee421a..0000000
--- a/components/camel-hipchat/src/generated/java/org/apache/camel/component/hipchat/HipchatComponentConfigurer.java
+++ /dev/null
@@ -1,60 +0,0 @@
-/* Generated by camel build tools - do NOT edit this file! */
-package org.apache.camel.component.hipchat;
-
-import java.util.Map;
-
-import org.apache.camel.CamelContext;
-import org.apache.camel.spi.GeneratedPropertyConfigurer;
-import org.apache.camel.spi.PropertyConfigurerGetter;
-import org.apache.camel.util.CaseInsensitiveMap;
-import org.apache.camel.support.component.PropertyConfigurerSupport;
-
-/**
- * Generated by camel build tools - do NOT edit this file!
- */
-@SuppressWarnings("unchecked")
-public class HipchatComponentConfigurer extends PropertyConfigurerSupport implements GeneratedPropertyConfigurer, PropertyConfigurerGetter {
-
- private static final Map<String, Object> ALL_OPTIONS;
- static {
- Map<String, Object> map = new CaseInsensitiveMap();
- map.put("bridgeErrorHandler", boolean.class);
- map.put("lazyStartProducer", boolean.class);
- map.put("basicPropertyBinding", boolean.class);
- ALL_OPTIONS = map;
- }
-
- @Override
- public boolean configure(CamelContext camelContext, Object obj, String name, Object value, boolean ignoreCase) {
- HipchatComponent target = (HipchatComponent) obj;
- switch (ignoreCase ? name.toLowerCase() : name) {
- case "basicpropertybinding":
- case "basicPropertyBinding": target.setBasicPropertyBinding(property(camelContext, boolean.class, value)); return true;
- case "bridgeerrorhandler":
- case "bridgeErrorHandler": target.setBridgeErrorHandler(property(camelContext, boolean.class, value)); return true;
- case "lazystartproducer":
- case "lazyStartProducer": target.setLazyStartProducer(property(camelContext, boolean.class, value)); return true;
- default: return false;
- }
- }
-
- @Override
- public Map<String, Object> getAllOptions(Object target) {
- return ALL_OPTIONS;
- }
-
- @Override
- public Object getOptionValue(Object obj, String name, boolean ignoreCase) {
- HipchatComponent target = (HipchatComponent) obj;
- switch (ignoreCase ? name.toLowerCase() : name) {
- case "basicpropertybinding":
- case "basicPropertyBinding": return target.isBasicPropertyBinding();
- case "bridgeerrorhandler":
- case "bridgeErrorHandler": return target.isBridgeErrorHandler();
- case "lazystartproducer":
- case "lazyStartProducer": return target.isLazyStartProducer();
- default: return null;
- }
- }
-}
-
diff --git a/components/camel-hipchat/src/generated/java/org/apache/camel/component/hipchat/HipchatEndpointConfigurer.java b/components/camel-hipchat/src/generated/java/org/apache/camel/component/hipchat/HipchatEndpointConfigurer.java
deleted file mode 100644
index b3e156c..0000000
--- a/components/camel-hipchat/src/generated/java/org/apache/camel/component/hipchat/HipchatEndpointConfigurer.java
+++ /dev/null
@@ -1,165 +0,0 @@
-/* Generated by camel build tools - do NOT edit this file! */
-package org.apache.camel.component.hipchat;
-
-import java.util.Map;
-
-import org.apache.camel.CamelContext;
-import org.apache.camel.spi.GeneratedPropertyConfigurer;
-import org.apache.camel.spi.PropertyConfigurerGetter;
-import org.apache.camel.util.CaseInsensitiveMap;
-import org.apache.camel.support.component.PropertyConfigurerSupport;
-
-/**
- * Generated by camel build tools - do NOT edit this file!
- */
-@SuppressWarnings("unchecked")
-public class HipchatEndpointConfigurer extends PropertyConfigurerSupport implements GeneratedPropertyConfigurer, PropertyConfigurerGetter {
-
- private static final Map<String, Object> ALL_OPTIONS;
- static {
- Map<String, Object> map = new CaseInsensitiveMap();
- map.put("protocol", java.lang.String.class);
- map.put("host", java.lang.String.class);
- map.put("port", java.lang.Integer.class);
- map.put("authToken", java.lang.String.class);
- map.put("consumeUsers", java.lang.String.class);
- map.put("httpClient", org.apache.http.impl.client.CloseableHttpClient.class);
- map.put("bridgeErrorHandler", boolean.class);
- map.put("sendEmptyMessageWhenIdle", boolean.class);
- map.put("exceptionHandler", org.apache.camel.spi.ExceptionHandler.class);
- map.put("exchangePattern", org.apache.camel.ExchangePattern.class);
- map.put("pollStrategy", org.apache.camel.spi.PollingConsumerPollStrategy.class);
- map.put("lazyStartProducer", boolean.class);
- map.put("basicPropertyBinding", boolean.class);
- map.put("synchronous", boolean.class);
- map.put("backoffErrorThreshold", int.class);
- map.put("backoffIdleThreshold", int.class);
- map.put("backoffMultiplier", int.class);
- map.put("delay", long.class);
- map.put("greedy", boolean.class);
- map.put("initialDelay", long.class);
- map.put("repeatCount", long.class);
- map.put("runLoggingLevel", org.apache.camel.LoggingLevel.class);
- map.put("scheduledExecutorService", java.util.concurrent.ScheduledExecutorService.class);
- map.put("scheduler", java.lang.Object.class);
- map.put("schedulerProperties", java.util.Map.class);
- map.put("startScheduler", boolean.class);
- map.put("timeUnit", java.util.concurrent.TimeUnit.class);
- map.put("useFixedDelay", boolean.class);
- ALL_OPTIONS = map;
- }
-
- @Override
- public boolean configure(CamelContext camelContext, Object obj, String name, Object value, boolean ignoreCase) {
- HipchatEndpoint target = (HipchatEndpoint) obj;
- switch (ignoreCase ? name.toLowerCase() : name) {
- case "authtoken":
- case "authToken": target.getConfiguration().setAuthToken(property(camelContext, java.lang.String.class, value)); return true;
- case "backofferrorthreshold":
- case "backoffErrorThreshold": target.setBackoffErrorThreshold(property(camelContext, int.class, value)); return true;
- case "backoffidlethreshold":
- case "backoffIdleThreshold": target.setBackoffIdleThreshold(property(camelContext, int.class, value)); return true;
- case "backoffmultiplier":
- case "backoffMultiplier": target.setBackoffMultiplier(property(camelContext, int.class, value)); return true;
- case "basicpropertybinding":
- case "basicPropertyBinding": target.setBasicPropertyBinding(property(camelContext, boolean.class, value)); return true;
- case "bridgeerrorhandler":
- case "bridgeErrorHandler": target.setBridgeErrorHandler(property(camelContext, boolean.class, value)); return true;
- case "consumeusers":
- case "consumeUsers": target.getConfiguration().setConsumeUsers(property(camelContext, java.lang.String.class, value)); return true;
- case "delay": target.setDelay(property(camelContext, long.class, value)); return true;
- case "exceptionhandler":
- case "exceptionHandler": target.setExceptionHandler(property(camelContext, org.apache.camel.spi.ExceptionHandler.class, value)); return true;
- case "exchangepattern":
- case "exchangePattern": target.setExchangePattern(property(camelContext, org.apache.camel.ExchangePattern.class, value)); return true;
- case "greedy": target.setGreedy(property(camelContext, boolean.class, value)); return true;
- case "httpclient":
- case "httpClient": target.getConfiguration().setHttpClient(property(camelContext, org.apache.http.impl.client.CloseableHttpClient.class, value)); return true;
- case "initialdelay":
- case "initialDelay": target.setInitialDelay(property(camelContext, long.class, value)); return true;
- case "lazystartproducer":
- case "lazyStartProducer": target.setLazyStartProducer(property(camelContext, boolean.class, value)); return true;
- case "pollstrategy":
- case "pollStrategy": target.setPollStrategy(property(camelContext, org.apache.camel.spi.PollingConsumerPollStrategy.class, value)); return true;
- case "repeatcount":
- case "repeatCount": target.setRepeatCount(property(camelContext, long.class, value)); return true;
- case "runlogginglevel":
- case "runLoggingLevel": target.setRunLoggingLevel(property(camelContext, org.apache.camel.LoggingLevel.class, value)); return true;
- case "scheduledexecutorservice":
- case "scheduledExecutorService": target.setScheduledExecutorService(property(camelContext, java.util.concurrent.ScheduledExecutorService.class, value)); return true;
- case "scheduler": target.setScheduler(property(camelContext, java.lang.Object.class, value)); return true;
- case "schedulerproperties":
- case "schedulerProperties": target.setSchedulerProperties(property(camelContext, java.util.Map.class, value)); return true;
- case "sendemptymessagewhenidle":
- case "sendEmptyMessageWhenIdle": target.setSendEmptyMessageWhenIdle(property(camelContext, boolean.class, value)); return true;
- case "startscheduler":
- case "startScheduler": target.setStartScheduler(property(camelContext, boolean.class, value)); return true;
- case "synchronous": target.setSynchronous(property(camelContext, boolean.class, value)); return true;
- case "timeunit":
- case "timeUnit": target.setTimeUnit(property(camelContext, java.util.concurrent.TimeUnit.class, value)); return true;
- case "usefixeddelay":
- case "useFixedDelay": target.setUseFixedDelay(property(camelContext, boolean.class, value)); return true;
- default: return false;
- }
- }
-
- @Override
- public Map<String, Object> getAllOptions(Object target) {
- return ALL_OPTIONS;
- }
-
- @Override
- public Object getOptionValue(Object obj, String name, boolean ignoreCase) {
- HipchatEndpoint target = (HipchatEndpoint) obj;
- switch (ignoreCase ? name.toLowerCase() : name) {
- case "authtoken":
- case "authToken": return target.getConfiguration().getAuthToken();
- case "backofferrorthreshold":
- case "backoffErrorThreshold": return target.getBackoffErrorThreshold();
- case "backoffidlethreshold":
- case "backoffIdleThreshold": return target.getBackoffIdleThreshold();
- case "backoffmultiplier":
- case "backoffMultiplier": return target.getBackoffMultiplier();
- case "basicpropertybinding":
- case "basicPropertyBinding": return target.isBasicPropertyBinding();
- case "bridgeerrorhandler":
- case "bridgeErrorHandler": return target.isBridgeErrorHandler();
- case "consumeusers":
- case "consumeUsers": return target.getConfiguration().getConsumeUsers();
- case "delay": return target.getDelay();
- case "exceptionhandler":
- case "exceptionHandler": return target.getExceptionHandler();
- case "exchangepattern":
- case "exchangePattern": return target.getExchangePattern();
- case "greedy": return target.isGreedy();
- case "httpclient":
- case "httpClient": return target.getConfiguration().getHttpClient();
- case "initialdelay":
- case "initialDelay": return target.getInitialDelay();
- case "lazystartproducer":
- case "lazyStartProducer": return target.isLazyStartProducer();
- case "pollstrategy":
- case "pollStrategy": return target.getPollStrategy();
- case "repeatcount":
- case "repeatCount": return target.getRepeatCount();
- case "runlogginglevel":
- case "runLoggingLevel": return target.getRunLoggingLevel();
- case "scheduledexecutorservice":
- case "scheduledExecutorService": return target.getScheduledExecutorService();
- case "scheduler": return target.getScheduler();
- case "schedulerproperties":
- case "schedulerProperties": return target.getSchedulerProperties();
- case "sendemptymessagewhenidle":
- case "sendEmptyMessageWhenIdle": return target.isSendEmptyMessageWhenIdle();
- case "startscheduler":
- case "startScheduler": return target.isStartScheduler();
- case "synchronous": return target.isSynchronous();
- case "timeunit":
- case "timeUnit": return target.getTimeUnit();
- case "usefixeddelay":
- case "useFixedDelay": return target.isUseFixedDelay();
- default: return null;
- }
- }
-}
-
diff --git a/components/camel-hipchat/src/generated/java/org/apache/camel/component/hipchat/HipchatEndpointUriFactory.java b/components/camel-hipchat/src/generated/java/org/apache/camel/component/hipchat/HipchatEndpointUriFactory.java
deleted file mode 100644
index 18f0440..0000000
--- a/components/camel-hipchat/src/generated/java/org/apache/camel/component/hipchat/HipchatEndpointUriFactory.java
+++ /dev/null
@@ -1,90 +0,0 @@
-/* Generated by camel build tools - do NOT edit this file! */
-package org.apache.camel.component.hipchat;
-
-import java.net.URISyntaxException;
-import java.util.Collections;
-import java.util.HashMap;
-import java.util.HashSet;
-import java.util.Map;
-import java.util.Set;
-
-import org.apache.camel.spi.EndpointUriFactory;
-
-/**
- * Generated by camel build tools - do NOT edit this file!
- */
-public class HipchatEndpointUriFactory extends org.apache.camel.support.component.EndpointUriFactorySupport implements EndpointUriFactory {
-
- private static final String BASE = ":protocol:host:port";
-
- private static final Set<String> PROPERTY_NAMES;
- private static final Set<String> SECRET_PROPERTY_NAMES;
- static {
- Set<String> props = new HashSet<>(28);
- props.add("basicPropertyBinding");
- props.add("backoffMultiplier");
- props.add("synchronous");
- props.add("authToken");
- props.add("initialDelay");
- props.add("scheduler");
- props.add("protocol");
- props.add("bridgeErrorHandler");
- props.add("useFixedDelay");
- props.add("runLoggingLevel");
- props.add("backoffErrorThreshold");
- props.add("host");
- props.add("greedy");
- props.add("scheduledExecutorService");
- props.add("repeatCount");
- props.add("timeUnit");
- props.add("httpClient");
- props.add("sendEmptyMessageWhenIdle");
- props.add("schedulerProperties");
- props.add("exchangePattern");
- props.add("backoffIdleThreshold");
- props.add("lazyStartProducer");
- props.add("delay");
- props.add("pollStrategy");
- props.add("port");
- props.add("startScheduler");
- props.add("consumeUsers");
- props.add("exceptionHandler");
- PROPERTY_NAMES = Collections.unmodifiableSet(props);
- SECRET_PROPERTY_NAMES = Collections.emptySet();
- }
-
- @Override
- public boolean isEnabled(String scheme) {
- return "hipchat".equals(scheme);
- }
-
- @Override
- public String buildUri(String scheme, Map<String, Object> properties) throws URISyntaxException {
- String syntax = scheme + BASE;
- String uri = syntax;
-
- Map<String, Object> copy = new HashMap<>(properties);
-
- uri = buildPathParameter(syntax, uri, "protocol", null, true, copy);
- uri = buildPathParameter(syntax, uri, "host", null, true, copy);
- uri = buildPathParameter(syntax, uri, "port", "80", false, copy);
- uri = buildQueryParameters(uri, copy);
- return uri;
- }
-
- @Override
- public Set<String> propertyNames() {
- return PROPERTY_NAMES;
- }
-
- @Override
- public Set<String> secretPropertyNames() {
- return SECRET_PROPERTY_NAMES;
- }
-
- @Override
- public boolean isLenientProperties() {
- return false;
- }
-}
-
diff --git a/components/camel-hipchat/src/generated/resources/META-INF/services/org/apache/camel/component.properties b/components/camel-hipchat/src/generated/resources/META-INF/services/org/apache/camel/component.properties
deleted file mode 100644
index acdcf97..0000000
--- a/components/camel-hipchat/src/generated/resources/META-INF/services/org/apache/camel/component.properties
+++ /dev/null
@@ -1,7 +0,0 @@
-# Generated by camel build tools - do NOT edit this file!
-components=hipchat
-groupId=org.apache.camel
-artifactId=camel-hipchat
-version=3.6.0-SNAPSHOT
-projectName=Camel :: Hipchat
-projectDescription=Camel Hipchat Component
diff --git a/components/camel-hipchat/src/generated/resources/META-INF/services/org/apache/camel/component/hipchat b/components/camel-hipchat/src/generated/resources/META-INF/services/org/apache/camel/component/hipchat
deleted file mode 100644
index 00c3723..0000000
--- a/components/camel-hipchat/src/generated/resources/META-INF/services/org/apache/camel/component/hipchat
+++ /dev/null
@@ -1,2 +0,0 @@
-# Generated by camel build tools - do NOT edit this file!
-class=org.apache.camel.component.hipchat.HipchatComponent
diff --git a/components/camel-hipchat/src/generated/resources/META-INF/services/org/apache/camel/configurer/hipchat-component b/components/camel-hipchat/src/generated/resources/META-INF/services/org/apache/camel/configurer/hipchat-component
deleted file mode 100644
index 3774e5b..0000000
--- a/components/camel-hipchat/src/generated/resources/META-INF/services/org/apache/camel/configurer/hipchat-component
+++ /dev/null
@@ -1,2 +0,0 @@
-# Generated by camel build tools - do NOT edit this file!
-class=org.apache.camel.component.hipchat.HipchatComponentConfigurer
diff --git a/components/camel-hipchat/src/generated/resources/META-INF/services/org/apache/camel/configurer/hipchat-endpoint b/components/camel-hipchat/src/generated/resources/META-INF/services/org/apache/camel/configurer/hipchat-endpoint
deleted file mode 100644
index 71295e6..0000000
--- a/components/camel-hipchat/src/generated/resources/META-INF/services/org/apache/camel/configurer/hipchat-endpoint
+++ /dev/null
@@ -1,2 +0,0 @@
-# Generated by camel build tools - do NOT edit this file!
-class=org.apache.camel.component.hipchat.HipchatEndpointConfigurer
diff --git a/components/camel-hipchat/src/generated/resources/META-INF/services/org/apache/camel/urifactory/hipchat-endpoint b/components/camel-hipchat/src/generated/resources/META-INF/services/org/apache/camel/urifactory/hipchat-endpoint
deleted file mode 100644
index 74ee9ba..0000000
--- a/components/camel-hipchat/src/generated/resources/META-INF/services/org/apache/camel/urifactory/hipchat-endpoint
+++ /dev/null
@@ -1,2 +0,0 @@
-# Generated by camel build tools - do NOT edit this file!
-class=org.apache.camel.component.hipchat.HipchatEndpointUriFactory
diff --git a/components/camel-hipchat/src/generated/resources/org/apache/camel/component/hipchat/hipchat.json b/components/camel-hipchat/src/generated/resources/org/apache/camel/component/hipchat/hipchat.json
deleted file mode 100644
index 872542f..0000000
--- a/components/camel-hipchat/src/generated/resources/org/apache/camel/component/hipchat/hipchat.json
+++ /dev/null
@@ -1,59 +0,0 @@
-{
- "component": {
- "kind": "component",
- "name": "hipchat",
- "title": "Hipchat",
- "description": "Send and receive messages to\/from Hipchat service.",
- "deprecated": false,
- "firstVersion": "2.15.0",
- "label": "api,chat,cloud",
- "javaType": "org.apache.camel.component.hipchat.HipchatComponent",
- "supportLevel": "Stable",
- "groupId": "org.apache.camel",
- "artifactId": "camel-hipchat",
- "version": "3.6.0-SNAPSHOT",
- "scheme": "hipchat",
- "extendsScheme": "",
- "syntax": "hipchat:protocol:host:port",
- "async": false,
- "api": false,
- "consumerOnly": false,
- "producerOnly": false,
- "lenientProperties": false
- },
- "componentProperties": {
- "bridgeErrorHandler": { "kind": "property", "displayName": "Bridge Error Handler", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": false, "description": "Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled by [...]
- "lazyStartProducer": { "kind": "property", "displayName": "Lazy Start Producer", "group": "producer", "label": "producer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": false, "description": "Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the r [...]
- "basicPropertyBinding": { "kind": "property", "displayName": "Basic Property Binding", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": true, "secret": false, "defaultValue": false, "description": "Whether the component should use basic property binding (Camel 2.x) or the newer property binding with additional capabilities" }
- },
- "properties": {
- "protocol": { "kind": "path", "displayName": "Protocol", "group": "common", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "secret": false, "configurationClass": "org.apache.camel.component.hipchat.HipchatConfiguration", "configurationField": "configuration", "description": "The protocol for the hipchat server, such as http." },
- "host": { "kind": "path", "displayName": "Host", "group": "common", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "secret": false, "configurationClass": "org.apache.camel.component.hipchat.HipchatConfiguration", "configurationField": "configuration", "description": "The host for the hipchat server, such as api.hipchat.com" },
- "port": { "kind": "path", "displayName": "Port", "group": "common", "label": "", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "secret": false, "defaultValue": "80", "configurationClass": "org.apache.camel.component.hipchat.HipchatConfiguration", "configurationField": "configuration", "description": "The port for the hipchat server. Is by default 80." },
- "authToken": { "kind": "parameter", "displayName": "Auth Token", "group": "common", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.hipchat.HipchatConfiguration", "configurationField": "configuration", "description": "OAuth 2 auth token" },
- "consumeUsers": { "kind": "parameter", "displayName": "Consume Users", "group": "common", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.hipchat.HipchatConfiguration", "configurationField": "configuration", "description": "Username(s) when consuming messages from the hiptchat server. Multiple user names can be separated by comma." },
- "httpClient": { "kind": "parameter", "displayName": "Http Client", "group": "common", "label": "", "required": false, "type": "object", "javaType": "org.apache.http.impl.client.CloseableHttpClient", "deprecated": false, "secret": false, "defaultValue": "CloseableHttpClient default from HttpClient library", "configurationClass": "org.apache.camel.component.hipchat.HipchatConfiguration", "configurationField": "configuration", "description": "The CloseableHttpClient reference from regis [...]
- "bridgeErrorHandler": { "kind": "parameter", "displayName": "Bridge Error Handler", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": false, "description": "Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled b [...]
- "sendEmptyMessageWhenIdle": { "kind": "parameter", "displayName": "Send Empty Message When Idle", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": false, "description": "If the polling consumer did not poll any files, you can enable this option to send an empty message (no body) instead." },
- "exceptionHandler": { "kind": "parameter", "displayName": "Exception Handler", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "object", "javaType": "org.apache.camel.spi.ExceptionHandler", "optionalPrefix": "consumer.", "deprecated": false, "secret": false, "description": "To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this option is not in use. By default the consumer will deal with [...]
- "exchangePattern": { "kind": "parameter", "displayName": "Exchange Pattern", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "object", "javaType": "org.apache.camel.ExchangePattern", "enum": [ "InOnly", "InOut", "InOptionalOut" ], "deprecated": false, "secret": false, "description": "Sets the exchange pattern when the consumer creates an exchange." },
- "pollStrategy": { "kind": "parameter", "displayName": "Poll Strategy", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "object", "javaType": "org.apache.camel.spi.PollingConsumerPollStrategy", "deprecated": false, "secret": false, "description": "A pluggable org.apache.camel.PollingConsumerPollingStrategy allowing you to provide your custom implementation to control error handling usually occurred during the poll operation before an Exchange h [...]
- "lazyStartProducer": { "kind": "parameter", "displayName": "Lazy Start Producer", "group": "producer", "label": "producer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": false, "description": "Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the [...]
- "basicPropertyBinding": { "kind": "parameter", "displayName": "Basic Property Binding", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": false, "description": "Whether the endpoint should use basic property binding (Camel 2.x) or the newer property binding with additional capabilities" },
- "synchronous": { "kind": "parameter", "displayName": "Synchronous", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": false, "description": "Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported)." },
- "backoffErrorThreshold": { "kind": "parameter", "displayName": "Backoff Error Threshold", "group": "scheduler", "label": "consumer,scheduler", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "secret": false, "description": "The number of subsequent error polls (failed due some error) that should happen before the backoffMultipler should kick-in." },
- "backoffIdleThreshold": { "kind": "parameter", "displayName": "Backoff Idle Threshold", "group": "scheduler", "label": "consumer,scheduler", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "secret": false, "description": "The number of subsequent idle polls that should happen before the backoffMultipler should kick-in." },
- "backoffMultiplier": { "kind": "parameter", "displayName": "Backoff Multiplier", "group": "scheduler", "label": "consumer,scheduler", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "secret": false, "description": "To let the scheduled polling consumer backoff if there has been a number of subsequent idles\/errors in a row. The multiplier is then the number of polls that will be skipped before the next actual attempt is happening again. When this option [...]
- "delay": { "kind": "parameter", "displayName": "Delay", "group": "scheduler", "label": "consumer,scheduler", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "secret": false, "defaultValue": 5000, "description": "Milliseconds before the next poll." },
- "greedy": { "kind": "parameter", "displayName": "Greedy", "group": "scheduler", "label": "consumer,scheduler", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": false, "description": "If greedy is enabled, then the ScheduledPollConsumer will run immediately again, if the previous run polled 1 or more messages." },
- "initialDelay": { "kind": "parameter", "displayName": "Initial Delay", "group": "scheduler", "label": "consumer,scheduler", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "secret": false, "defaultValue": 1000, "description": "Milliseconds before the first poll starts." },
- "repeatCount": { "kind": "parameter", "displayName": "Repeat Count", "group": "scheduler", "label": "consumer,scheduler", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "secret": false, "defaultValue": 0, "description": "Specifies a maximum limit of number of fires. So if you set it to 1, the scheduler will only fire once. If you set it to 5, it will only fire five times. A value of zero or negative means fire forever." },
- "runLoggingLevel": { "kind": "parameter", "displayName": "Run Logging Level", "group": "scheduler", "label": "consumer,scheduler", "required": false, "type": "object", "javaType": "org.apache.camel.LoggingLevel", "enum": [ "TRACE", "DEBUG", "INFO", "WARN", "ERROR", "OFF" ], "deprecated": false, "secret": false, "defaultValue": "TRACE", "description": "The consumer logs a start\/complete log line when it polls. This option allows you to configure the logging level for that." },
- "scheduledExecutorService": { "kind": "parameter", "displayName": "Scheduled Executor Service", "group": "scheduler", "label": "consumer,scheduler", "required": false, "type": "object", "javaType": "java.util.concurrent.ScheduledExecutorService", "deprecated": false, "secret": false, "description": "Allows for configuring a custom\/shared thread pool to use for the consumer. By default each consumer has its own single threaded thread pool." },
- "scheduler": { "kind": "parameter", "displayName": "Scheduler", "group": "scheduler", "label": "consumer,scheduler", "required": false, "type": "object", "javaType": "java.lang.Object", "deprecated": false, "secret": false, "defaultValue": "none", "description": "To use a cron scheduler from either camel-spring or camel-quartz component. Use value spring or quartz for built in scheduler" },
- "schedulerProperties": { "kind": "parameter", "displayName": "Scheduler Properties", "group": "scheduler", "label": "consumer,scheduler", "required": false, "type": "object", "javaType": "java.util.Map<java.lang.String, java.lang.Object>", "prefix": "scheduler.", "multiValue": true, "deprecated": false, "secret": false, "description": "To configure additional properties when using a custom scheduler or any of the Quartz, Spring based scheduler." },
- "startScheduler": { "kind": "parameter", "displayName": "Start Scheduler", "group": "scheduler", "label": "consumer,scheduler", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": true, "description": "Whether the scheduler should be auto started." },
- "timeUnit": { "kind": "parameter", "displayName": "Time Unit", "group": "scheduler", "label": "consumer,scheduler", "required": false, "type": "object", "javaType": "java.util.concurrent.TimeUnit", "enum": [ "NANOSECONDS", "MICROSECONDS", "MILLISECONDS", "SECONDS", "MINUTES", "HOURS", "DAYS" ], "deprecated": false, "secret": false, "defaultValue": "MILLISECONDS", "description": "Time unit for initialDelay and delay options." },
- "useFixedDelay": { "kind": "parameter", "displayName": "Use Fixed Delay", "group": "scheduler", "label": "consumer,scheduler", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": true, "description": "Controls if fixed delay or fixed rate is used. See ScheduledExecutorService in JDK for details." }
- }
-}
diff --git a/components/camel-hipchat/src/main/docs/hipchat-component.adoc b/components/camel-hipchat/src/main/docs/hipchat-component.adoc
deleted file mode 100644
index 7b53762..0000000
--- a/components/camel-hipchat/src/main/docs/hipchat-component.adoc
+++ /dev/null
@@ -1,246 +0,0 @@
-[[hipchat-component]]
-= Hipchat Component
-:docTitle: Hipchat
-:artifactId: camel-hipchat
-:description: Send and receive messages to/from Hipchat service.
-:since: 2.15
-:supportLevel: Stable
-:component-header: Both producer and consumer are supported
-include::{cq-version}@camel-quarkus:ROOT:partial$reference/components/hipchat.adoc[]
-
-*Since Camel {since}*
-
-*{component-header}*
-
-The Hipchat component supports producing and consuming messages from/to
-https://www.hipchat.com[Hipchat] service.
-
-*Prerequisites*
-
-You must have a valid Hipchat user account and get a
-https://www.hipchat.com/account/api[personal access token] that you can
-use to produce/consume messages.
-
-
-== URI Format
-
-[source,java]
--------------------------------
-hipchat://[host][:port]?options
--------------------------------
-
-You can append query options to the URI in the following format,
-?options=value&option2=value&...
-
-== URI Options
-
-
-// component options: START
-The Hipchat component supports 3 options, which are listed below.
-
-
-
-[width="100%",cols="2,5,^1,2",options="header"]
-|===
-| Name | Description | Default | Type
-| *bridgeErrorHandler* (consumer) | Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled by the routing Error Handler. By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be logged at WARN or ERROR level and ignored. | false | boolean
-| *lazyStartProducer* (producer) | Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and [...]
-| *basicPropertyBinding* (advanced) | *Deprecated* Whether the component should use basic property binding (Camel 2.x) or the newer property binding with additional capabilities | false | boolean
-|===
-// component options: END
-
-
-
-
-
-
-// endpoint options: START
-The Hipchat endpoint is configured using URI syntax:
-
-----
-hipchat:protocol:host:port
-----
-
-with the following path and query parameters:
-
-=== Path Parameters (3 parameters):
-
-
-[width="100%",cols="2,5,^1,2",options="header"]
-|===
-| Name | Description | Default | Type
-| *protocol* | *Required* The protocol for the hipchat server, such as http. | | String
-| *host* | *Required* The host for the hipchat server, such as api.hipchat.com | | String
-| *port* | The port for the hipchat server. Is by default 80. | 80 | Integer
-|===
-
-
-=== Query Parameters (25 parameters):
-
-
-[width="100%",cols="2,5,^1,2",options="header"]
-|===
-| Name | Description | Default | Type
-| *authToken* (common) | OAuth 2 auth token | | String
-| *consumeUsers* (common) | Username(s) when consuming messages from the hiptchat server. Multiple user names can be separated by comma. | | String
-| *httpClient* (common) | The CloseableHttpClient reference from registry to be used during API HTTP requests. | CloseableHttpClient default from HttpClient library | CloseableHttpClient
-| *bridgeErrorHandler* (consumer) | Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled by the routing Error Handler. By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be logged at WARN or ERROR level and ignored. | false | boolean
-| *sendEmptyMessageWhenIdle* (consumer) | If the polling consumer did not poll any files, you can enable this option to send an empty message (no body) instead. | false | boolean
-| *exceptionHandler* (consumer) | To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this option is not in use. By default the consumer will deal with exceptions, that will be logged at WARN or ERROR level and ignored. | | ExceptionHandler
-| *exchangePattern* (consumer) | Sets the exchange pattern when the consumer creates an exchange. There are 3 enums and the value can be one of: InOnly, InOut, InOptionalOut | | ExchangePattern
-| *pollStrategy* (consumer) | A pluggable org.apache.camel.PollingConsumerPollingStrategy allowing you to provide your custom implementation to control error handling usually occurred during the poll operation before an Exchange have been created and being routed in Camel. | | PollingConsumerPollStrategy
-| *lazyStartProducer* (producer) | Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and [...]
-| *basicPropertyBinding* (advanced) | Whether the endpoint should use basic property binding (Camel 2.x) or the newer property binding with additional capabilities | false | boolean
-| *synchronous* (advanced) | Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported). | false | boolean
-| *backoffErrorThreshold* (scheduler) | The number of subsequent error polls (failed due some error) that should happen before the backoffMultipler should kick-in. | | int
-| *backoffIdleThreshold* (scheduler) | The number of subsequent idle polls that should happen before the backoffMultipler should kick-in. | | int
-| *backoffMultiplier* (scheduler) | To let the scheduled polling consumer backoff if there has been a number of subsequent idles/errors in a row. The multiplier is then the number of polls that will be skipped before the next actual attempt is happening again. When this option is in use then backoffIdleThreshold and/or backoffErrorThreshold must also be configured. | | int
-| *delay* (scheduler) | Milliseconds before the next poll. | 5000 | long
-| *greedy* (scheduler) | If greedy is enabled, then the ScheduledPollConsumer will run immediately again, if the previous run polled 1 or more messages. | false | boolean
-| *initialDelay* (scheduler) | Milliseconds before the first poll starts. | 1000 | long
-| *repeatCount* (scheduler) | Specifies a maximum limit of number of fires. So if you set it to 1, the scheduler will only fire once. If you set it to 5, it will only fire five times. A value of zero or negative means fire forever. | 0 | long
-| *runLoggingLevel* (scheduler) | The consumer logs a start/complete log line when it polls. This option allows you to configure the logging level for that. There are 6 enums and the value can be one of: TRACE, DEBUG, INFO, WARN, ERROR, OFF | TRACE | LoggingLevel
-| *scheduledExecutorService* (scheduler) | Allows for configuring a custom/shared thread pool to use for the consumer. By default each consumer has its own single threaded thread pool. | | ScheduledExecutorService
-| *scheduler* (scheduler) | To use a cron scheduler from either camel-spring or camel-quartz component. Use value spring or quartz for built in scheduler | none | Object
-| *schedulerProperties* (scheduler) | To configure additional properties when using a custom scheduler or any of the Quartz, Spring based scheduler. | | Map
-| *startScheduler* (scheduler) | Whether the scheduler should be auto started. | true | boolean
-| *timeUnit* (scheduler) | Time unit for initialDelay and delay options. There are 7 enums and the value can be one of: NANOSECONDS, MICROSECONDS, MILLISECONDS, SECONDS, MINUTES, HOURS, DAYS | MILLISECONDS | TimeUnit
-| *useFixedDelay* (scheduler) | Controls if fixed delay or fixed rate is used. See ScheduledExecutorService in JDK for details. | true | boolean
-|===
-// endpoint options: END
-
-
-
-
-
-
-
-== Scheduled Poll Consumer
-
-This component implements the
-ScheduledPollConsumer. Only the last message
-from the provided 'consumeUsers' are retrieved and sent as Exchange
-body. If you do not want the same message to be retrieved again when
-there are no new messages on next poll then you can add the
-idempotent consumer as shown below. All
-the options on the ScheduledPollConsumer can
-also be used for more control on the consumer.
-
-[source,java]
----------------------------------------------------------------------------------
-@Override
-public void configure() throws Exception {
- String hipchatEndpointUri = "hipchat://?authToken=XXXX&consumeUsers=@Joe,@John";
- from(hipchatEndpointUri)
- .idempotentConsumer(
- simple("${in.header.HipchatMessageDate} ${in.header.HipchatFromUser}"),
- MemoryIdempotentRepository.memoryIdempotentRepository(200)
- )
- .to("mock:result");
-}
----------------------------------------------------------------------------------
-
-=== Message headers set by the Hipchat consumer
-
-[width="100%",cols="10%,10%,10%,70%",options="header",]
-|=======================================================================
-
-|*Header* |*Constant* |*Type* |*Description*
-
-|HipchatFromUser |HipchatConstants.FROM_USER |_String_ |The body has the message that was sent from this user to the owner of
-authToken
-
-|HipchatMessageDate |HipchatConstants.MESSAGE_DATE |_String_ |The date message was sent. The format is ISO-8601 as present in the
-Hipchat https://www.hipchat.com/docs/apiv2/method/view_recent_privatechat_history[response].
-
-|HipchatFromUserResponseStatus |HipchatConstants.FROM_USER_RESPONSE_STATUS |_http://hc.apache.org/httpcomponents-core-4.2.x/httpcore/apidocs/org/apache/http/StatusLine.html[StatusLine]_
-The status of the API response received.
-|=======================================================================
-
-== Hipchat Producer
-
-Producer can send messages to both Room's and User's simultaneously. The
-body of the exchange is sent as message. Sample usage is shown below.
-Appropriate headers needs to be set.
-
-[source,java]
-----------------------------------------------------------
-@Override
- public void configure() throws Exception {
- String hipchatEndpointUri = "hipchat://?authToken=XXXX";
- from("direct:start")
- .to(hipchatEndpointUri)
- .to("mock:result");
- }
-----------------------------------------------------------
-
-=== Message headers evaluated by the Hipchat producer
-
-[width="100%",cols="10%,10%,10%,70%",options="header",]
-|=======================================================================
-
-|*Header* |*Constant* |*Type* |*Description*
-
-|HipchatToUser |HipchatConstants.TO_USER |_String_ |The Hipchat user to which the message needs to be sent.
-
-|HipchatToRoom |HipchatConstants.TO_ROOM |_String_ |The Hipchat room to which the message needs to be sent.
-
-|HipchatMessageFormat |HipchatConstants.MESSAGE_FORMAT |String |Valid formats are 'text' or 'html'. *Default: 'text'*
-
-|HipchatMessageBackgroundColor |HipchatConstants.MESSAGE_BACKGROUND_COLOR |_String_ |Valid color values are 'yellow', 'green', 'red', 'purple', 'gray',
-'random'. *Default: 'yellow' (Room Only)*
-
-|HipchatTriggerNotification |HipchatConstants.TRIGGER_NOTIFY |_String_ |Valid values are 'true' or 'false'. Whether this message should trigger
-a user notification (change the tab color, play a sound, notify mobile
-phones, etc). *Default: 'false' (Room Only)*
-|=======================================================================
-
-=== Message headers set by the Hipchat producer
-
-[width="100%",cols="10%,10%,10%,70%",options="header",]
-|=======================================================================
-
-|*Header* |*Constant* |*Type* |*Description*
-
-|HipchatToUserResponseStatus |HipchatConstants.TO_USER_RESPONSE_STATUS |_http://hc.apache.org/httpcomponents-core-4.2.x/httpcore/apidocs/org/apache/http/StatusLine.html[StatusLine]_
-The status of the API response received when message sent to the user.
-
-|HipchatFromUserResponseStatus |HipchatConstants.TO_ROOM_RESPONSE_STATUS |_http://hc.apache.org/httpcomponents-core-4.2.x/httpcore/apidocs/org/apache/http/StatusLine.html[StatusLine]_ |The status of the API response received when message sent to the room.
-|=======================================================================
-
-=== Configuring Http Client
-
-The HipChat component allow your own `HttpClient` configuration. This can be done by defining a reference for `CloseableHttpClient` in the http://camel.apache.org/registry.html[registry] (e.g. Spring Context) and then, set the parameter during the Endpoint definition, for example: `hipchat:http://api.hipchat.com?httpClient=#myHttpClient`.
-
-[source,java]
-------------------------------------------
-CloseableHttpClient httpclient = HttpClients.custom()
- .setConnectionManager(connManager)
- .setDefaultCookieStore(cookieStore)
- .setDefaultCredentialsProvider(credentialsProvider)
- .setProxy(new HttpHost("myproxy", 8080))
- .setDefaultRequestConfig(defaultRequestConfig)
- .build();
-------------------------------------------
-
-To see more information about Http Client configuration, please check the https://hc.apache.org/httpcomponents-client-ga/examples.html[official documentation].
-
-
-=== Dependencies
-
-Maven users will need to add the following dependency to their pom.xml.
-
-*pom.xml*
-
-[source,xml]
-------------------------------------------
-<dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-hipchat</artifactId>
- <version>${camel-version}</version>
-</dependency>
-------------------------------------------
-
-where `$\{camel-version}` must be replaced by the actual version of Camel.
-
-include::camel-spring-boot::page$hipchat-starter.adoc[]
diff --git a/components/camel-hipchat/src/main/java/org/apache/camel/component/hipchat/HipchatApiConstants.java b/components/camel-hipchat/src/main/java/org/apache/camel/component/hipchat/HipchatApiConstants.java
deleted file mode 100644
index be6bac1..0000000
--- a/components/camel-hipchat/src/main/java/org/apache/camel/component/hipchat/HipchatApiConstants.java
+++ /dev/null
@@ -1,34 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF 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
- *
- * http://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 org.apache.camel.component.hipchat;
-
-/**
- * List of constants specifically used for invoking Hipchat API
- */
-interface HipchatApiConstants {
- String URI_PATH_ROOM_NOTIFY = "/v2/room/%s/notification";
- String URI_PATH_USER_MESSAGE = "/v2/user/%s/message";
- String URI_PATH_USER_LATEST_PRIVATE_CHAT = "/v2/user/%s/history/latest";
- String API_MESSAGE_COLOR = "color";
- String API_MESSAGE_FORMAT = "message_format";
- String API_MESSAGE = "message";
- String API_DATE = "date";
- String API_ITEMS = "items";
- String API_MESSAGE_NOTIFY = "notify";
- String AUTH_TOKEN_PREFIX = "?auth_token=";
- String DEFAULT_MAX_RESULT = "max-results=1";
-}
diff --git a/components/camel-hipchat/src/main/java/org/apache/camel/component/hipchat/HipchatComponent.java b/components/camel-hipchat/src/main/java/org/apache/camel/component/hipchat/HipchatComponent.java
deleted file mode 100644
index cd33b7a..0000000
--- a/components/camel-hipchat/src/main/java/org/apache/camel/component/hipchat/HipchatComponent.java
+++ /dev/null
@@ -1,79 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF 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
- *
- * http://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 org.apache.camel.component.hipchat;
-
-import java.net.URI;
-import java.util.Map;
-
-import org.apache.camel.CamelContext;
-import org.apache.camel.Endpoint;
-import org.apache.camel.spi.annotations.Component;
-import org.apache.camel.support.DefaultComponent;
-import org.apache.camel.util.URISupport;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-/**
- * Represents the component that manages {@link HipchatEndpoint}. Hipchat is an Atlassian software for team chat.
- *
- * The hipchat component uses the OAuth2 Hipchat API to produce/consume messages. For more details about Hipchat API
- *
- * @see <a href="https://www.hipchat.com/docs/apiv2/auth">Hipchat API</a>. You can get the Oauth2 auth token at @see
- * <a href="https://www.hipchat.com/account/api">Hipchat Auth Token</a>. The messages produced and consumed would
- * be from/to owner of the provided auth token.
- */
-@Component("hipchat")
-public class HipchatComponent extends DefaultComponent {
-
- private static final Logger LOG = LoggerFactory.getLogger(HipchatComponent.class);
-
- public HipchatComponent() {
- }
-
- public HipchatComponent(CamelContext context) {
- super(context);
- }
-
- @Override
- protected Endpoint createEndpoint(String uri, String remaining, Map<String, Object> parameters) throws Exception {
- HipchatEndpoint endpoint = getHipchatEndpoint(uri);
- setProperties(endpoint, parameters);
- if (endpoint.getConfiguration().getAuthToken() == null) {
- throw new HipchatException("OAuth 2 auth token must be specified");
- }
- parseUri(remaining, endpoint);
- LOG.debug("Using Hipchat API URL: {}", endpoint.getConfiguration().hipChatUrl());
- return endpoint;
- }
-
- private void parseUri(String remaining, HipchatEndpoint endpoint) throws Exception {
- String uri = URISupport.normalizeUri(remaining);
-
- URI hipChatUri = new URI(uri);
- if (hipChatUri.getHost() != null) {
- endpoint.getConfiguration().setHost(hipChatUri.getHost());
- if (hipChatUri.getPort() != -1) {
- endpoint.getConfiguration().setPort(hipChatUri.getPort());
- }
- endpoint.getConfiguration().setProtocol(hipChatUri.getScheme());
- }
- }
-
- protected HipchatEndpoint getHipchatEndpoint(String uri) {
- return new HipchatEndpoint(uri, this);
- }
-}
diff --git a/components/camel-hipchat/src/main/java/org/apache/camel/component/hipchat/HipchatConfiguration.java b/components/camel-hipchat/src/main/java/org/apache/camel/component/hipchat/HipchatConfiguration.java
deleted file mode 100644
index 6d6ca25..0000000
--- a/components/camel-hipchat/src/main/java/org/apache/camel/component/hipchat/HipchatConfiguration.java
+++ /dev/null
@@ -1,120 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF 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
- *
- * http://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 org.apache.camel.component.hipchat;
-
-import org.apache.camel.spi.Metadata;
-import org.apache.camel.spi.UriParam;
-import org.apache.camel.spi.UriParams;
-import org.apache.camel.spi.UriPath;
-import org.apache.http.impl.client.CloseableHttpClient;
-import org.apache.http.impl.client.HttpClients;
-
-@UriParams
-public class HipchatConfiguration {
- @UriPath
- @Metadata(required = true)
- private String protocol;
- @UriPath
- @Metadata(required = true)
- private String host = HipchatConstants.DEFAULT_HOST;
- @UriPath(defaultValue = "" + HipchatConstants.DEFAULT_PORT)
- private Integer port = HipchatConstants.DEFAULT_PORT;
- @UriParam
- private String authToken;
- @UriParam
- private String consumeUsers;
- @UriParam(description = "The CloseableHttpClient reference from registry to be used during API HTTP requests.",
- defaultValue = "CloseableHttpClient default from HttpClient library")
- private CloseableHttpClient httpClient = HttpClients.createDefault();
-
- public String getHost() {
- return host;
- }
-
- /**
- * The host for the hipchat server, such as api.hipchat.com
- */
- public void setHost(String host) {
- this.host = host;
- }
-
- public Integer getPort() {
- return port;
- }
-
- /**
- * The port for the hipchat server. Is by default 80.
- */
- public void setPort(Integer port) {
- this.port = port;
- }
-
- public String getProtocol() {
- return protocol;
- }
-
- /**
- * The protocol for the hipchat server, such as http.
- */
- public void setProtocol(String protocol) {
- this.protocol = protocol;
- }
-
- public String getAuthToken() {
- return authToken;
- }
-
- /**
- * OAuth 2 auth token
- */
- public void setAuthToken(String authToken) {
- this.authToken = authToken;
- }
-
- public String getConsumeUsers() {
- return consumeUsers;
- }
-
- /**
- * Username(s) when consuming messages from the hiptchat server.
- * <p/>
- * Multiple user names can be separated by comma.
- */
- public void setConsumeUsers(String consumeUsers) {
- this.consumeUsers = consumeUsers;
- }
-
- public String hipChatUrl() {
- return getProtocol() + "://" + getHost() + ":" + getPort();
- }
-
- public String[] consumableUsers() {
- return consumeUsers != null ? consumeUsers.split(",") : new String[0];
- }
-
- public String withAuthToken(String urlPath) {
- return urlPath + HipchatApiConstants.AUTH_TOKEN_PREFIX + getAuthToken();
- }
-
- public CloseableHttpClient getHttpClient() {
- return httpClient;
- }
-
- public void setHttpClient(CloseableHttpClient httpClient) {
- this.httpClient = httpClient;
- }
-}
diff --git a/components/camel-hipchat/src/main/java/org/apache/camel/component/hipchat/HipchatConstants.java b/components/camel-hipchat/src/main/java/org/apache/camel/component/hipchat/HipchatConstants.java
deleted file mode 100644
index 4a928a9..0000000
--- a/components/camel-hipchat/src/main/java/org/apache/camel/component/hipchat/HipchatConstants.java
+++ /dev/null
@@ -1,34 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF 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
- *
- * http://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 org.apache.camel.component.hipchat;
-
-public interface HipchatConstants {
-
- String DEFAULT_HOST = "api.hipchat.com";
- int DEFAULT_PORT = 80;
- String DEFAULT_PROTOCOL = "http";
- String TO_USER = "HipchatToUser";
- String TO_USER_RESPONSE_STATUS = "HipchatToUserResponseStatus";
- String FROM_USER = "HipchatFromUser";
- String FROM_USER_RESPONSE_STATUS = "HipchatFromUserResponseStatus";
- String MESSAGE_DATE = "HipchatMessageDate";
- String TO_ROOM = "HipchatToRoom";
- String TO_ROOM_RESPONSE_STATUS = "HipchatToRoomResponseStatus";
- String TRIGGER_NOTIFY = "HipchatTriggerNotification";
- String MESSAGE_FORMAT = "HipchatMessageFormat";
- String MESSAGE_BACKGROUND_COLOR = "HipchatMessageBackgroundColor";
-}
diff --git a/components/camel-hipchat/src/main/java/org/apache/camel/component/hipchat/HipchatConsumer.java b/components/camel-hipchat/src/main/java/org/apache/camel/component/hipchat/HipchatConsumer.java
deleted file mode 100644
index 11b2f5a..0000000
--- a/components/camel-hipchat/src/main/java/org/apache/camel/component/hipchat/HipchatConsumer.java
+++ /dev/null
@@ -1,128 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF 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
- *
- * http://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 org.apache.camel.component.hipchat;
-
-import java.io.IOException;
-import java.util.Calendar;
-import java.util.List;
-import java.util.Map;
-import java.util.TimeZone;
-
-import com.fasterxml.jackson.databind.ObjectMapper;
-import com.fasterxml.jackson.databind.type.MapType;
-import com.fasterxml.jackson.databind.type.TypeFactory;
-import org.apache.camel.Exchange;
-import org.apache.camel.Processor;
-import org.apache.camel.support.ScheduledPollConsumer;
-import org.apache.camel.util.URISupport;
-import org.apache.http.client.methods.CloseableHttpResponse;
-import org.apache.http.client.methods.HttpGet;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-/**
- * The Hipchat consumer consumes messages from a list of users.
- */
-public class HipchatConsumer extends ScheduledPollConsumer {
- public static final long DEFAULT_CONSUMER_DELAY = 5 * 1000;
-
- private static final Logger LOG = LoggerFactory.getLogger(HipchatConsumer.class);
-
- private static final MapType MAP_TYPE
- = TypeFactory.defaultInstance().constructMapType(Map.class, String.class, Object.class);
- private static final ObjectMapper MAPPER = new ObjectMapper();
-
- private transient String hipchatConsumerToString;
-
- public HipchatConsumer(HipchatEndpoint endpoint, Processor processor) {
- super(endpoint, processor);
- }
-
- @Override
- protected int poll() throws Exception {
- int messageCount = 0;
- for (String user : getConfig().consumableUsers()) {
- Exchange exchange = getEndpoint().createExchange();
- processExchangeForUser(user, exchange);
- messageCount++;
- }
- return messageCount;
- }
-
- private void processExchangeForUser(String user, Exchange exchange) throws Exception {
- String urlPath = String.format(getMostRecentMessageUrl(), user);
- LOG.debug("Polling HipChat Api " + urlPath + " for new messages at "
- + Calendar.getInstance(TimeZone.getTimeZone("UTC")).getTime());
- HttpGet httpGet = new HttpGet(getConfig().hipChatUrl() + urlPath);
- CloseableHttpResponse response = executeGet(httpGet);
- exchange.getIn().setHeader(HipchatConstants.FROM_USER, user);
- processApiResponse(exchange, response);
- }
-
- private void processApiResponse(Exchange exchange, CloseableHttpResponse response) throws Exception {
- try {
- Map<String, Object> jsonMap = MAPPER.readValue(response.getEntity().getContent(), MAP_TYPE);
- LOG.debug("Hipchat response " + response + ", json: " + MAPPER.writeValueAsString(jsonMap));
- if (jsonMap != null && jsonMap.size() > 0) {
- List<Map<String, Object>> items = (List<Map<String, Object>>) jsonMap.get(HipchatApiConstants.API_ITEMS);
- if (items != null && items.size() > 0) {
- try {
- Map<String, Object> item = items.get(0);
- String date = (String) item.get(HipchatApiConstants.API_DATE);
- String message = (String) item.get(HipchatApiConstants.API_MESSAGE);
- LOG.debug("Setting exchange body: " + message + ", header " + HipchatConstants.MESSAGE_DATE + ": "
- + date);
- exchange.getIn().setHeader(HipchatConstants.FROM_USER_RESPONSE_STATUS, response.getStatusLine());
- exchange.getIn().setHeader(HipchatConstants.MESSAGE_DATE, date);
- exchange.getIn().setBody(message);
- getProcessor().process(exchange);
- } catch (Exception e) {
- throw new HipchatException("Error parsing Json response from Hipchat API", e);
- }
- }
- }
- } finally {
- response.close();
- }
- }
-
- protected CloseableHttpResponse executeGet(HttpGet httpGet) throws IOException {
- return getConfig().getHttpClient().execute(httpGet);
- }
-
- private String getMostRecentMessageUrl() {
- return getConfig().withAuthToken(HipchatApiConstants.URI_PATH_USER_LATEST_PRIVATE_CHAT) + "&"
- + HipchatApiConstants.DEFAULT_MAX_RESULT;
- }
-
- private HipchatConfiguration getConfig() {
- return getEndpoint().getConfiguration();
- }
-
- @Override
- public HipchatEndpoint getEndpoint() {
- return (HipchatEndpoint) super.getEndpoint();
- }
-
- @Override
- public String toString() {
- if (hipchatConsumerToString == null) {
- hipchatConsumerToString = "HipchatConsumer[" + URISupport.sanitizeUri(getEndpoint().getEndpointUri()) + "]";
- }
- return hipchatConsumerToString;
- }
-}
diff --git a/components/camel-hipchat/src/main/java/org/apache/camel/component/hipchat/HipchatEndpoint.java b/components/camel-hipchat/src/main/java/org/apache/camel/component/hipchat/HipchatEndpoint.java
deleted file mode 100644
index 4b43a34..0000000
--- a/components/camel-hipchat/src/main/java/org/apache/camel/component/hipchat/HipchatEndpoint.java
+++ /dev/null
@@ -1,75 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF 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
- *
- * http://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 org.apache.camel.component.hipchat;
-
-import org.apache.camel.Category;
-import org.apache.camel.Consumer;
-import org.apache.camel.Processor;
-import org.apache.camel.Producer;
-import org.apache.camel.spi.UriEndpoint;
-import org.apache.camel.spi.UriParam;
-import org.apache.camel.support.ScheduledPollEndpoint;
-
-/**
- * Send and receive messages to/from Hipchat service.
- */
-@UriEndpoint(firstVersion = "2.15.0", scheme = "hipchat", title = "Hipchat", syntax = "hipchat:protocol:host:port",
- category = { Category.API, Category.CHAT, Category.CLOUD })
-public class HipchatEndpoint extends ScheduledPollEndpoint {
-
- @UriParam(defaultValue = "" + HipchatConsumer.DEFAULT_CONSUMER_DELAY, label = "consumer,scheduler",
- description = "Milliseconds before the next poll.")
- private long delay = HipchatConsumer.DEFAULT_CONSUMER_DELAY;
-
- @UriParam
- private HipchatConfiguration configuration;
-
- public HipchatEndpoint(String uri, HipchatComponent component) {
- super(uri, component);
- //Default delay of 500 millis is too often and would result in Rate Limit error's from
- //HipChat API as per https://www.hipchat.com/docs/apiv2/rate_limiting. End user can override using
- //consumer.delay parameter
- setDelay(HipchatConsumer.DEFAULT_CONSUMER_DELAY);
- configuration = new HipchatConfiguration();
- }
-
- @Override
- public Producer createProducer() throws Exception {
- return new HipchatProducer(this);
- }
-
- @Override
- public Consumer createConsumer(Processor processor) throws Exception {
- HipchatConsumer consumer = new HipchatConsumer(this, processor);
- configureConsumer(consumer);
- return consumer;
- }
-
- public HipchatConfiguration getConfiguration() {
- return configuration;
- }
-
- /**
- * Milliseconds before the next poll.
- */
- @Override
- public void setDelay(long delay) {
- super.setDelay(delay);
- this.delay = delay;
- }
-
-}
diff --git a/components/camel-hipchat/src/main/java/org/apache/camel/component/hipchat/HipchatException.java b/components/camel-hipchat/src/main/java/org/apache/camel/component/hipchat/HipchatException.java
deleted file mode 100644
index ce8e504..0000000
--- a/components/camel-hipchat/src/main/java/org/apache/camel/component/hipchat/HipchatException.java
+++ /dev/null
@@ -1,28 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF 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
- *
- * http://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 org.apache.camel.component.hipchat;
-
-public class HipchatException extends Exception {
-
- public HipchatException(String message, Exception e) {
- super(message, e);
- }
-
- public HipchatException(String message) {
- super(message);
- }
-}
diff --git a/components/camel-hipchat/src/main/java/org/apache/camel/component/hipchat/HipchatProducer.java b/components/camel-hipchat/src/main/java/org/apache/camel/component/hipchat/HipchatProducer.java
deleted file mode 100644
index 9b5d89f..0000000
--- a/components/camel-hipchat/src/main/java/org/apache/camel/component/hipchat/HipchatProducer.java
+++ /dev/null
@@ -1,137 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF 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
- *
- * http://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 org.apache.camel.component.hipchat;
-
-import java.io.IOException;
-import java.util.HashMap;
-import java.util.Map;
-
-import com.fasterxml.jackson.databind.ObjectMapper;
-import org.apache.camel.Exchange;
-import org.apache.camel.InvalidPayloadException;
-import org.apache.camel.Message;
-import org.apache.camel.support.DefaultProducer;
-import org.apache.camel.util.URISupport;
-import org.apache.http.StatusLine;
-import org.apache.http.client.methods.CloseableHttpResponse;
-import org.apache.http.client.methods.HttpPost;
-import org.apache.http.entity.ContentType;
-import org.apache.http.entity.StringEntity;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import static org.apache.camel.util.UnsafeUriCharactersEncoder.encodeHttpURI;
-
-/**
- * The Hipchat producer to send message to a user and/or a room.
- */
-public class HipchatProducer extends DefaultProducer {
-
- private static final Logger LOG = LoggerFactory.getLogger(HipchatProducer.class);
-
- private static final ObjectMapper MAPPER = new ObjectMapper();
-
- private transient String hipchatProducerToString;
-
- public HipchatProducer(HipchatEndpoint endpoint) {
- super(endpoint);
- }
-
- @Override
- public void process(Exchange exchange) throws Exception {
- Message message = getMessageForResponse(exchange);
- String user = exchange.getIn().getHeader(HipchatConstants.TO_USER, String.class);
- if (user != null) {
- message.setHeader(HipchatConstants.TO_USER_RESPONSE_STATUS, sendUserMessage(user, exchange));
- }
- String room = exchange.getIn().getHeader(HipchatConstants.TO_ROOM, String.class);
- if (room != null) {
- message.setHeader(HipchatConstants.TO_ROOM_RESPONSE_STATUS, sendRoomMessage(room, exchange));
- }
- }
-
- private StatusLine sendRoomMessage(String room, Exchange exchange) throws IOException, InvalidPayloadException {
- String urlPath = String.format(getConfig().withAuthToken(HipchatApiConstants.URI_PATH_ROOM_NOTIFY), room);
- String backGroundColor = exchange.getIn().getHeader(HipchatConstants.MESSAGE_BACKGROUND_COLOR, String.class);
- Map<String, String> jsonParam = getCommonHttpPostParam(exchange);
- if (backGroundColor != null) {
- jsonParam.put(HipchatApiConstants.API_MESSAGE_COLOR, backGroundColor);
- }
- LOG.info("Sending message to room: " + room + ", " + MAPPER.writeValueAsString(jsonParam));
- StatusLine statusLine = post(encodeHttpURI(urlPath), jsonParam);
- LOG.debug("Response status for send room message: {}", statusLine);
- return statusLine;
- }
-
- private StatusLine sendUserMessage(String user, Exchange exchange) throws IOException, InvalidPayloadException {
- String urlPath = String.format(getConfig().withAuthToken(HipchatApiConstants.URI_PATH_USER_MESSAGE), user);
- Map<String, String> jsonParam = getCommonHttpPostParam(exchange);
- LOG.info("Sending message to user: " + user + ", " + MAPPER.writeValueAsString(jsonParam));
- StatusLine statusLine = post(urlPath, jsonParam);
- LOG.debug("Response status for send user message: {}", statusLine);
- return statusLine;
- }
-
- private Map<String, String> getCommonHttpPostParam(Exchange exchange) throws InvalidPayloadException {
- String format = exchange.getIn().getHeader(HipchatConstants.MESSAGE_FORMAT, "text", String.class);
- String notify = exchange.getIn().getHeader(HipchatConstants.TRIGGER_NOTIFY, String.class);
- Map<String, String> jsonMap = new HashMap<>(4);
- jsonMap.put(HipchatApiConstants.API_MESSAGE, exchange.getIn().getMandatoryBody(String.class));
- if (notify != null) {
- jsonMap.put(HipchatApiConstants.API_MESSAGE_NOTIFY, notify);
- }
- jsonMap.put(HipchatApiConstants.API_MESSAGE_FORMAT, format);
- return jsonMap;
- }
-
- protected StatusLine post(String urlPath, Map<String, String> postParam) throws IOException {
- HttpPost httpPost = new HttpPost(getConfig().hipChatUrl() + urlPath);
- httpPost.setEntity(new StringEntity(MAPPER.writeValueAsString(postParam), ContentType.APPLICATION_JSON));
- CloseableHttpResponse closeableHttpResponse = getConfig().getHttpClient().execute(httpPost);
- try {
- return closeableHttpResponse.getStatusLine();
- } finally {
- closeableHttpResponse.close();
- }
- }
-
- private Message getMessageForResponse(final Exchange exchange) {
- if (exchange.getPattern().isOutCapable()) {
- Message out = exchange.getOut();
- out.copyFrom(exchange.getIn());
- return out;
- }
- return exchange.getIn();
- }
-
- private HipchatConfiguration getConfig() {
- return getEndpoint().getConfiguration();
- }
-
- @Override
- public HipchatEndpoint getEndpoint() {
- return (HipchatEndpoint) super.getEndpoint();
- }
-
- @Override
- public String toString() {
- if (hipchatProducerToString == null) {
- hipchatProducerToString = "HipchatProducer[" + URISupport.sanitizeUri(getEndpoint().getEndpointUri()) + "]";
- }
- return hipchatProducerToString;
- }
-}
diff --git a/components/camel-hipchat/src/test/java/org/apache/camel/component/hipchat/HipchatComponentConsumerTest.java b/components/camel-hipchat/src/test/java/org/apache/camel/component/hipchat/HipchatComponentConsumerTest.java
deleted file mode 100644
index 685a700..0000000
--- a/components/camel-hipchat/src/test/java/org/apache/camel/component/hipchat/HipchatComponentConsumerTest.java
+++ /dev/null
@@ -1,212 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF 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
- *
- * http://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 org.apache.camel.component.hipchat;
-
-import java.io.ByteArrayInputStream;
-import java.nio.charset.StandardCharsets;
-
-import org.apache.camel.CamelContext;
-import org.apache.camel.EndpointInject;
-import org.apache.camel.Exchange;
-import org.apache.camel.ProducerTemplate;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.apache.camel.test.junit5.CamelTestSupport;
-import org.apache.http.HttpEntity;
-import org.apache.http.ProtocolVersion;
-import org.apache.http.client.methods.CloseableHttpResponse;
-import org.apache.http.message.BasicStatusLine;
-import org.junit.jupiter.api.Test;
-
-import static org.apache.camel.test.junit5.TestSupport.assertIsInstanceOf;
-import static org.junit.jupiter.api.Assertions.assertEquals;
-import static org.junit.jupiter.api.Assertions.assertNotNull;
-import static org.mockito.Mockito.mock;
-import static org.mockito.Mockito.when;
-
-public class HipchatComponentConsumerTest extends CamelTestSupport {
- private CloseableHttpResponse closeableHttpResponse = mock(CloseableHttpResponse.class);
-
- @EndpointInject("hipchat:http:api.hipchat.com?authToken=anything&consumeUsers=@AUser")
- private ProducerTemplate template;
-
- @EndpointInject("mock:result")
- private MockEndpoint result;
-
- @Test
- public void sendInOnly() throws Exception {
- result.expectedMessageCount(1);
- String expectedResponse = "{\n"
- +
- " \"items\" : [\n"
- +
- " {\n"
- +
- " \"date\" : \"2015-01-19T22:07:11.030740+00:00\",\n"
- +
- " \"from\" : {\n"
- +
- " \"id\" : 1647095,\n"
- +
- " \"links\" : {\n"
- +
- " \"self\" : \"https://api.hipchat.com/v2/user/1647095\"\n"
- +
- " },\n"
- +
- " \"mention_name\" : \"notifier\",\n"
- +
- " \"name\" : \"Message Notifier\"\n"
- +
- " },\n"
- +
- " \"id\" : \"6567c6f7-7c1b-43cf-bed0-792b1d092919\",\n"
- +
- " \"mentions\" : [ ],\n"
- +
- " \"message\" : \"Unit test Alert\",\n"
- +
- " \"type\" : \"message\"\n"
- +
- " }\n"
- +
- " ],\n"
- +
- " \"links\" : {\n"
- +
- " \"self\" : \"https://api.hipchat.com/v2/user/%40ShreyasPurohit/history/latest\"\n"
- +
- " },\n"
- +
- " \"maxResults\" : 1,\n"
- +
- " \"startIndex\" : 0\n"
- +
- "}";
- HttpEntity mockHttpEntity = mock(HttpEntity.class);
- when(mockHttpEntity.getContent())
- .thenReturn(new ByteArrayInputStream(expectedResponse.getBytes(StandardCharsets.UTF_8)));
- when(closeableHttpResponse.getEntity()).thenReturn(mockHttpEntity);
- when(closeableHttpResponse.getStatusLine()).thenReturn(new BasicStatusLine(new ProtocolVersion("HTTP", 1, 1), 200, ""));
-
- assertMockEndpointsSatisfied();
-
- assertCommonResultExchange(result.getExchanges().get(0));
- }
-
- //TODO
- @Test
- public void sendInOnlyMultipleUsers() throws Exception {
- result.expectedMessageCount(1);
- String expectedResponse = "{\n"
- +
- " \"items\" : [\n"
- +
- " {\n"
- +
- " \"date\" : \"2015-01-19T22:07:11.030740+00:00\",\n"
- +
- " \"from\" : {\n"
- +
- " \"id\" : 1647095,\n"
- +
- " \"links\" : {\n"
- +
- " \"self\" : \"https://api.hipchat.com/v2/user/1647095\"\n"
- +
- " },\n"
- +
- " \"mention_name\" : \"notifier\",\n"
- +
- " \"name\" : \"Message Notifier\"\n"
- +
- " },\n"
- +
- " \"id\" : \"6567c6f7-7c1b-43cf-bed0-792b1d092919\",\n"
- +
- " \"mentions\" : [ ],\n"
- +
- " \"message\" : \"Unit test Alert\",\n"
- +
- " \"type\" : \"message\"\n"
- +
- " }\n"
- +
- " ],\n"
- +
- " \"links\" : {\n"
- +
- " \"self\" : \"https://api.hipchat.com/v2/user/%40ShreyasPurohit/history/latest\"\n"
- +
- " },\n"
- +
- " \"maxResults\" : 1,\n"
- +
- " \"startIndex\" : 0\n"
- +
- "}";
- HttpEntity mockHttpEntity = mock(HttpEntity.class);
- when(mockHttpEntity.getContent())
- .thenReturn(new ByteArrayInputStream(expectedResponse.getBytes(StandardCharsets.UTF_8)));
- when(closeableHttpResponse.getEntity()).thenReturn(mockHttpEntity);
- when(closeableHttpResponse.getStatusLine()).thenReturn(new BasicStatusLine(new ProtocolVersion("HTTP", 1, 1), 200, ""));
-
- assertMockEndpointsSatisfied();
-
- assertCommonResultExchange(result.getExchanges().get(0));
- }
-
- @Test
- public void sendInOnlyNoResponse() throws Exception {
- result.expectedMessageCount(0);
- HttpEntity mockHttpEntity = mock(HttpEntity.class);
- when(mockHttpEntity.getContent()).thenReturn(null);
- when(closeableHttpResponse.getEntity()).thenReturn(mockHttpEntity);
- when(closeableHttpResponse.getStatusLine()).thenReturn(new BasicStatusLine(new ProtocolVersion("HTTP", 1, 1), 200, ""));
-
- assertMockEndpointsSatisfied();
- }
-
- private void assertCommonResultExchange(Exchange resultExchange) {
- assertIsInstanceOf(String.class, resultExchange.getIn().getBody());
- assertEquals("Unit test Alert", resultExchange.getIn().getBody(String.class));
- assertEquals("@AUser", resultExchange.getIn().getHeader(HipchatConstants.FROM_USER));
- assertEquals("2015-01-19T22:07:11.030740+00:00", resultExchange.getIn().getHeader(HipchatConstants.MESSAGE_DATE));
- assertNotNull(resultExchange.getIn().getHeader(HipchatConstants.FROM_USER_RESPONSE_STATUS));
- }
-
- @Override
- protected CamelContext createCamelContext() throws Exception {
- final CamelContext context = super.createCamelContext();
- HipchatComponent component = new HipchatTestComponent(context, closeableHttpResponse);
- component.init();
- context.addComponent("hipchat", component);
- return context;
- }
-
- @Override
- protected RouteBuilder createRouteBuilder() throws Exception {
- return new RouteBuilder() {
- @Override
- public void configure() {
- from("hipchat:http://api.hipchat.com?authToken=anything&consumeUsers=@AUser")
- .to("mock:result");
- }
- };
- }
-
-}
diff --git a/components/camel-hipchat/src/test/java/org/apache/camel/component/hipchat/HipchatComponentCustomHttpClientTest.java b/components/camel-hipchat/src/test/java/org/apache/camel/component/hipchat/HipchatComponentCustomHttpClientTest.java
deleted file mode 100644
index e57f47e..0000000
--- a/components/camel-hipchat/src/test/java/org/apache/camel/component/hipchat/HipchatComponentCustomHttpClientTest.java
+++ /dev/null
@@ -1,97 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF 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
- *
- * http://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 org.apache.camel.component.hipchat;
-
-import java.io.IOException;
-
-import org.apache.camel.BindToRegistry;
-import org.apache.camel.EndpointInject;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.test.junit5.CamelTestSupport;
-import org.apache.http.HttpHost;
-import org.apache.http.HttpRequest;
-import org.apache.http.client.ClientProtocolException;
-import org.apache.http.client.HttpClient;
-import org.apache.http.client.methods.CloseableHttpResponse;
-import org.apache.http.conn.ClientConnectionManager;
-import org.apache.http.impl.client.CloseableHttpClient;
-import org.apache.http.impl.client.HttpClientBuilder;
-import org.apache.http.params.HttpParams;
-import org.apache.http.protocol.HttpContext;
-import org.junit.jupiter.api.Test;
-
-import static org.apache.camel.test.junit5.TestSupport.assertIsInstanceOf;
-import static org.junit.jupiter.api.Assertions.assertNotNull;
-
-public class HipchatComponentCustomHttpClientTest extends CamelTestSupport {
-
- @EndpointInject("hipchat:http://api.hipchat.com?httpClient=#myHttpClient&authToken=anything&consumeUsers=@AUser")
- private HipchatEndpoint hipchatEndpoint;
-
- @BindToRegistry("myHttpClient")
- private MyCustomHttpClient client = new MyCustomHttpClient();
-
- @Test
- public void ensureCustomHttpClientIsDefined() {
- HttpClient httpClient = hipchatEndpoint.getConfiguration().getHttpClient();
- assertNotNull(httpClient);
- assertIsInstanceOf(MyCustomHttpClient.class, httpClient);
- }
-
- @Override
- protected RouteBuilder createRouteBuilder() throws Exception {
- return new RouteBuilder() {
- @Override
- public void configure() {
- from("direct:start")
- .to("hipchat:http://api.hipchat.com?httpClient=#myHttpClient&authToken=anything&consumeUsers=@AUser")
- .to("mock:result");
- }
- };
- }
-
- public static class MyCustomHttpClient extends CloseableHttpClient {
-
- private final CloseableHttpClient innerHttpClient;
-
- public MyCustomHttpClient() {
- this.innerHttpClient = HttpClientBuilder.create().build();
- }
-
- @Override
- public HttpParams getParams() {
- return innerHttpClient.getParams();
- }
-
- @Override
- public ClientConnectionManager getConnectionManager() {
- return innerHttpClient.getConnectionManager();
- }
-
- @Override
- public void close() throws IOException {
- innerHttpClient.close();
- }
-
- @Override
- protected CloseableHttpResponse doExecute(HttpHost target, HttpRequest request, HttpContext context)
- throws IOException, ClientProtocolException {
- return innerHttpClient.execute(target, request, context);
- }
- }
-
-}
diff --git a/components/camel-hipchat/src/test/java/org/apache/camel/component/hipchat/HipchatComponentMultipleUsersTest.java b/components/camel-hipchat/src/test/java/org/apache/camel/component/hipchat/HipchatComponentMultipleUsersTest.java
deleted file mode 100644
index 45b2e66..0000000
--- a/components/camel-hipchat/src/test/java/org/apache/camel/component/hipchat/HipchatComponentMultipleUsersTest.java
+++ /dev/null
@@ -1,134 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF 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
- *
- * http://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 org.apache.camel.component.hipchat;
-
-import java.io.ByteArrayInputStream;
-import java.nio.charset.StandardCharsets;
-import java.util.Arrays;
-
-import org.apache.camel.CamelContext;
-import org.apache.camel.EndpointInject;
-import org.apache.camel.ProducerTemplate;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.apache.camel.test.junit5.CamelTestSupport;
-import org.apache.http.HttpEntity;
-import org.apache.http.ProtocolVersion;
-import org.apache.http.client.methods.CloseableHttpResponse;
-import org.apache.http.message.BasicStatusLine;
-import org.junit.jupiter.api.Test;
-import org.mockito.invocation.InvocationOnMock;
-import org.mockito.stubbing.Answer;
-
-import static org.mockito.Mockito.mock;
-import static org.mockito.Mockito.when;
-
-public class HipchatComponentMultipleUsersTest extends CamelTestSupport {
- private CloseableHttpResponse closeableHttpResponse = mock(CloseableHttpResponse.class);
-
- @EndpointInject("hipchat:http://api.hipchat.com?authToken=anything&consumeUsers=@AUser")
- private ProducerTemplate template;
-
- @EndpointInject("mock:result")
- private MockEndpoint result;
-
- @Test
- public void sendInOnlyMultipleUsers() throws Exception {
- result.expectedMessageCount(2);
- result.expectedHeaderValuesReceivedInAnyOrder(HipchatConstants.FROM_USER,
- Arrays.asList(new String[] { "@AUser", "@BUser" }));
- final String expectedResponse = "{\n"
- +
- " \"items\" : [\n"
- +
- " {\n"
- +
- " \"date\" : \"2015-01-19T22:07:11.030740+00:00\",\n"
- +
- " \"from\" : {\n"
- +
- " \"id\" : 1647095,\n"
- +
- " \"links\" : {\n"
- +
- " \"self\" : \"https://api.hipchat.com/v2/user/1647095\"\n"
- +
- " },\n"
- +
- " \"mention_name\" : \"notifier\",\n"
- +
- " \"name\" : \"Message Notifier\"\n"
- +
- " },\n"
- +
- " \"id\" : \"6567c6f7-7c1b-43cf-bed0-792b1d092919\",\n"
- +
- " \"mentions\" : [ ],\n"
- +
- " \"message\" : \"Unit test Alert\",\n"
- +
- " \"type\" : \"message\"\n"
- +
- " }\n"
- +
- " ],\n"
- +
- " \"links\" : {\n"
- +
- " \"self\" : \"https://api.hipchat.com/v2/user/%40ShreyasPurohit/history/latest\"\n"
- +
- " },\n"
- +
- " \"maxResults\" : 1,\n"
- +
- " \"startIndex\" : 0\n"
- +
- "}";
- HttpEntity mockHttpEntity = mock(HttpEntity.class);
- when(mockHttpEntity.getContent()).thenAnswer(new Answer<Object>() {
- @Override
- public Object answer(InvocationOnMock invocationOnMock) throws Throwable {
- return new ByteArrayInputStream(expectedResponse.getBytes(StandardCharsets.UTF_8));
- }
- });
- when(closeableHttpResponse.getEntity()).thenReturn(mockHttpEntity);
- when(closeableHttpResponse.getStatusLine()).thenReturn(new BasicStatusLine(new ProtocolVersion("HTTP", 1, 1), 200, ""));
-
- assertMockEndpointsSatisfied();
- }
-
- @Override
- protected CamelContext createCamelContext() throws Exception {
- final CamelContext context = super.createCamelContext();
- HipchatComponent component = new HipchatTestComponent(context, closeableHttpResponse);
- component.init();
- context.addComponent("hipchat", component);
- return context;
- }
-
- @Override
- protected RouteBuilder createRouteBuilder() throws Exception {
- return new RouteBuilder() {
- @Override
- public void configure() {
- from("hipchat:http://api.hipchat.com?authToken=anything&consumeUsers=@AUser,@BUser")
- .to("mock:result");
- }
- };
- }
-
-}
diff --git a/components/camel-hipchat/src/test/java/org/apache/camel/component/hipchat/HipchatComponentProducerTest.java b/components/camel-hipchat/src/test/java/org/apache/camel/component/hipchat/HipchatComponentProducerTest.java
deleted file mode 100644
index d4f6b3a..0000000
--- a/components/camel-hipchat/src/test/java/org/apache/camel/component/hipchat/HipchatComponentProducerTest.java
+++ /dev/null
@@ -1,218 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF 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
- *
- * http://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 org.apache.camel.component.hipchat;
-
-import java.util.Map;
-
-import org.apache.camel.CamelContext;
-import org.apache.camel.EndpointInject;
-import org.apache.camel.Exchange;
-import org.apache.camel.ExchangePattern;
-import org.apache.camel.Message;
-import org.apache.camel.Processor;
-import org.apache.camel.ProducerTemplate;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.apache.camel.test.junit5.CamelTestSupport;
-import org.apache.http.StatusLine;
-import org.junit.jupiter.api.Test;
-
-import static org.apache.camel.test.junit5.TestSupport.assertIsInstanceOf;
-import static org.junit.jupiter.api.Assertions.assertEquals;
-import static org.junit.jupiter.api.Assertions.assertNotNull;
-import static org.junit.jupiter.api.Assertions.assertNull;
-
-public class HipchatComponentProducerTest extends CamelTestSupport {
- @EndpointInject("direct:start")
- private ProducerTemplate template;
-
- @EndpointInject("mock:result")
- private MockEndpoint result;
-
- private PostCallback callback = new PostCallback();
-
- @Test
- public void sendInOnly() throws Exception {
- result.expectedMessageCount(1);
-
- Exchange exchange = template.send("direct:start", ExchangePattern.InOnly, new Processor() {
- public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(HipchatConstants.TO_ROOM, "CamelUnitTest");
- exchange.getIn().setHeader(HipchatConstants.TO_USER, "CamelUnitTestUser");
- exchange.getIn().setBody("This is my unit test message.");
- }
- });
-
- assertMockEndpointsSatisfied();
-
- assertCommonResultExchange(result.getExchanges().get(0));
- assertNullExchangeHeader(result.getExchanges().get(0));
-
- assertResponseMessage(exchange.getIn());
- }
-
- @Test
- public void sendInOut() throws Exception {
- result.expectedMessageCount(1);
-
- Exchange exchange = template.send("direct:start", ExchangePattern.InOut, new Processor() {
- public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(HipchatConstants.TO_ROOM, "CamelUnitTest");
- exchange.getIn().setHeader(HipchatConstants.TO_USER, "CamelUnitTestUser");
- exchange.getIn().setHeader(HipchatConstants.MESSAGE_BACKGROUND_COLOR, "CamelUnitTestBkColor");
- exchange.getIn().setHeader(HipchatConstants.MESSAGE_FORMAT, "CamelUnitTestFormat");
- exchange.getIn().setHeader(HipchatConstants.TRIGGER_NOTIFY, "CamelUnitTestNotify");
- exchange.getIn().setBody("This is my unit test message.");
- }
- });
-
- assertMockEndpointsSatisfied();
-
- assertCommonResultExchange(result.getExchanges().get(0));
- assertRemainingResultExchange(result.getExchanges().get(0));
-
- assertResponseMessage(exchange.getIn());
-
- }
-
- @Test
- public void sendInOutRoomOnly() throws Exception {
- result.expectedMessageCount(1);
-
- Exchange exchange = template.send("direct:start", ExchangePattern.InOut, new Processor() {
- public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(HipchatConstants.TO_ROOM, "CamelUnitTest");
- exchange.getIn().setHeader(HipchatConstants.MESSAGE_BACKGROUND_COLOR, "CamelUnitTestBkColor");
- exchange.getIn().setHeader(HipchatConstants.MESSAGE_FORMAT, "CamelUnitTestFormat");
- exchange.getIn().setHeader(HipchatConstants.TRIGGER_NOTIFY, "CamelUnitTestNotify");
- exchange.getIn().setBody("This is my unit test message.");
- }
- });
-
- assertMockEndpointsSatisfied();
- Exchange resultExchange = result.getExchanges().get(0);
- assertIsInstanceOf(String.class, resultExchange.getIn().getBody());
- assertEquals("This is my unit test message.", resultExchange.getIn().getBody(String.class));
- assertEquals("CamelUnitTest", resultExchange.getIn().getHeader(HipchatConstants.TO_ROOM));
- assertNull(resultExchange.getIn().getHeader(HipchatConstants.TO_USER));
- assertNull(resultExchange.getIn().getHeader(HipchatConstants.TO_USER_RESPONSE_STATUS));
- assertNotNull(resultExchange.getIn().getHeader(HipchatConstants.TO_ROOM_RESPONSE_STATUS));
-
- assertRemainingResultExchange(result.getExchanges().get(0));
-
- assertEquals(204,
- exchange.getIn().getHeader(HipchatConstants.TO_ROOM_RESPONSE_STATUS, StatusLine.class).getStatusCode());
- assertNotNull(callback);
- assertNotNull(callback.called);
- assertEquals("This is my unit test message.", callback.called.get(HipchatApiConstants.API_MESSAGE));
- assertEquals("CamelUnitTestBkColor", callback.called.get(HipchatApiConstants.API_MESSAGE_COLOR));
- assertEquals("CamelUnitTestFormat", callback.called.get(HipchatApiConstants.API_MESSAGE_FORMAT));
- assertEquals("CamelUnitTestNotify", callback.called.get(HipchatApiConstants.API_MESSAGE_NOTIFY));
- }
-
- @Test
- public void sendInOutUserOnly() throws Exception {
- result.expectedMessageCount(1);
-
- Exchange exchange = template.send("direct:start", ExchangePattern.InOut, new Processor() {
- public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(HipchatConstants.TO_USER, "CamelUnitTest");
- exchange.getIn().setHeader(HipchatConstants.MESSAGE_BACKGROUND_COLOR, "CamelUnitTestBkColor");
- exchange.getIn().setHeader(HipchatConstants.MESSAGE_FORMAT, "CamelUnitTestFormat");
- exchange.getIn().setHeader(HipchatConstants.TRIGGER_NOTIFY, "CamelUnitTestNotify");
- exchange.getIn().setBody("This is my unit test message.");
- }
- });
-
- assertMockEndpointsSatisfied();
- Exchange resultExchange = result.getExchanges().get(0);
- assertIsInstanceOf(String.class, resultExchange.getIn().getBody());
- assertEquals("This is my unit test message.", resultExchange.getIn().getBody(String.class));
- assertEquals("CamelUnitTest", resultExchange.getIn().getHeader(HipchatConstants.TO_USER));
- assertNull(resultExchange.getIn().getHeader(HipchatConstants.TO_ROOM));
- assertNull(resultExchange.getIn().getHeader(HipchatConstants.TO_ROOM_RESPONSE_STATUS));
- assertNotNull(resultExchange.getIn().getHeader(HipchatConstants.TO_USER_RESPONSE_STATUS));
-
- assertRemainingResultExchange(result.getExchanges().get(0));
-
- assertEquals(204,
- exchange.getIn().getHeader(HipchatConstants.TO_USER_RESPONSE_STATUS, StatusLine.class).getStatusCode());
- assertNotNull(callback);
- assertNotNull(callback.called);
- assertEquals("This is my unit test message.", callback.called.get(HipchatApiConstants.API_MESSAGE));
- assertNull(callback.called.get(HipchatApiConstants.API_MESSAGE_COLOR));
- assertEquals("CamelUnitTestFormat", callback.called.get(HipchatApiConstants.API_MESSAGE_FORMAT));
- assertEquals("CamelUnitTestNotify", callback.called.get(HipchatApiConstants.API_MESSAGE_NOTIFY));
- }
-
- private void assertNullExchangeHeader(Exchange resultExchange) {
- assertNull(resultExchange.getIn().getHeader(HipchatConstants.FROM_USER));
- assertNull(resultExchange.getIn().getHeader(HipchatConstants.MESSAGE_BACKGROUND_COLOR));
- assertNull(resultExchange.getIn().getHeader(HipchatConstants.MESSAGE_FORMAT));
- assertNull(resultExchange.getIn().getHeader(HipchatConstants.TRIGGER_NOTIFY));
- }
-
- private void assertRemainingResultExchange(Exchange resultExchange) {
- assertEquals("CamelUnitTestBkColor", resultExchange.getIn().getHeader(HipchatConstants.MESSAGE_BACKGROUND_COLOR));
- assertEquals("CamelUnitTestFormat", resultExchange.getIn().getHeader(HipchatConstants.MESSAGE_FORMAT));
- assertEquals("CamelUnitTestNotify", resultExchange.getIn().getHeader(HipchatConstants.TRIGGER_NOTIFY));
- }
-
- private void assertResponseMessage(Message message) {
- assertEquals(204, message.getHeader(HipchatConstants.TO_ROOM_RESPONSE_STATUS, StatusLine.class).getStatusCode());
- assertEquals(204, message.getHeader(HipchatConstants.TO_USER_RESPONSE_STATUS, StatusLine.class).getStatusCode());
- }
-
- private void assertCommonResultExchange(Exchange resultExchange) {
- assertIsInstanceOf(String.class, resultExchange.getIn().getBody());
- assertEquals("This is my unit test message.", resultExchange.getIn().getBody(String.class));
- assertEquals("CamelUnitTest", resultExchange.getIn().getHeader(HipchatConstants.TO_ROOM));
- assertEquals("CamelUnitTestUser", resultExchange.getIn().getHeader(HipchatConstants.TO_USER));
- assertNotNull(resultExchange.getIn().getHeader(HipchatConstants.TO_USER_RESPONSE_STATUS));
- assertNotNull(resultExchange.getIn().getHeader(HipchatConstants.TO_ROOM_RESPONSE_STATUS));
- }
-
- @Override
- protected CamelContext createCamelContext() throws Exception {
- final CamelContext context = super.createCamelContext();
- HipchatComponent component = new HipchatTestComponent(context, callback);
- component.init();
- context.addComponent("hipchat", component);
- return context;
- }
-
- @Override
- protected RouteBuilder createRouteBuilder() throws Exception {
- return new RouteBuilder() {
- @Override
- public void configure() {
- from("direct:start")
- .to("hipchat:http:api.hipchat.com?authToken=anything")
- .to("mock:result");
- }
- };
- }
-
- public static class PostCallback {
- public Map<String, String> called;
-
- public void call(Map<String, String> postParam) {
- this.called = postParam;
- }
- }
-
-}
diff --git a/components/camel-hipchat/src/test/java/org/apache/camel/component/hipchat/HipchatEPSuccessTestSupport.java b/components/camel-hipchat/src/test/java/org/apache/camel/component/hipchat/HipchatEPSuccessTestSupport.java
deleted file mode 100644
index 8d74e5d..0000000
--- a/components/camel-hipchat/src/test/java/org/apache/camel/component/hipchat/HipchatEPSuccessTestSupport.java
+++ /dev/null
@@ -1,65 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF 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
- *
- * http://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 org.apache.camel.component.hipchat;
-
-import java.io.IOException;
-import java.util.Map;
-
-import org.apache.camel.Consumer;
-import org.apache.camel.Processor;
-import org.apache.camel.Producer;
-import org.apache.http.ProtocolVersion;
-import org.apache.http.StatusLine;
-import org.apache.http.client.methods.CloseableHttpResponse;
-import org.apache.http.client.methods.HttpGet;
-import org.apache.http.message.BasicStatusLine;
-
-public class HipchatEPSuccessTestSupport extends HipchatEndpoint {
- private HipchatComponentProducerTest.PostCallback callback;
- private CloseableHttpResponse closeableHttpResponse;
-
- public HipchatEPSuccessTestSupport(
- String uri,
- HipchatComponent component,
- HipchatComponentProducerTest.PostCallback callback,
- CloseableHttpResponse consumerResponse) {
- super(uri, component);
- this.callback = callback;
- this.closeableHttpResponse = consumerResponse;
- }
-
- @Override
- public Producer createProducer() throws Exception {
- return new HipchatProducer(this) {
- @Override
- protected StatusLine post(String urlPath, Map<String, String> postParam) throws IOException {
- callback.call(postParam);
- return new BasicStatusLine(new ProtocolVersion("any", 1, 1), 204, "");
- }
- };
- }
-
- @Override
- public Consumer createConsumer(Processor processor) throws Exception {
- return new HipchatConsumer(this, processor) {
- @Override
- protected CloseableHttpResponse executeGet(HttpGet httpGet) throws IOException {
- return closeableHttpResponse;
- }
- };
- }
-}
diff --git a/components/camel-hipchat/src/test/java/org/apache/camel/component/hipchat/HipchatEndpointTest.java b/components/camel-hipchat/src/test/java/org/apache/camel/component/hipchat/HipchatEndpointTest.java
deleted file mode 100644
index 6f21cb1..0000000
--- a/components/camel-hipchat/src/test/java/org/apache/camel/component/hipchat/HipchatEndpointTest.java
+++ /dev/null
@@ -1,41 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF 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
- *
- * http://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 org.apache.camel.component.hipchat;
-
-import org.apache.camel.CamelContext;
-import org.apache.camel.Exchange;
-import org.apache.camel.Processor;
-import org.junit.jupiter.api.Test;
-import org.mockito.Mockito;
-
-import static org.junit.jupiter.api.Assertions.assertEquals;
-
-public class HipchatEndpointTest {
- @Test
- public void testCreateConsumer() throws Exception {
- HipchatComponent component = new HipchatComponent(Mockito.mock(CamelContext.class));
- HipchatEndpoint endpoint = new HipchatEndpoint("hipchat:http://api.hipchat.com?authKey=token", component);
- HipchatConsumer consumer = (HipchatConsumer) endpoint.createConsumer(new Processor() {
- @Override
- public void process(Exchange exchange) throws Exception {
-
- }
- });
-
- assertEquals(5000, consumer.getDelay());
- }
-}
diff --git a/components/camel-hipchat/src/test/java/org/apache/camel/component/hipchat/HipchatTestComponent.java b/components/camel-hipchat/src/test/java/org/apache/camel/component/hipchat/HipchatTestComponent.java
deleted file mode 100644
index c999545..0000000
--- a/components/camel-hipchat/src/test/java/org/apache/camel/component/hipchat/HipchatTestComponent.java
+++ /dev/null
@@ -1,48 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF 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
- *
- * http://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 org.apache.camel.component.hipchat;
-
-import org.apache.camel.CamelContext;
-import org.apache.camel.component.hipchat.HipchatComponentProducerTest.PostCallback;
-import org.apache.camel.spi.annotations.Component;
-import org.apache.http.client.methods.CloseableHttpResponse;
-
-@Component("hipchat")
-public class HipchatTestComponent extends HipchatComponent {
-
- PostCallback callback;
- CloseableHttpResponse closeableHttpResponse;
-
- public HipchatTestComponent(CamelContext context) {
- super(context);
- }
-
- public HipchatTestComponent(CamelContext context, CloseableHttpResponse closeableHttpResponse) {
- super(context);
- this.closeableHttpResponse = closeableHttpResponse;
- }
-
- public HipchatTestComponent(CamelContext context, PostCallback callback) {
- super(context);
- this.callback = callback;
- }
-
- @Override
- protected HipchatEndpoint getHipchatEndpoint(String uri) {
- return new HipchatEPSuccessTestSupport(uri, this, callback, closeableHttpResponse);
- }
-}
diff --git a/components/camel-hipchat/src/test/java/org/apache/camel/component/hipchat/HipchatXmlDefinedComponentProducerTest.java b/components/camel-hipchat/src/test/java/org/apache/camel/component/hipchat/HipchatXmlDefinedComponentProducerTest.java
deleted file mode 100644
index 612c980..0000000
--- a/components/camel-hipchat/src/test/java/org/apache/camel/component/hipchat/HipchatXmlDefinedComponentProducerTest.java
+++ /dev/null
@@ -1,67 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF 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
- *
- * http://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 org.apache.camel.component.hipchat;
-
-import java.io.InputStream;
-
-import org.apache.camel.CamelContext;
-import org.apache.camel.Endpoint;
-import org.apache.camel.EndpointInject;
-import org.apache.camel.ExtendedCamelContext;
-import org.apache.camel.model.Model;
-import org.apache.camel.model.RoutesDefinition;
-import org.apache.camel.test.junit5.CamelTestSupport;
-import org.junit.jupiter.api.Test;
-
-import static org.apache.camel.test.junit5.TestSupport.assertIsInstanceOf;
-import static org.hamcrest.MatcherAssert.assertThat;
-import static org.hamcrest.core.Is.is;
-
-public class HipchatXmlDefinedComponentProducerTest extends CamelTestSupport {
-
- @EndpointInject("hipchat:https:foobar.com:443?authToken=abc123")
- protected Endpoint endpoint;
-
- @Test
- public void shouldConfigureEndpointCorrectlyViaXml() throws Exception {
- assertIsInstanceOf(HipchatEndpoint.class, endpoint);
- HipchatEndpoint hipchatEndpoint = (HipchatEndpoint) endpoint;
- HipchatConfiguration configuration = hipchatEndpoint.getConfiguration();
- assertThat(configuration.getAuthToken(), is("abc123"));
- assertThat(configuration.getHost(), is("foobar.com"));
- assertThat(configuration.getProtocol(), is("https"));
- assertThat(configuration.getPort(), is(443));
- }
-
- @Override
- protected CamelContext createCamelContext() throws Exception {
- final CamelContext context = super.createCamelContext();
- HipchatComponent component = new HipchatTestComponent(context);
- component.init();
- context.addComponent("hipchat", component);
-
- // This test is all about ensuring the endpoint is configured correctly when using the XML DSL so this
- try (InputStream routes = getClass().getResourceAsStream("HipchatXmlDefinedComponentProducerTest-route.xml")) {
- ExtendedCamelContext ecc = context.adapt(ExtendedCamelContext.class);
- RoutesDefinition routesDefinition
- = (RoutesDefinition) ecc.getXMLRoutesDefinitionLoader().loadRoutesDefinition(ecc, routes);
- context.getExtension(Model.class).addRouteDefinition(routesDefinition.getRoutes().get(0));
- }
-
- return context;
- }
-}
diff --git a/components/camel-hipchat/src/test/java/org/apache/camel/component/hipchat/integration/HipchatConsumerIntegrationTest.java b/components/camel-hipchat/src/test/java/org/apache/camel/component/hipchat/integration/HipchatConsumerIntegrationTest.java
deleted file mode 100644
index b3520db..0000000
--- a/components/camel-hipchat/src/test/java/org/apache/camel/component/hipchat/integration/HipchatConsumerIntegrationTest.java
+++ /dev/null
@@ -1,68 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF 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
- *
- * http://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 org.apache.camel.component.hipchat.integration;
-
-import org.apache.camel.EndpointInject;
-import org.apache.camel.Exchange;
-import org.apache.camel.Predicate;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.hipchat.HipchatConstants;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.apache.camel.support.processor.idempotent.MemoryIdempotentRepository;
-import org.apache.camel.test.junit5.CamelTestSupport;
-import org.apache.http.StatusLine;
-import org.junit.jupiter.api.Disabled;
-import org.junit.jupiter.api.Test;
-
-@Disabled("Must be manually tested. Provide your own auth key, user, & room from https://www.hipchat.com/docs/apiv2/auth")
-public class HipchatConsumerIntegrationTest extends CamelTestSupport {
-
- @EndpointInject("mock:result")
- private MockEndpoint result;
-
- @Test
- public void sendInOnly() throws Exception {
- result.expectedMessageCount(1);
- result.expectedMessagesMatches(new Predicate() {
- @Override
- public boolean matches(Exchange exchange) {
- StatusLine status = (StatusLine) exchange.getIn().getHeader(HipchatConstants.FROM_USER_RESPONSE_STATUS);
- return 200 == status.getStatusCode();
- }
- });
-
- assertMockEndpointsSatisfied();
- }
-
- @Override
- protected RouteBuilder createRouteBuilder() throws Exception {
- return new RouteBuilder() {
- @Override
- public void configure() throws Exception {
- String hipchatEndpointUri
- = "hipchat:http:api.hipchat.com?authToken=XXXX&consumeUsers=@ShreyasPurohit&delay=1000";
-
- from(hipchatEndpointUri)
- .idempotentConsumer(
- simple("${in.header.HipchatMessageDate} ${in.header.HipchatFromUser}"),
- MemoryIdempotentRepository.memoryIdempotentRepository(200))
- .to("mock:result");
- }
- };
- }
-
-}
diff --git a/components/camel-hipchat/src/test/java/org/apache/camel/component/hipchat/integration/HipchatProducerIntegrationTest.java b/components/camel-hipchat/src/test/java/org/apache/camel/component/hipchat/integration/HipchatProducerIntegrationTest.java
deleted file mode 100644
index 58ec849..0000000
--- a/components/camel-hipchat/src/test/java/org/apache/camel/component/hipchat/integration/HipchatProducerIntegrationTest.java
+++ /dev/null
@@ -1,113 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF 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
- *
- * http://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 org.apache.camel.component.hipchat.integration;
-
-import org.apache.camel.EndpointInject;
-import org.apache.camel.Exchange;
-import org.apache.camel.ExchangePattern;
-import org.apache.camel.Message;
-import org.apache.camel.Processor;
-import org.apache.camel.ProducerTemplate;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.hipchat.HipchatConstants;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.apache.camel.test.junit5.CamelTestSupport;
-import org.apache.http.StatusLine;
-import org.junit.jupiter.api.Disabled;
-import org.junit.jupiter.api.Test;
-
-import static org.junit.jupiter.api.Assertions.assertEquals;
-
-@Disabled("Must be manually tested. Provide your own auth key, user, & room from https://www.hipchat.com/docs/apiv2/auth")
-public class HipchatProducerIntegrationTest extends CamelTestSupport {
-
- @EndpointInject("direct:start")
- private ProducerTemplate template;
-
- @EndpointInject("mock:result")
- private MockEndpoint result;
-
- @Test
- public void sendInOnly() throws Exception {
- result.expectedMessageCount(2);
-
- Exchange exchange1 = template.send("direct:start", ExchangePattern.InOnly, new Processor() {
- public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(HipchatConstants.TO_ROOM, "Developer");
- exchange.getIn().setHeader(HipchatConstants.MESSAGE_FORMAT, "text");
- exchange.getIn().setHeader(HipchatConstants.TRIGGER_NOTIFY, "true");
- exchange.getIn().setHeader(HipchatConstants.MESSAGE_BACKGROUND_COLOR, "green");
- exchange.getIn().setHeader(HipchatConstants.TO_USER, "@ShreyasPurohit");
- exchange.getIn().setBody("Integration test Alert");
- }
- });
-
- Exchange exchange2 = template.send("direct:start", ExchangePattern.InOnly, new Processor() {
- public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(HipchatConstants.TO_ROOM, "Developer");
- exchange.getIn().setHeader(HipchatConstants.MESSAGE_FORMAT, "html");
- exchange.getIn().setHeader(HipchatConstants.TRIGGER_NOTIFY, "false");
- exchange.getIn().setHeader(HipchatConstants.MESSAGE_BACKGROUND_COLOR, "red");
- exchange.getIn().setHeader(HipchatConstants.TO_USER, "@ShreyasPurohit");
- exchange.getIn().setBody("<b>Integration test Alert</b>");
- }
- });
-
- assertMockEndpointsSatisfied();
-
- assertResponseMessage(exchange1.getIn());
- assertResponseMessage(exchange2.getIn());
-
- }
-
- @Test
- public void sendToUriUnsafeRoomName() throws Exception {
- result.expectedMessageCount(1);
-
- Exchange exchange1 = template.send("direct:start", ExchangePattern.InOnly, new Processor() {
- public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(HipchatConstants.TO_ROOM, "Camel Test");
- exchange.getIn().setHeader(HipchatConstants.TO_USER, "@ShreyasPurohit");
- exchange.getIn().setBody("A room with spaces");
- }
- });
-
- assertMockEndpointsSatisfied();
-
- assertResponseMessage(exchange1.getIn());
- }
-
- private void assertResponseMessage(Message message) {
- assertEquals(204, message.getHeader(HipchatConstants.TO_ROOM_RESPONSE_STATUS, StatusLine.class).getStatusCode());
- assertEquals(204, message.getHeader(HipchatConstants.TO_USER_RESPONSE_STATUS, StatusLine.class).getStatusCode());
- }
-
- @Override
- protected RouteBuilder createRouteBuilder() throws Exception {
- return new RouteBuilder() {
- @Override
- public void configure() throws Exception {
- String hipchatEndpointUri = "hipchat:http:api.hipchat.com?authToken=XXXX";
-
- from("direct:start")
- .to(hipchatEndpointUri)
- .to("mock:result");
- }
- };
- }
-
-}
diff --git a/components/camel-hipchat/src/test/resources/log4j2.properties b/components/camel-hipchat/src/test/resources/log4j2.properties
deleted file mode 100644
index 2492bcc..0000000
--- a/components/camel-hipchat/src/test/resources/log4j2.properties
+++ /dev/null
@@ -1,28 +0,0 @@
-## ---------------------------------------------------------------------------
-## Licensed to the Apache Software Foundation (ASF) under one or more
-## contributor license agreements. See the NOTICE file distributed with
-## this work for additional information regarding copyright ownership.
-## The ASF 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
-##
-## http://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.
-## ---------------------------------------------------------------------------
-
-appender.file.type = File
-appender.file.name = file
-appender.file.fileName = target/camel-hipchat-test.log
-appender.file.layout.type = PatternLayout
-appender.file.layout.pattern = %d [%-15.15t] %-5p %-30.30c{1} - %m%n
-appender.out.type = Console
-appender.out.name = out
-appender.out.layout.type = PatternLayout
-appender.out.layout.pattern = %d [%-15.15t] %-5p %-30.30c{1} - %m%n
-rootLogger.level = INFO
-rootLogger.appenderRef.file.ref = file
diff --git a/components/camel-hipchat/src/test/resources/org/apache/camel/component/hipchat/HipchatXmlDefinedComponentProducerTest-route.xml b/components/camel-hipchat/src/test/resources/org/apache/camel/component/hipchat/HipchatXmlDefinedComponentProducerTest-route.xml
deleted file mode 100644
index cf1e827..0000000
--- a/components/camel-hipchat/src/test/resources/org/apache/camel/component/hipchat/HipchatXmlDefinedComponentProducerTest-route.xml
+++ /dev/null
@@ -1,30 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!--
-
- Licensed to the Apache Software Foundation (ASF) under one or more
- contributor license agreements. See the NOTICE file distributed with
- this work for additional information regarding copyright ownership.
- The ASF 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
-
- http://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.
-
--->
-<routes xmlns="http://camel.apache.org/schema/spring"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xsi:schemaLocation="http://camel.apache.org/schema/spring
- http://camel.apache.org/schema/spring/camel-spring.xsd">
-
- <route id="hipchatTest">
- <from uri="direct://foo"/>
- <to id="hipchat" uri="hipchat:https:foobar.com:443?authToken=abc123"/>
- </route>
-
-</routes>
\ No newline at end of file
diff --git a/components/pom.xml b/components/pom.xml
index 2773f07..f6eb73a 100644
--- a/components/pom.xml
+++ b/components/pom.xml
@@ -223,7 +223,6 @@
<module>camel-hbase</module>
<module>camel-hdfs</module>
<module>camel-headersmap</module>
- <module>camel-hipchat</module>
<module>camel-hl7</module>
<module>camel-ical</module>
<module>camel-iec60870</module>