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:47 UTC
[camel] branch master updated (9bd1bd6 -> cbcdba6)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git.
from 9bd1bd6 CAMEL-15686: Added unit test
new 570d861 CAMEL-15684 - Remove Camel-Hipchat
new 7defc45 CAMEL-15684 - Removed camel-hipchat from parent pom
new dc65bff CAMEL-15684 - Removed camel-hipchat from kit
new d7191bc CAMEL-15684 - Removed camel-hipchat from allcomponents
new abf12cd CAMEL-15684 - Removed Camel-hipchat from component and endpoint DSL
new bfd9ef3 CAMEL-15684 - Removed camel-hipchat
new b8fc89a CAMEL-15684 - Removed camel-hipchat
new cbcdba6 CAMEL-15684 - Removed ref to camel-hipchat
The 8 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
apache-camel/src/main/descriptors/common-bin.xml | 1 -
bom/camel-bom/pom.xml | 5 -
.../org/apache/camel/catalog/components.properties | 1 -
.../apache/camel/catalog/components/hipchat.json | 59 --
.../org/apache/camel/catalog/docs.properties | 1 -
.../camel/catalog/docs/hipchat-component.adoc | 246 -----
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/components-init-work-in-progress.md | 1 -
components/pom.xml | 1 -
core/camel-allcomponents/pom.xml | 4 -
.../component/ComponentsBuilderFactory.java | 13 +-
.../dsl/HipchatComponentBuilderFactory.java | 130 ---
.../src/generated/resources/metadata.json | 22 -
.../builder/endpoint/StaticEndpointBuilders.java | 57 +-
.../dsl/HipchatEndpointBuilderFactory.java | 1074 --------------------
docs/components/modules/ROOT/nav.adoc | 1 -
.../modules/ROOT/pages/hipchat-component.adoc | 248 -----
parent/pom.xml | 5 -
48 files changed, 2 insertions(+), 4357 deletions(-)
delete mode 100644 catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/hipchat.json
delete mode 100644 catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/hipchat-component.adoc
delete mode 100644 components/camel-hipchat/pom.xml
delete mode 100644 components/camel-hipchat/src/generated/java/org/apache/camel/component/hipchat/HipchatComponentConfigurer.java
delete mode 100644 components/camel-hipchat/src/generated/java/org/apache/camel/component/hipchat/HipchatEndpointConfigurer.java
delete mode 100644 components/camel-hipchat/src/generated/java/org/apache/camel/component/hipchat/HipchatEndpointUriFactory.java
delete mode 100644 components/camel-hipchat/src/generated/resources/META-INF/services/org/apache/camel/component.properties
delete mode 100644 components/camel-hipchat/src/generated/resources/META-INF/services/org/apache/camel/component/hipchat
delete mode 100644 components/camel-hipchat/src/generated/resources/META-INF/services/org/apache/camel/configurer/hipchat-component
delete mode 100644 components/camel-hipchat/src/generated/resources/META-INF/services/org/apache/camel/configurer/hipchat-endpoint
delete mode 100644 components/camel-hipchat/src/generated/resources/META-INF/services/org/apache/camel/urifactory/hipchat-endpoint
delete mode 100644 components/camel-hipchat/src/generated/resources/org/apache/camel/component/hipchat/hipchat.json
delete mode 100644 components/camel-hipchat/src/main/docs/hipchat-component.adoc
delete mode 100644 components/camel-hipchat/src/main/java/org/apache/camel/component/hipchat/HipchatApiConstants.java
delete mode 100644 components/camel-hipchat/src/main/java/org/apache/camel/component/hipchat/HipchatComponent.java
delete mode 100644 components/camel-hipchat/src/main/java/org/apache/camel/component/hipchat/HipchatConfiguration.java
delete mode 100644 components/camel-hipchat/src/main/java/org/apache/camel/component/hipchat/HipchatConstants.java
delete mode 100644 components/camel-hipchat/src/main/java/org/apache/camel/component/hipchat/HipchatConsumer.java
delete mode 100644 components/camel-hipchat/src/main/java/org/apache/camel/component/hipchat/HipchatEndpoint.java
delete mode 100644 components/camel-hipchat/src/main/java/org/apache/camel/component/hipchat/HipchatException.java
delete mode 100644 components/camel-hipchat/src/main/java/org/apache/camel/component/hipchat/HipchatProducer.java
delete mode 100644 components/camel-hipchat/src/test/java/org/apache/camel/component/hipchat/HipchatComponentConsumerTest.java
delete mode 100644 components/camel-hipchat/src/test/java/org/apache/camel/component/hipchat/HipchatComponentCustomHttpClientTest.java
delete mode 100644 components/camel-hipchat/src/test/java/org/apache/camel/component/hipchat/HipchatComponentMultipleUsersTest.java
delete mode 100644 components/camel-hipchat/src/test/java/org/apache/camel/component/hipchat/HipchatComponentProducerTest.java
delete mode 100644 components/camel-hipchat/src/test/java/org/apache/camel/component/hipchat/HipchatEPSuccessTestSupport.java
delete mode 100644 components/camel-hipchat/src/test/java/org/apache/camel/component/hipchat/HipchatEndpointTest.java
delete mode 100644 components/camel-hipchat/src/test/java/org/apache/camel/component/hipchat/HipchatTestComponent.java
delete mode 100644 components/camel-hipchat/src/test/java/org/apache/camel/component/hipchat/HipchatXmlDefinedComponentProducerTest.java
delete mode 100644 components/camel-hipchat/src/test/java/org/apache/camel/component/hipchat/integration/HipchatConsumerIntegrationTest.java
delete mode 100644 components/camel-hipchat/src/test/java/org/apache/camel/component/hipchat/integration/HipchatProducerIntegrationTest.java
delete mode 100644 components/camel-hipchat/src/test/resources/log4j2.properties
delete mode 100644 components/camel-hipchat/src/test/resources/org/apache/camel/component/hipchat/HipchatXmlDefinedComponentProducerTest-route.xml
delete mode 100644 core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/HipchatComponentBuilderFactory.java
delete mode 100644 core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/HipchatEndpointBuilderFactory.java
delete mode 100644 docs/components/modules/ROOT/pages/hipchat-component.adoc
[camel] 07/08: CAMEL-15684 - Removed camel-hipchat
Posted by ac...@apache.org.
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 b8fc89aa3074671569018ef9ad9b2cc9f7a648c9
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Oct 14 10:32:12 2020 +0200
CAMEL-15684 - Removed camel-hipchat
---
.../src/generated/resources/metadata.json | 22 ----------------------
1 file changed, 22 deletions(-)
diff --git a/core/camel-componentdsl/src/generated/resources/metadata.json b/core/camel-componentdsl/src/generated/resources/metadata.json
index 3345b01..8d38fc3 100644
--- a/core/camel-componentdsl/src/generated/resources/metadata.json
+++ b/core/camel-componentdsl/src/generated/resources/metadata.json
@@ -3611,28 +3611,6 @@
"producerOnly": false,
"lenientProperties": false
},
- "HipchatComponentBuilderFactory": {
- "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
- },
"HttpComponentBuilderFactory": {
"kind": "component",
"name": "http",
[camel] 05/08: CAMEL-15684 - Removed Camel-hipchat from component
and endpoint DSL
Posted by ac...@apache.org.
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 abf12cd3df0885405cd5e2d82b796cd23a9e218b
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Oct 14 10:13:51 2020 +0200
CAMEL-15684 - Removed Camel-hipchat from component and endpoint DSL
---
.../component/ComponentsBuilderFactory.java | 13 +-
.../dsl/HipchatComponentBuilderFactory.java | 130 ---
.../builder/endpoint/StaticEndpointBuilders.java | 57 +-
.../dsl/HipchatEndpointBuilderFactory.java | 1074 --------------------
4 files changed, 2 insertions(+), 1272 deletions(-)
diff --git a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/ComponentsBuilderFactory.java b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/ComponentsBuilderFactory.java
index da13164..556886c 100644
--- a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/ComponentsBuilderFactory.java
+++ b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/ComponentsBuilderFactory.java
@@ -1861,17 +1861,6 @@ public interface ComponentsBuilderFactory {
return org.apache.camel.builder.component.dsl.HdfsComponentBuilderFactory.hdfs();
}
/**
- * Hipchat (camel-hipchat)
- * Send and receive messages to/from Hipchat service.
- *
- * Category: api,chat,cloud
- * Since: 2.15
- * Maven coordinates: org.apache.camel:camel-hipchat
- */
- static org.apache.camel.builder.component.dsl.HipchatComponentBuilderFactory.HipchatComponentBuilder hipchat() {
- return org.apache.camel.builder.component.dsl.HipchatComponentBuilderFactory.hipchat();
- }
- /**
* HTTP (camel-http)
* Send requests to external HTTP servers using Apache HTTP Client 4.x.
*
@@ -4070,4 +4059,4 @@ public interface ComponentsBuilderFactory {
static org.apache.camel.builder.component.dsl.ZookeeperMasterComponentBuilderFactory.ZookeeperMasterComponentBuilder zookeeperMaster() {
return org.apache.camel.builder.component.dsl.ZookeeperMasterComponentBuilderFactory.zookeeperMaster();
}
-}
\ No newline at end of file
+}
diff --git a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/HipchatComponentBuilderFactory.java b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/HipchatComponentBuilderFactory.java
deleted file mode 100644
index 2559526..0000000
--- a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/HipchatComponentBuilderFactory.java
+++ /dev/null
@@ -1,130 +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.builder.component.dsl;
-
-import javax.annotation.Generated;
-import org.apache.camel.Component;
-import org.apache.camel.builder.component.AbstractComponentBuilder;
-import org.apache.camel.builder.component.ComponentBuilder;
-import org.apache.camel.component.hipchat.HipchatComponent;
-
-/**
- * Send and receive messages to/from Hipchat service.
- *
- * Generated by camel-package-maven-plugin - do not edit this file!
- */
-@Generated("org.apache.camel.maven.packaging.ComponentDslMojo")
-public interface HipchatComponentBuilderFactory {
-
- /**
- * Hipchat (camel-hipchat)
- * Send and receive messages to/from Hipchat service.
- *
- * Category: api,chat,cloud
- * Since: 2.15
- * Maven coordinates: org.apache.camel:camel-hipchat
- */
- static HipchatComponentBuilder hipchat() {
- return new HipchatComponentBuilderImpl();
- }
-
- /**
- * Builder for the Hipchat component.
- */
- interface HipchatComponentBuilder
- extends
- ComponentBuilder<HipchatComponent> {
- /**
- * 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.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: consumer
- */
- default HipchatComponentBuilder bridgeErrorHandler(
- boolean bridgeErrorHandler) {
- doSetProperty("bridgeErrorHandler", bridgeErrorHandler);
- return this;
- }
- /**
- * 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 starting the
- * producer may take a little time and prolong the total processing time
- * of the processing.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: producer
- */
- default HipchatComponentBuilder lazyStartProducer(
- boolean lazyStartProducer) {
- doSetProperty("lazyStartProducer", lazyStartProducer);
- return this;
- }
- /**
- * Whether the component should use basic property binding (Camel 2.x)
- * or the newer property binding with additional capabilities.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: advanced
- */
- @Deprecated
- default HipchatComponentBuilder basicPropertyBinding(
- boolean basicPropertyBinding) {
- doSetProperty("basicPropertyBinding", basicPropertyBinding);
- return this;
- }
- }
-
- class HipchatComponentBuilderImpl
- extends
- AbstractComponentBuilder<HipchatComponent>
- implements
- HipchatComponentBuilder {
- @Override
- protected HipchatComponent buildConcreteComponent() {
- return new HipchatComponent();
- }
- @Override
- protected boolean setPropertyOnComponent(
- Component component,
- String name,
- Object value) {
- switch (name) {
- case "bridgeErrorHandler": ((HipchatComponent) component).setBridgeErrorHandler((boolean) value); return true;
- case "lazyStartProducer": ((HipchatComponent) component).setLazyStartProducer((boolean) value); return true;
- case "basicPropertyBinding": ((HipchatComponent) component).setBasicPropertyBinding((boolean) value); return true;
- default: return false;
- }
- }
- }
-}
\ No newline at end of file
diff --git a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java
index 5d50e4a..9f933a1 100644
--- a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java
+++ b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java
@@ -7140,61 +7140,6 @@ public class StaticEndpointBuilders {
return org.apache.camel.builder.endpoint.dsl.HdfsEndpointBuilderFactory.endpointBuilder(componentName, path);
}
/**
- * Hipchat (camel-hipchat)
- * Send and receive messages to/from Hipchat service.
- *
- * Category: api,chat,cloud
- * Since: 2.15
- * Maven coordinates: org.apache.camel:camel-hipchat
- *
- * Syntax: <code>hipchat:protocol:host:port</code>
- *
- * Path parameter: protocol (required)
- * The protocol for the hipchat server, such as http.
- *
- * Path parameter: host (required)
- * The host for the hipchat server, such as api.hipchat.com
- *
- * Path parameter: port
- * The port for the hipchat server. Is by default 80.
- * Default value: 80
- *
- * @param path protocol:host:port
- */
- public static org.apache.camel.builder.endpoint.dsl.HipchatEndpointBuilderFactory.HipchatEndpointBuilder hipchat(
- String path) {
- return org.apache.camel.builder.endpoint.dsl.HipchatEndpointBuilderFactory.endpointBuilder("hipchat", path);
- }
- /**
- * Hipchat (camel-hipchat)
- * Send and receive messages to/from Hipchat service.
- *
- * Category: api,chat,cloud
- * Since: 2.15
- * Maven coordinates: org.apache.camel:camel-hipchat
- *
- * Syntax: <code>hipchat:protocol:host:port</code>
- *
- * Path parameter: protocol (required)
- * The protocol for the hipchat server, such as http.
- *
- * Path parameter: host (required)
- * The host for the hipchat server, such as api.hipchat.com
- *
- * Path parameter: port
- * The port for the hipchat server. Is by default 80.
- * Default value: 80
- *
- * @param componentName to use a custom component name for the endpoint
- * instead of the default name
- * @param path protocol:host:port
- */
- public static org.apache.camel.builder.endpoint.dsl.HipchatEndpointBuilderFactory.HipchatEndpointBuilder hipchat(
- String componentName,
- String path) {
- return org.apache.camel.builder.endpoint.dsl.HipchatEndpointBuilderFactory.endpointBuilder(componentName, path);
- }
- /**
* HTTP (camel-http)
* Send requests to external HTTP servers using Apache HTTP Client 4.x.
*
@@ -16138,4 +16083,4 @@ public class StaticEndpointBuilders {
return org.apache.camel.builder.endpoint.dsl.ZooKeeperMasterEndpointBuilderFactory.endpointBuilder(componentName, path);
}
}
-//CHECKSTYLE:ON
\ No newline at end of file
+//CHECKSTYLE:ON
diff --git a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/HipchatEndpointBuilderFactory.java b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/HipchatEndpointBuilderFactory.java
deleted file mode 100644
index ca68b74..0000000
--- a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/HipchatEndpointBuilderFactory.java
+++ /dev/null
@@ -1,1074 +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.builder.endpoint.dsl;
-
-import java.util.Map;
-import java.util.concurrent.ScheduledExecutorService;
-import java.util.concurrent.TimeUnit;
-import javax.annotation.Generated;
-import org.apache.camel.ExchangePattern;
-import org.apache.camel.LoggingLevel;
-import org.apache.camel.builder.EndpointConsumerBuilder;
-import org.apache.camel.builder.EndpointProducerBuilder;
-import org.apache.camel.builder.endpoint.AbstractEndpointBuilder;
-import org.apache.camel.spi.ExceptionHandler;
-import org.apache.camel.spi.PollingConsumerPollStrategy;
-
-/**
- * Send and receive messages to/from Hipchat service.
- *
- * Generated by camel build tools - do NOT edit this file!
- */
-@Generated("org.apache.camel.maven.packaging.EndpointDslMojo")
-public interface HipchatEndpointBuilderFactory {
-
-
- /**
- * Builder for endpoint consumers for the Hipchat component.
- */
- public interface HipchatEndpointConsumerBuilder
- extends
- EndpointConsumerBuilder {
- default AdvancedHipchatEndpointConsumerBuilder advanced() {
- return (AdvancedHipchatEndpointConsumerBuilder) this;
- }
- /**
- * OAuth 2 auth token.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: common
- */
- default HipchatEndpointConsumerBuilder authToken(String authToken) {
- doSetProperty("authToken", authToken);
- return this;
- }
- /**
- * Username(s) when consuming messages from the hiptchat server.
- * Multiple user names can be separated by comma.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: common
- */
- default HipchatEndpointConsumerBuilder consumeUsers(String consumeUsers) {
- doSetProperty("consumeUsers", consumeUsers);
- return this;
- }
- /**
- * The CloseableHttpClient reference from registry to be used during API
- * HTTP requests.
- *
- * The option is a:
- * <code>org.apache.http.impl.client.CloseableHttpClient</code> type.
- *
- * Default: CloseableHttpClient default from HttpClient library
- * Group: common
- */
- default HipchatEndpointConsumerBuilder httpClient(Object httpClient) {
- doSetProperty("httpClient", httpClient);
- return this;
- }
- /**
- * The CloseableHttpClient reference from registry to be used during API
- * HTTP requests.
- *
- * The option will be converted to a
- * <code>org.apache.http.impl.client.CloseableHttpClient</code> type.
- *
- * Default: CloseableHttpClient default from HttpClient library
- * Group: common
- */
- default HipchatEndpointConsumerBuilder httpClient(String httpClient) {
- doSetProperty("httpClient", httpClient);
- return this;
- }
- /**
- * 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.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: consumer
- */
- default HipchatEndpointConsumerBuilder bridgeErrorHandler(
- boolean bridgeErrorHandler) {
- doSetProperty("bridgeErrorHandler", bridgeErrorHandler);
- return this;
- }
- /**
- * 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.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Default: false
- * Group: consumer
- */
- default HipchatEndpointConsumerBuilder bridgeErrorHandler(
- String bridgeErrorHandler) {
- doSetProperty("bridgeErrorHandler", bridgeErrorHandler);
- return this;
- }
- /**
- * If the polling consumer did not poll any files, you can enable this
- * option to send an empty message (no body) instead.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: consumer
- */
- default HipchatEndpointConsumerBuilder sendEmptyMessageWhenIdle(
- boolean sendEmptyMessageWhenIdle) {
- doSetProperty("sendEmptyMessageWhenIdle", sendEmptyMessageWhenIdle);
- return this;
- }
- /**
- * If the polling consumer did not poll any files, you can enable this
- * option to send an empty message (no body) instead.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Default: false
- * Group: consumer
- */
- default HipchatEndpointConsumerBuilder sendEmptyMessageWhenIdle(
- String sendEmptyMessageWhenIdle) {
- doSetProperty("sendEmptyMessageWhenIdle", sendEmptyMessageWhenIdle);
- return this;
- }
- /**
- * The number of subsequent error polls (failed due some error) that
- * should happen before the backoffMultipler should kick-in.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: scheduler
- */
- default HipchatEndpointConsumerBuilder backoffErrorThreshold(
- int backoffErrorThreshold) {
- doSetProperty("backoffErrorThreshold", backoffErrorThreshold);
- return this;
- }
- /**
- * The number of subsequent error polls (failed due some error) that
- * should happen before the backoffMultipler should kick-in.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: scheduler
- */
- default HipchatEndpointConsumerBuilder backoffErrorThreshold(
- String backoffErrorThreshold) {
- doSetProperty("backoffErrorThreshold", backoffErrorThreshold);
- return this;
- }
- /**
- * The number of subsequent idle polls that should happen before the
- * backoffMultipler should kick-in.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: scheduler
- */
- default HipchatEndpointConsumerBuilder backoffIdleThreshold(
- int backoffIdleThreshold) {
- doSetProperty("backoffIdleThreshold", backoffIdleThreshold);
- return this;
- }
- /**
- * The number of subsequent idle polls that should happen before the
- * backoffMultipler should kick-in.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: scheduler
- */
- default HipchatEndpointConsumerBuilder backoffIdleThreshold(
- String backoffIdleThreshold) {
- doSetProperty("backoffIdleThreshold", backoffIdleThreshold);
- return this;
- }
- /**
- * 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.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: scheduler
- */
- default HipchatEndpointConsumerBuilder backoffMultiplier(
- int backoffMultiplier) {
- doSetProperty("backoffMultiplier", backoffMultiplier);
- return this;
- }
- /**
- * 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.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: scheduler
- */
- default HipchatEndpointConsumerBuilder backoffMultiplier(
- String backoffMultiplier) {
- doSetProperty("backoffMultiplier", backoffMultiplier);
- return this;
- }
- /**
- * Milliseconds before the next poll.
- *
- * The option is a: <code>long</code> type.
- *
- * Default: 5000
- * Group: scheduler
- */
- default HipchatEndpointConsumerBuilder delay(long delay) {
- doSetProperty("delay", delay);
- return this;
- }
- /**
- * Milliseconds before the next poll.
- *
- * The option will be converted to a <code>long</code> type.
- *
- * Default: 5000
- * Group: scheduler
- */
- default HipchatEndpointConsumerBuilder delay(String delay) {
- doSetProperty("delay", delay);
- return this;
- }
- /**
- * If greedy is enabled, then the ScheduledPollConsumer will run
- * immediately again, if the previous run polled 1 or more messages.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: scheduler
- */
- default HipchatEndpointConsumerBuilder greedy(boolean greedy) {
- doSetProperty("greedy", greedy);
- return this;
- }
- /**
- * If greedy is enabled, then the ScheduledPollConsumer will run
- * immediately again, if the previous run polled 1 or more messages.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Default: false
- * Group: scheduler
- */
- default HipchatEndpointConsumerBuilder greedy(String greedy) {
- doSetProperty("greedy", greedy);
- return this;
- }
- /**
- * Milliseconds before the first poll starts.
- *
- * The option is a: <code>long</code> type.
- *
- * Default: 1000
- * Group: scheduler
- */
- default HipchatEndpointConsumerBuilder initialDelay(long initialDelay) {
- doSetProperty("initialDelay", initialDelay);
- return this;
- }
- /**
- * Milliseconds before the first poll starts.
- *
- * The option will be converted to a <code>long</code> type.
- *
- * Default: 1000
- * Group: scheduler
- */
- default HipchatEndpointConsumerBuilder initialDelay(String initialDelay) {
- doSetProperty("initialDelay", initialDelay);
- return this;
- }
- /**
- * 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.
- *
- * The option is a: <code>long</code> type.
- *
- * Default: 0
- * Group: scheduler
- */
- default HipchatEndpointConsumerBuilder repeatCount(long repeatCount) {
- doSetProperty("repeatCount", repeatCount);
- return this;
- }
- /**
- * 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.
- *
- * The option will be converted to a <code>long</code> type.
- *
- * Default: 0
- * Group: scheduler
- */
- default HipchatEndpointConsumerBuilder repeatCount(String repeatCount) {
- doSetProperty("repeatCount", repeatCount);
- return this;
- }
- /**
- * The consumer logs a start/complete log line when it polls. This
- * option allows you to configure the logging level for that.
- *
- * The option is a: <code>org.apache.camel.LoggingLevel</code> type.
- *
- * Default: TRACE
- * Group: scheduler
- */
- default HipchatEndpointConsumerBuilder runLoggingLevel(
- LoggingLevel runLoggingLevel) {
- doSetProperty("runLoggingLevel", runLoggingLevel);
- return this;
- }
- /**
- * The consumer logs a start/complete log line when it polls. This
- * option allows you to configure the logging level for that.
- *
- * The option will be converted to a
- * <code>org.apache.camel.LoggingLevel</code> type.
- *
- * Default: TRACE
- * Group: scheduler
- */
- default HipchatEndpointConsumerBuilder runLoggingLevel(
- String runLoggingLevel) {
- doSetProperty("runLoggingLevel", runLoggingLevel);
- return this;
- }
- /**
- * Allows for configuring a custom/shared thread pool to use for the
- * consumer. By default each consumer has its own single threaded thread
- * pool.
- *
- * The option is a:
- * <code>java.util.concurrent.ScheduledExecutorService</code> type.
- *
- * Group: scheduler
- */
- default HipchatEndpointConsumerBuilder scheduledExecutorService(
- ScheduledExecutorService scheduledExecutorService) {
- doSetProperty("scheduledExecutorService", scheduledExecutorService);
- return this;
- }
- /**
- * Allows for configuring a custom/shared thread pool to use for the
- * consumer. By default each consumer has its own single threaded thread
- * pool.
- *
- * The option will be converted to a
- * <code>java.util.concurrent.ScheduledExecutorService</code> type.
- *
- * Group: scheduler
- */
- default HipchatEndpointConsumerBuilder scheduledExecutorService(
- String scheduledExecutorService) {
- doSetProperty("scheduledExecutorService", scheduledExecutorService);
- return this;
- }
- /**
- * To use a cron scheduler from either camel-spring or camel-quartz
- * component. Use value spring or quartz for built in scheduler.
- *
- * The option is a: <code>java.lang.Object</code> type.
- *
- * Default: none
- * Group: scheduler
- */
- default HipchatEndpointConsumerBuilder scheduler(Object scheduler) {
- doSetProperty("scheduler", scheduler);
- return this;
- }
- /**
- * To use a cron scheduler from either camel-spring or camel-quartz
- * component. Use value spring or quartz for built in scheduler.
- *
- * The option will be converted to a <code>java.lang.Object</code> type.
- *
- * Default: none
- * Group: scheduler
- */
- default HipchatEndpointConsumerBuilder scheduler(String scheduler) {
- doSetProperty("scheduler", scheduler);
- return this;
- }
- /**
- * To configure additional properties when using a custom scheduler or
- * any of the Quartz, Spring based scheduler.
- *
- * The option is a: <code>java.util.Map<java.lang.String,
- * java.lang.Object></code> type.
- * The option is multivalued, and you can use the
- * schedulerProperties(String, Object) method to add a value (call the
- * method multiple times to set more values).
- *
- * Group: scheduler
- */
- default HipchatEndpointConsumerBuilder schedulerProperties(
- String key,
- Object value) {
- doSetMultiValueProperty("schedulerProperties", "scheduler." + key, value);
- return this;
- }
- /**
- * To configure additional properties when using a custom scheduler or
- * any of the Quartz, Spring based scheduler.
- *
- * The option is a: <code>java.util.Map<java.lang.String,
- * java.lang.Object></code> type.
- * The option is multivalued, and you can use the
- * schedulerProperties(String, Object) method to add a value (call the
- * method multiple times to set more values).
- *
- * Group: scheduler
- */
- default HipchatEndpointConsumerBuilder schedulerProperties(Map values) {
- doSetMultiValueProperties("schedulerProperties", "scheduler.", values);
- return this;
- }
- /**
- * Whether the scheduler should be auto started.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: true
- * Group: scheduler
- */
- default HipchatEndpointConsumerBuilder startScheduler(
- boolean startScheduler) {
- doSetProperty("startScheduler", startScheduler);
- return this;
- }
- /**
- * Whether the scheduler should be auto started.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Default: true
- * Group: scheduler
- */
- default HipchatEndpointConsumerBuilder startScheduler(
- String startScheduler) {
- doSetProperty("startScheduler", startScheduler);
- return this;
- }
- /**
- * Time unit for initialDelay and delay options.
- *
- * The option is a: <code>java.util.concurrent.TimeUnit</code> type.
- *
- * Default: MILLISECONDS
- * Group: scheduler
- */
- default HipchatEndpointConsumerBuilder timeUnit(TimeUnit timeUnit) {
- doSetProperty("timeUnit", timeUnit);
- return this;
- }
- /**
- * Time unit for initialDelay and delay options.
- *
- * The option will be converted to a
- * <code>java.util.concurrent.TimeUnit</code> type.
- *
- * Default: MILLISECONDS
- * Group: scheduler
- */
- default HipchatEndpointConsumerBuilder timeUnit(String timeUnit) {
- doSetProperty("timeUnit", timeUnit);
- return this;
- }
- /**
- * Controls if fixed delay or fixed rate is used. See
- * ScheduledExecutorService in JDK for details.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: true
- * Group: scheduler
- */
- default HipchatEndpointConsumerBuilder useFixedDelay(
- boolean useFixedDelay) {
- doSetProperty("useFixedDelay", useFixedDelay);
- return this;
- }
- /**
- * Controls if fixed delay or fixed rate is used. See
- * ScheduledExecutorService in JDK for details.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Default: true
- * Group: scheduler
- */
- default HipchatEndpointConsumerBuilder useFixedDelay(
- String useFixedDelay) {
- doSetProperty("useFixedDelay", useFixedDelay);
- return this;
- }
- }
-
- /**
- * Advanced builder for endpoint consumers for the Hipchat component.
- */
- public interface AdvancedHipchatEndpointConsumerBuilder
- extends
- EndpointConsumerBuilder {
- default HipchatEndpointConsumerBuilder basic() {
- return (HipchatEndpointConsumerBuilder) this;
- }
- /**
- * 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.
- *
- * The option is a: <code>org.apache.camel.spi.ExceptionHandler</code>
- * type.
- *
- * Group: consumer (advanced)
- */
- default AdvancedHipchatEndpointConsumerBuilder exceptionHandler(
- ExceptionHandler exceptionHandler) {
- doSetProperty("exceptionHandler", exceptionHandler);
- return this;
- }
- /**
- * 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.
- *
- * The option will be converted to a
- * <code>org.apache.camel.spi.ExceptionHandler</code> type.
- *
- * Group: consumer (advanced)
- */
- default AdvancedHipchatEndpointConsumerBuilder exceptionHandler(
- String exceptionHandler) {
- doSetProperty("exceptionHandler", exceptionHandler);
- return this;
- }
- /**
- * Sets the exchange pattern when the consumer creates an exchange.
- *
- * The option is a: <code>org.apache.camel.ExchangePattern</code> type.
- *
- * Group: consumer (advanced)
- */
- default AdvancedHipchatEndpointConsumerBuilder exchangePattern(
- ExchangePattern exchangePattern) {
- doSetProperty("exchangePattern", exchangePattern);
- return this;
- }
- /**
- * Sets the exchange pattern when the consumer creates an exchange.
- *
- * The option will be converted to a
- * <code>org.apache.camel.ExchangePattern</code> type.
- *
- * Group: consumer (advanced)
- */
- default AdvancedHipchatEndpointConsumerBuilder exchangePattern(
- String exchangePattern) {
- doSetProperty("exchangePattern", exchangePattern);
- return this;
- }
- /**
- * 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.
- *
- * The option is a:
- * <code>org.apache.camel.spi.PollingConsumerPollStrategy</code> type.
- *
- * Group: consumer (advanced)
- */
- default AdvancedHipchatEndpointConsumerBuilder pollStrategy(
- PollingConsumerPollStrategy pollStrategy) {
- doSetProperty("pollStrategy", pollStrategy);
- return this;
- }
- /**
- * 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.
- *
- * The option will be converted to a
- * <code>org.apache.camel.spi.PollingConsumerPollStrategy</code> type.
- *
- * Group: consumer (advanced)
- */
- default AdvancedHipchatEndpointConsumerBuilder pollStrategy(
- String pollStrategy) {
- doSetProperty("pollStrategy", pollStrategy);
- return this;
- }
- /**
- * Whether the endpoint should use basic property binding (Camel 2.x) or
- * the newer property binding with additional capabilities.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: advanced
- */
- default AdvancedHipchatEndpointConsumerBuilder basicPropertyBinding(
- boolean basicPropertyBinding) {
- doSetProperty("basicPropertyBinding", basicPropertyBinding);
- return this;
- }
- /**
- * Whether the endpoint should use basic property binding (Camel 2.x) or
- * the newer property binding with additional capabilities.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Default: false
- * Group: advanced
- */
- default AdvancedHipchatEndpointConsumerBuilder basicPropertyBinding(
- String basicPropertyBinding) {
- doSetProperty("basicPropertyBinding", basicPropertyBinding);
- return this;
- }
- /**
- * Sets whether synchronous processing should be strictly used, or Camel
- * is allowed to use asynchronous processing (if supported).
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: advanced
- */
- default AdvancedHipchatEndpointConsumerBuilder synchronous(
- boolean synchronous) {
- doSetProperty("synchronous", synchronous);
- return this;
- }
- /**
- * Sets whether synchronous processing should be strictly used, or Camel
- * is allowed to use asynchronous processing (if supported).
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Default: false
- * Group: advanced
- */
- default AdvancedHipchatEndpointConsumerBuilder synchronous(
- String synchronous) {
- doSetProperty("synchronous", synchronous);
- return this;
- }
- }
-
- /**
- * Builder for endpoint producers for the Hipchat component.
- */
- public interface HipchatEndpointProducerBuilder
- extends
- EndpointProducerBuilder {
- default AdvancedHipchatEndpointProducerBuilder advanced() {
- return (AdvancedHipchatEndpointProducerBuilder) this;
- }
- /**
- * OAuth 2 auth token.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: common
- */
- default HipchatEndpointProducerBuilder authToken(String authToken) {
- doSetProperty("authToken", authToken);
- return this;
- }
- /**
- * Username(s) when consuming messages from the hiptchat server.
- * Multiple user names can be separated by comma.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: common
- */
- default HipchatEndpointProducerBuilder consumeUsers(String consumeUsers) {
- doSetProperty("consumeUsers", consumeUsers);
- return this;
- }
- /**
- * The CloseableHttpClient reference from registry to be used during API
- * HTTP requests.
- *
- * The option is a:
- * <code>org.apache.http.impl.client.CloseableHttpClient</code> type.
- *
- * Default: CloseableHttpClient default from HttpClient library
- * Group: common
- */
- default HipchatEndpointProducerBuilder httpClient(Object httpClient) {
- doSetProperty("httpClient", httpClient);
- return this;
- }
- /**
- * The CloseableHttpClient reference from registry to be used during API
- * HTTP requests.
- *
- * The option will be converted to a
- * <code>org.apache.http.impl.client.CloseableHttpClient</code> type.
- *
- * Default: CloseableHttpClient default from HttpClient library
- * Group: common
- */
- default HipchatEndpointProducerBuilder httpClient(String httpClient) {
- doSetProperty("httpClient", httpClient);
- return this;
- }
- /**
- * 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 starting the
- * producer may take a little time and prolong the total processing time
- * of the processing.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: producer
- */
- default HipchatEndpointProducerBuilder lazyStartProducer(
- boolean lazyStartProducer) {
- doSetProperty("lazyStartProducer", lazyStartProducer);
- return this;
- }
- /**
- * 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 starting the
- * producer may take a little time and prolong the total processing time
- * of the processing.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Default: false
- * Group: producer
- */
- default HipchatEndpointProducerBuilder lazyStartProducer(
- String lazyStartProducer) {
- doSetProperty("lazyStartProducer", lazyStartProducer);
- return this;
- }
- }
-
- /**
- * Advanced builder for endpoint producers for the Hipchat component.
- */
- public interface AdvancedHipchatEndpointProducerBuilder
- extends
- EndpointProducerBuilder {
- default HipchatEndpointProducerBuilder basic() {
- return (HipchatEndpointProducerBuilder) this;
- }
- /**
- * Whether the endpoint should use basic property binding (Camel 2.x) or
- * the newer property binding with additional capabilities.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: advanced
- */
- default AdvancedHipchatEndpointProducerBuilder basicPropertyBinding(
- boolean basicPropertyBinding) {
- doSetProperty("basicPropertyBinding", basicPropertyBinding);
- return this;
- }
- /**
- * Whether the endpoint should use basic property binding (Camel 2.x) or
- * the newer property binding with additional capabilities.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Default: false
- * Group: advanced
- */
- default AdvancedHipchatEndpointProducerBuilder basicPropertyBinding(
- String basicPropertyBinding) {
- doSetProperty("basicPropertyBinding", basicPropertyBinding);
- return this;
- }
- /**
- * Sets whether synchronous processing should be strictly used, or Camel
- * is allowed to use asynchronous processing (if supported).
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: advanced
- */
- default AdvancedHipchatEndpointProducerBuilder synchronous(
- boolean synchronous) {
- doSetProperty("synchronous", synchronous);
- return this;
- }
- /**
- * Sets whether synchronous processing should be strictly used, or Camel
- * is allowed to use asynchronous processing (if supported).
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Default: false
- * Group: advanced
- */
- default AdvancedHipchatEndpointProducerBuilder synchronous(
- String synchronous) {
- doSetProperty("synchronous", synchronous);
- return this;
- }
- }
-
- /**
- * Builder for endpoint for the Hipchat component.
- */
- public interface HipchatEndpointBuilder
- extends
- HipchatEndpointConsumerBuilder,
- HipchatEndpointProducerBuilder {
- default AdvancedHipchatEndpointBuilder advanced() {
- return (AdvancedHipchatEndpointBuilder) this;
- }
- /**
- * OAuth 2 auth token.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: common
- */
- default HipchatEndpointBuilder authToken(String authToken) {
- doSetProperty("authToken", authToken);
- return this;
- }
- /**
- * Username(s) when consuming messages from the hiptchat server.
- * Multiple user names can be separated by comma.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: common
- */
- default HipchatEndpointBuilder consumeUsers(String consumeUsers) {
- doSetProperty("consumeUsers", consumeUsers);
- return this;
- }
- /**
- * The CloseableHttpClient reference from registry to be used during API
- * HTTP requests.
- *
- * The option is a:
- * <code>org.apache.http.impl.client.CloseableHttpClient</code> type.
- *
- * Default: CloseableHttpClient default from HttpClient library
- * Group: common
- */
- default HipchatEndpointBuilder httpClient(Object httpClient) {
- doSetProperty("httpClient", httpClient);
- return this;
- }
- /**
- * The CloseableHttpClient reference from registry to be used during API
- * HTTP requests.
- *
- * The option will be converted to a
- * <code>org.apache.http.impl.client.CloseableHttpClient</code> type.
- *
- * Default: CloseableHttpClient default from HttpClient library
- * Group: common
- */
- default HipchatEndpointBuilder httpClient(String httpClient) {
- doSetProperty("httpClient", httpClient);
- return this;
- }
- }
-
- /**
- * Advanced builder for endpoint for the Hipchat component.
- */
- public interface AdvancedHipchatEndpointBuilder
- extends
- AdvancedHipchatEndpointConsumerBuilder,
- AdvancedHipchatEndpointProducerBuilder {
- default HipchatEndpointBuilder basic() {
- return (HipchatEndpointBuilder) this;
- }
- /**
- * Whether the endpoint should use basic property binding (Camel 2.x) or
- * the newer property binding with additional capabilities.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: advanced
- */
- default AdvancedHipchatEndpointBuilder basicPropertyBinding(
- boolean basicPropertyBinding) {
- doSetProperty("basicPropertyBinding", basicPropertyBinding);
- return this;
- }
- /**
- * Whether the endpoint should use basic property binding (Camel 2.x) or
- * the newer property binding with additional capabilities.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Default: false
- * Group: advanced
- */
- default AdvancedHipchatEndpointBuilder basicPropertyBinding(
- String basicPropertyBinding) {
- doSetProperty("basicPropertyBinding", basicPropertyBinding);
- return this;
- }
- /**
- * Sets whether synchronous processing should be strictly used, or Camel
- * is allowed to use asynchronous processing (if supported).
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: advanced
- */
- default AdvancedHipchatEndpointBuilder synchronous(boolean synchronous) {
- doSetProperty("synchronous", synchronous);
- return this;
- }
- /**
- * Sets whether synchronous processing should be strictly used, or Camel
- * is allowed to use asynchronous processing (if supported).
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Default: false
- * Group: advanced
- */
- default AdvancedHipchatEndpointBuilder synchronous(String synchronous) {
- doSetProperty("synchronous", synchronous);
- return this;
- }
- }
-
- public interface HipchatBuilders {
- /**
- * Hipchat (camel-hipchat)
- * Send and receive messages to/from Hipchat service.
- *
- * Category: api,chat,cloud
- * Since: 2.15
- * Maven coordinates: org.apache.camel:camel-hipchat
- *
- * Syntax: <code>hipchat:protocol:host:port</code>
- *
- * Path parameter: protocol (required)
- * The protocol for the hipchat server, such as http.
- *
- * Path parameter: host (required)
- * The host for the hipchat server, such as api.hipchat.com
- *
- * Path parameter: port
- * The port for the hipchat server. Is by default 80.
- * Default value: 80
- *
- * @param path protocol:host:port
- */
- default HipchatEndpointBuilder hipchat(String path) {
- return HipchatEndpointBuilderFactory.endpointBuilder("hipchat", path);
- }
- /**
- * Hipchat (camel-hipchat)
- * Send and receive messages to/from Hipchat service.
- *
- * Category: api,chat,cloud
- * Since: 2.15
- * Maven coordinates: org.apache.camel:camel-hipchat
- *
- * Syntax: <code>hipchat:protocol:host:port</code>
- *
- * Path parameter: protocol (required)
- * The protocol for the hipchat server, such as http.
- *
- * Path parameter: host (required)
- * The host for the hipchat server, such as api.hipchat.com
- *
- * Path parameter: port
- * The port for the hipchat server. Is by default 80.
- * Default value: 80
- *
- * @param componentName to use a custom component name for the endpoint
- * instead of the default name
- * @param path protocol:host:port
- */
- default HipchatEndpointBuilder hipchat(String componentName, String path) {
- return HipchatEndpointBuilderFactory.endpointBuilder(componentName, path);
- }
- }
- static HipchatEndpointBuilder endpointBuilder(
- String componentName,
- String path) {
- class HipchatEndpointBuilderImpl extends AbstractEndpointBuilder implements HipchatEndpointBuilder, AdvancedHipchatEndpointBuilder {
- public HipchatEndpointBuilderImpl(String path) {
- super(componentName, path);
- }
- }
- return new HipchatEndpointBuilderImpl(path);
- }
-}
\ No newline at end of file
[camel] 04/08: CAMEL-15684 - Removed camel-hipchat from
allcomponents
Posted by ac...@apache.org.
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 d7191bca69a997fdf6110d3f6133affbfcc42438
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Oct 14 09:37:21 2020 +0200
CAMEL-15684 - Removed camel-hipchat from allcomponents
---
core/camel-allcomponents/pom.xml | 4 ----
1 file changed, 4 deletions(-)
diff --git a/core/camel-allcomponents/pom.xml b/core/camel-allcomponents/pom.xml
index ecf8daf..67c4b90 100644
--- a/core/camel-allcomponents/pom.xml
+++ b/core/camel-allcomponents/pom.xml
@@ -604,10 +604,6 @@
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
- <artifactId>camel-hipchat</artifactId>
- </dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
<artifactId>camel-hl7</artifactId>
</dependency>
<dependency>
[camel] 01/08: CAMEL-15684 - Remove Camel-Hipchat
Posted by ac...@apache.org.
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>
[camel] 06/08: CAMEL-15684 - Removed camel-hipchat
Posted by ac...@apache.org.
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 bfd9ef330ff67bba1875bac9a2332833fc487fd5
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Oct 14 10:31:25 2020 +0200
CAMEL-15684 - Removed camel-hipchat
---
.../org/apache/camel/catalog/components.properties | 1 -
.../apache/camel/catalog/components/hipchat.json | 59 -----
.../org/apache/camel/catalog/docs.properties | 1 -
.../camel/catalog/docs/hipchat-component.adoc | 246 --------------------
docs/components/modules/ROOT/nav.adoc | 1 -
.../modules/ROOT/pages/hipchat-component.adoc | 248 ---------------------
6 files changed, 556 deletions(-)
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components.properties b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components.properties
index e7eebaa..09c54a2 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components.properties
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components.properties
@@ -161,7 +161,6 @@ hazelcast-set
hazelcast-topic
hbase
hdfs
-hipchat
http
https
iec60870-client
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/hipchat.json b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/hipchat.json
deleted file mode 100644
index 872542f..0000000
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/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/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs.properties b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs.properties
index eeb7887..adb36cf 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs.properties
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs.properties
@@ -218,7 +218,6 @@ hbase-component
hdfs-component
header-language
headersmap
-hipchat-component
hl7-dataformat
hl7terser-language
http-component
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/hipchat-component.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/hipchat-component.adoc
deleted file mode 100644
index 7b53762..0000000
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/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/docs/components/modules/ROOT/nav.adoc b/docs/components/modules/ROOT/nav.adoc
index f5c3113..1fc770a 100644
--- a/docs/components/modules/ROOT/nav.adoc
+++ b/docs/components/modules/ROOT/nav.adoc
@@ -164,7 +164,6 @@
*** xref:hazelcast-topic-component.adoc[Hazelcast Topic]
** xref:hbase-component.adoc[HBase]
** xref:hdfs-component.adoc[HDFS]
-** xref:hipchat-component.adoc[Hipchat]
** xref:http-component.adoc[HTTP]
** xref:iec60870-client-component.adoc[IEC 60870 Client]
** xref:iec60870-server-component.adoc[IEC 60870 Server]
diff --git a/docs/components/modules/ROOT/pages/hipchat-component.adoc b/docs/components/modules/ROOT/pages/hipchat-component.adoc
deleted file mode 100644
index 422caf1..0000000
--- a/docs/components/modules/ROOT/pages/hipchat-component.adoc
+++ /dev/null
@@ -1,248 +0,0 @@
-[[hipchat-component]]
-= Hipchat Component
-//THIS FILE IS COPIED: EDIT THE SOURCE FILE:
-:page-source: components/camel-hipchat/src/main/docs/hipchat-component.adoc
-: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[]
[camel] 03/08: CAMEL-15684 - Removed camel-hipchat from kit
Posted by ac...@apache.org.
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 dc65bff0afda8e99d833e02afb163ea7ece34a23
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Oct 14 09:34:31 2020 +0200
CAMEL-15684 - Removed camel-hipchat from kit
---
apache-camel/src/main/descriptors/common-bin.xml | 1 -
bom/camel-bom/pom.xml | 5 -----
2 files changed, 6 deletions(-)
diff --git a/apache-camel/src/main/descriptors/common-bin.xml b/apache-camel/src/main/descriptors/common-bin.xml
index 0111d7f..30a1329 100644
--- a/apache-camel/src/main/descriptors/common-bin.xml
+++ b/apache-camel/src/main/descriptors/common-bin.xml
@@ -201,7 +201,6 @@
<include>org.apache.camel:camel-hbase</include>
<include>org.apache.camel:camel-hdfs</include>
<include>org.apache.camel:camel-headersmap</include>
- <include>org.apache.camel:camel-hipchat</include>
<include>org.apache.camel:camel-hl7</include>
<include>org.apache.camel:camel-http</include>
<include>org.apache.camel:camel-http-base</include>
diff --git a/bom/camel-bom/pom.xml b/bom/camel-bom/pom.xml
index 4060e3d..cc1539a 100644
--- a/bom/camel-bom/pom.xml
+++ b/bom/camel-bom/pom.xml
@@ -894,11 +894,6 @@
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
- <artifactId>camel-hipchat</artifactId>
- <version>${project.version}</version>
- </dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
<artifactId>camel-hl7</artifactId>
<version>${project.version}</version>
</dependency>
[camel] 08/08: CAMEL-15684 - Removed ref to camel-hipchat
Posted by ac...@apache.org.
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 cbcdba684ef3b1e3a65c2c60ca55b65c20171257
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Oct 14 10:32:40 2020 +0200
CAMEL-15684 - Removed ref to camel-hipchat
---
components/components-init-work-in-progress.md | 1 -
1 file changed, 1 deletion(-)
diff --git a/components/components-init-work-in-progress.md b/components/components-init-work-in-progress.md
index ed0ac92..f4bbb88 100644
--- a/components/components-init-work-in-progress.md
+++ b/components/components-init-work-in-progress.md
@@ -166,7 +166,6 @@
|camel-hdfs2| | |
|camel-headersmap| | |
|camel-hessian| | |
-|camel-hipchat| | |
|camel-hl7| | |
|camel-http| | |
|camel-http-base| | |
[camel] 02/08: CAMEL-15684 - Removed camel-hipchat from parent pom
Posted by ac...@apache.org.
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 7defc451352c39b3eecc2dde10942c99f948b5ad
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Oct 14 09:33:31 2020 +0200
CAMEL-15684 - Removed camel-hipchat from parent pom
---
parent/pom.xml | 5 -----
1 file changed, 5 deletions(-)
diff --git a/parent/pom.xml b/parent/pom.xml
index 5a3f13e..6379740 100644
--- a/parent/pom.xml
+++ b/parent/pom.xml
@@ -1516,11 +1516,6 @@
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
- <artifactId>camel-hipchat</artifactId>
- <version>${project.version}</version>
- </dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
<artifactId>camel-hl7</artifactId>
<version>${project.version}</version>
</dependency>