Organizational Metrics
holunda-io / camel-zeebe-legacy Goto Github PK
View Code? Open in Web Editor NEWApache Camel routing for zeebe clients
Home Page: http://www.holunda.io/camel-zeebe/
Apache Camel routing for zeebe clients
Home Page: http://www.holunda.io/camel-zeebe/
As a remote consumer, I can subscribe to a stream of zeebe events published to a topic.
with zeebe:jobworker?name=foo
we can subscribe as "foo"
client side: send subscribe command
server side: create route that publishes and receives jobEvents
Future zeebe will drop the topic concept and rely on clients topic only.
So setting an optional topic is no longer required
single file for consumer/producer
Caused by: java.lang.ClassNotFoundException: javax.xml.bind.JAXBException
at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(BuiltinClassLoader.java:582)
at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(ClassLoaders.java:185)
at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:496)
... 13 more
on the client side: zeebe:startprocess?topic=x,processDefinitionKey=myProcess
body: initial payload
on the server side: start new instance
it is not possible to get the state from a generalEvent (see camunda/zeebe#367 ) but it is essential to have this in the message header for camel.
Until zeebe supports this, we have to extract the value from the json content.
When we subscribe with the universal event handler, we forward the zeebe events directly. They should be converted to zeebe-agnostic camel-zeebe-only pojos
via zeebe:deployment?topic=foo
I can override the clients defaultTopic in case the DeployCommand does not define a topic
currently constant, introduce parameter
I want to deploy a process using camels from file consumer
Required: processor that transforms the file exchange to a deployCommand
in the component, wrap all required information (Client Supplier, uri, remaining, parameters) in a data class and pass it to endpoints.
When reading from file or writing to file, we need the body command/event to be serialized as json.
I see two options:
AC:
On the client side: create a deploy command and publish to route
on the server side: receive command and use fluent deployment api to publish process
currently constant, introduce parameter
introduced with camunda/zeebe#672
Today, the camel.api.jobevent is written to the exchange, it should be possible to toggle the behavior
The body just requires payload and customHeaders.
Introduce exchange wrapper/processor
A declarative, efficient, and flexible JavaScript library for building user interfaces.
๐ Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
An Open Source Machine Learning Framework for Everyone
The Web framework for perfectionists with deadlines.
A PHP framework for web artisans
Bring data to life with SVG, Canvas and HTML. ๐๐๐
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
Some thing interesting about web. New door for the world.
A server is a program made to process requests and deliver data to clients.
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
Some thing interesting about visualization, use data art
Some thing interesting about game, make everyone happy.
We are working to build community through open source technology. NB: members must have two-factor auth.
Open source projects and samples from Microsoft.
Google โค๏ธ Open Source for everyone.
Alibaba Open Source for everyone
Data-Driven Documents codes.
China tencent open source team.