Custom Channel
If you want to use a channel other than the channels provided with TIBCO BusinessEvents, use the custom channel API to create the custom channel.
The Java API for custom channel (com.tibco.be.custom.channel package) is bundled with TIBCO BusinessEvents. The com.tibco.be.custom.channel package consists of interfaces and classes that you can implement and extend to create a custom channel. Implement these classes to initialize the channel, create serializer and deserializer for the custom channel, to store and access event data, and to perform various other operations. For more information about the classes and interfaces in the com.tibco.be.custom.channel package see Java API Reference.
TIBCO BusinessEvents bundles a sample Kafka channel and its source code to showcase the channel API usage. The sample Kafka channel implementation of custom channel API is located at BE_HOME\api\channel-api\examples\StudioProjKafka and the source code is located at BE_HOME\api\channel-api\examples\kafka\src.
- Custom Channel Lifecycle
By using the Java API, you can create your own custom channel according to your requirement. While implementing a custom channel, you can extend custom channel classes and override custom channel methods that BusinessEvents invokes during startup. - Channel Messages to Event Conversion
The overall function of your channel is to receive messages from your data source, convert them to Event instances and call EventProcess.processEvent to hand off the events to BusinessEvents for further processing. - Catalog Function Implementation for Custom Channel
Your channel code must implement certain methods to provide proper semantics to the Event catalog functions. - Creating a New Custom BusinessEvents Channel
You can use the custom channel API to create a custom channel according to your requirement for your project.