Open topic with navigation

TIBCO BusinessEvents® Enterprise Edition 6.3.1

# TIBCO BusinessEvents Contribution Repository

TIBCO BusinessEvents Contribution repository in GitHub provides different resources needed to use the features other than the default features provided by TIBCO BusinessEvents.

## Repository Structure

The following is the structure of the TIBCO BusinessEvents Contribution Repository:

Directory | Description
--- | ---
store | Provides reference implementations of custom stores.
metric | Provides JARs and resources to configure metric stores.
channel | Contains JARs and other resources to add channels.
catalog | Contains various Catalog functions.

## Samples

All examples related to the contribution repository are available in the TIBCO BusinessEvents Samples repository in GitHub. This repository also contains some additional examples apart from the bundled examples with TIBCO BusinessEvents.

## Channels

You can create the following channels by using the resources provided in the `channel` directory.

AWS SQS Channel
AWS SQS channel converts incoming SQS messages into events consumed by BusinessEvents and converts events to outgoing SQS messages.
Kafka Streams Channel
You can process input Kafka Streams by using the Kafka Streams channel. The Kafka Streams channel destination can be configured to use stream processors to create stream processing topologies. After the stream topology processes the incoming stream, a stream record is converted to a SimpleEvent that triggers the relevant rules.
MQTT Channel
MQTT is a machine-to-machine connectivity protocol that enables remote connections for IoT applications. By using the MQTT channel, TIBCO BusinessEvents can receive MQTT messages and transform them into TIBCO BusinessEvents events.
Kinesis Channel
Amazon Kinesis Data Streams helps in real-time collection and processing of data records. By using the Amazon Kinesis channel, TIBCO BusinessEvents can convert Kinesis data streams to TIBCO BusinessEvents events.
StreamBase Channel
Using the StreamBase Channel a BusinessEvents application (StreamBase client) can connect to a StreamBase server. The BusinessEvents application can subscribe to StreamBase streams to receive (dequeue) messages from the StreamBase server and send (enqueue) messages to the StreamBase server.

## Metric Store

You can configure and use the following metric stores:

Elasticsearch
Elasticsearch is an open source distributed, search, and analytics engine built on top of Apache Lucene. This implementation publishes entity data to Elasticsearch on RTC completion.

## Catalog Functions

AWS Catalog Functions

- You can use the S3 catalog functions to manipulate S3 objects and buckets.

- Use the SNS catalog functions to send text or SMS messages to a pre-defined SNS topic.

- Use the SQS catalog functions to interact with SQS Queues.

Cassandra Store Catalog Functions

You can use Cassandra Store catalog functions to perform different operations with Cassandra Store.

## Custom Store

Redis
By using this implementation, you can configure TIBCO BusinessEvents with Redis as a direct or backing store.
MongoDB
By using this implementation, you can configure TIBCO BusinessEvents with MongoDB as a direct or backing store.

Did you find this helpful?

YesNo
Great!
Thanks for taking the time to give us some feedback.
Sorry about that

Why wasn't this helpful? (check all that apply)

Could not find what I was looking for
Instructions confusing or unclear
Instructions did not work

Want to tell us more?

Please select at least one option or provide details about the issue!!

Error occurred while submitting feedback.

Error2 occurred while submitting feedback.

TIBCO BusinessEvents® Enterprise Edition

Copyright © 2004-2024. Cloud Software Group, Inc. All Rights Reserved.