Skip to content

Commit

Permalink
Update Camel event registry models
Browse files Browse the repository at this point in the history
  • Loading branch information
tijsrademakers committed Oct 4, 2024
1 parent c47582b commit 23d6692
Show file tree
Hide file tree
Showing 4 changed files with 77 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,8 @@
import java.util.List;
import java.util.Map;

import org.flowable.eventregistry.model.CamelInboundChannelModel;
import org.flowable.eventregistry.model.CamelOutboundChannelModel;
import org.flowable.eventregistry.model.ChannelModel;
import org.flowable.eventregistry.model.DelegateExpressionInboundChannelModel;
import org.flowable.eventregistry.model.DelegateExpressionOutboundChannelModel;
Expand Down Expand Up @@ -58,11 +60,13 @@ protected void addDefaultChannelModelClasses() {
addInboundChannelModelClass("jms", JmsInboundChannelModel.class);
addInboundChannelModelClass("rabbit", RabbitInboundChannelModel.class);
addInboundChannelModelClass("kafka", KafkaInboundChannelModel.class);
addInboundChannelModelClass("camel", CamelInboundChannelModel.class);
addInboundChannelModelClass("expression", DelegateExpressionInboundChannelModel.class);

addOutboundChannelModelClass("jms", JmsOutboundChannelModel.class);
addOutboundChannelModelClass("rabbit", RabbitOutboundChannelModel.class);
addOutboundChannelModelClass("kafka", KafkaOutboundChannelModel.class);
addOutboundChannelModelClass("camel", CamelOutboundChannelModel.class);
addOutboundChannelModelClass("expression", DelegateExpressionOutboundChannelModel.class);
}

Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,36 @@
/* Licensed 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.flowable.eventregistry.model;

import com.fasterxml.jackson.annotation.JsonInclude;
import com.fasterxml.jackson.annotation.JsonInclude.Include;


@JsonInclude(Include.NON_NULL)
public class CamelInboundChannelModel extends InboundChannelModel {

protected String sourceUri;

public CamelInboundChannelModel() {
super();
setType("camel");
}

public String getSourceUri() {
return sourceUri;
}

public void setSourceUri(String sourceUri) {
this.sourceUri = sourceUri;
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,36 @@
/* Licensed 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.flowable.eventregistry.model;

import com.fasterxml.jackson.annotation.JsonInclude;
import com.fasterxml.jackson.annotation.JsonInclude.Include;


@JsonInclude(Include.NON_NULL)
public class CamelOutboundChannelModel extends OutboundChannelModel {

protected String destination;

public CamelOutboundChannelModel() {
super();
setType("camel");
}

public String getDestination() {
return destination;
}

public void setDestination(String destination) {
this.destination = destination;
}
}
2 changes: 1 addition & 1 deletion pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
<reactor-netty.version>1.1.15</reactor-netty.version>
<jackson.version>2.15.3</jackson.version>
<jakarta-jms.version>3.1.0</jakarta-jms.version>
<camel.version>4.0.0</camel.version>
<camel.version>4.7.0</camel.version>
<cxf.version>4.0.2</cxf.version>
<slf4j.version>2.0.11</slf4j.version>
<groovy.version>4.0.17</groovy.version>
Expand Down

0 comments on commit 23d6692

Please sign in to comment.