Repository: camel Updated Branches: refs/heads/master ef38a4bb3 -> 857f55921
camel-jira: new issue producer Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/857f5592 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/857f5592 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/857f5592 Branch: refs/heads/master Commit: 857f5592181444a8d74e04b9676913415a310f9a Parents: ef38a4b Author: Brett Meyer <br...@3riverdev.com> Authored: Thu Oct 16 13:55:30 2014 -0400 Committer: Willem Jiang <willem.ji...@gmail.com> Committed: Fri Oct 17 16:40:21 2014 +0800 ---------------------------------------------------------------------- .../camel/component/jira/JIRAEndpoint.java | 17 ++++++- .../jira/producer/AbstractJIRAProducer.java | 45 ++++++++++++++++++ .../jira/producer/NewIssueProducer.java | 48 ++++++++++++++++++++ .../component/jira/producer/ProducerType.java | 31 +++++++++++++ 4 files changed, 140 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/857f5592/components/camel-jira/src/main/java/org/apache/camel/component/jira/JIRAEndpoint.java ---------------------------------------------------------------------- diff --git a/components/camel-jira/src/main/java/org/apache/camel/component/jira/JIRAEndpoint.java b/components/camel-jira/src/main/java/org/apache/camel/component/jira/JIRAEndpoint.java index ec1199a..dd8e8bf 100644 --- a/components/camel-jira/src/main/java/org/apache/camel/component/jira/JIRAEndpoint.java +++ b/components/camel-jira/src/main/java/org/apache/camel/component/jira/JIRAEndpoint.java @@ -24,6 +24,8 @@ import org.apache.camel.Producer; import org.apache.camel.component.jira.consumer.ConsumerType; import org.apache.camel.component.jira.consumer.NewCommentConsumer; import org.apache.camel.component.jira.consumer.NewIssueConsumer; +import org.apache.camel.component.jira.producer.NewIssueProducer; +import org.apache.camel.component.jira.producer.ProducerType; import org.apache.camel.impl.DefaultEndpoint; import org.apache.camel.spi.UriEndpoint; import org.apache.camel.spi.UriParam; @@ -61,7 +63,20 @@ public class JIRAEndpoint extends DefaultEndpoint { } public Producer createProducer() throws Exception { - throw new UnsupportedOperationException("JIRAProducer is not implemented"); + String uri = getEndpointUri(); + String[] uriSplit = splitUri(getEndpointUri()); + + if (uriSplit.length > 0) { + switch (ProducerType.fromUri(uriSplit[0])) { + case NEWISSUE: + return new NewIssueProducer(this); + default: + break; + } + } + + throw new IllegalArgumentException("Cannot create any producer with uri " + uri + + ". A producer type was not provided (or an incorrect pairing was used)."); } public Consumer createConsumer(Processor processor) throws Exception { http://git-wip-us.apache.org/repos/asf/camel/blob/857f5592/components/camel-jira/src/main/java/org/apache/camel/component/jira/producer/AbstractJIRAProducer.java ---------------------------------------------------------------------- diff --git a/components/camel-jira/src/main/java/org/apache/camel/component/jira/producer/AbstractJIRAProducer.java b/components/camel-jira/src/main/java/org/apache/camel/component/jira/producer/AbstractJIRAProducer.java new file mode 100644 index 0000000..4805d2d --- /dev/null +++ b/components/camel-jira/src/main/java/org/apache/camel/component/jira/producer/AbstractJIRAProducer.java @@ -0,0 +1,45 @@ +/** + * 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.jira.producer; + +import java.net.URI; + +import com.atlassian.jira.rest.client.JiraRestClient; +import com.atlassian.jira.rest.client.internal.jersey.JerseyJiraRestClientFactory; +import org.apache.camel.Exchange; +import org.apache.camel.component.jira.JIRAEndpoint; +import org.apache.camel.impl.DefaultProducer; + +public abstract class AbstractJIRAProducer extends DefaultProducer { + + private final JiraRestClient client; + + public AbstractJIRAProducer(JIRAEndpoint endpoint) throws Exception { + super(endpoint); + + final JerseyJiraRestClientFactory factory = new JerseyJiraRestClientFactory(); + final URI jiraServerUri = URI.create(endpoint.getServerUrl()); + client = factory.createWithBasicHttpAuthentication(jiraServerUri, endpoint.getUsername(), + endpoint.getPassword()); + } + + protected JiraRestClient client() { + return client; + } + + public abstract void process(Exchange exchange) throws Exception; +} http://git-wip-us.apache.org/repos/asf/camel/blob/857f5592/components/camel-jira/src/main/java/org/apache/camel/component/jira/producer/NewIssueProducer.java ---------------------------------------------------------------------- diff --git a/components/camel-jira/src/main/java/org/apache/camel/component/jira/producer/NewIssueProducer.java b/components/camel-jira/src/main/java/org/apache/camel/component/jira/producer/NewIssueProducer.java new file mode 100644 index 0000000..be54c70 --- /dev/null +++ b/components/camel-jira/src/main/java/org/apache/camel/component/jira/producer/NewIssueProducer.java @@ -0,0 +1,48 @@ +/** + * 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.jira.producer; + +import com.atlassian.jira.rest.client.domain.BasicIssue; +import com.atlassian.jira.rest.client.domain.input.IssueInputBuilder; +import org.apache.camel.Exchange; +import org.apache.camel.component.jira.JIRAEndpoint; + +public class NewIssueProducer extends AbstractJIRAProducer { + + public NewIssueProducer(JIRAEndpoint endpoint) throws Exception { + super(endpoint); + } + + @Override + public void process(Exchange exchange) throws Exception { + String projectKey = exchange.getIn().getHeader("ProjectKey", String.class); + Long issueTypeId = exchange.getIn().getHeader("IssueTypeId", Long.class); + String issueSummary = exchange.getIn().getHeader("IssueSummary", String.class); + IssueInputBuilder issueBuilder = new IssueInputBuilder(projectKey, issueTypeId); + issueBuilder.setDescription(exchange.getIn().getBody(String.class)); + issueBuilder.setSummary(issueSummary); + BasicIssue issue = client().getIssueClient().createIssue(issueBuilder.build(), null); + + // support InOut + if (exchange.getPattern().isOutCapable()) { + // copy the header of in message to the out message + exchange.getOut().copyFrom(exchange.getIn()); + exchange.getOut().setBody(issue); + } + } + +} http://git-wip-us.apache.org/repos/asf/camel/blob/857f5592/components/camel-jira/src/main/java/org/apache/camel/component/jira/producer/ProducerType.java ---------------------------------------------------------------------- diff --git a/components/camel-jira/src/main/java/org/apache/camel/component/jira/producer/ProducerType.java b/components/camel-jira/src/main/java/org/apache/camel/component/jira/producer/ProducerType.java new file mode 100644 index 0000000..037ec1a --- /dev/null +++ b/components/camel-jira/src/main/java/org/apache/camel/component/jira/producer/ProducerType.java @@ -0,0 +1,31 @@ +/** + * 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.jira.producer; + +public enum ProducerType { + + NEWISSUE, UNKNOWN; + + public static ProducerType fromUri(String uri) { + for (ProducerType producerType : ProducerType.values()) { + if (producerType.name().equalsIgnoreCase(uri)) { + return producerType; + } + } + return ProducerType.UNKNOWN; + } +}
