This example shows how to use Camel in the Java Container using CDI to connect to an ActiveMQ broker hosted in Kubernetes.

This example is implemented using Java code with CDI injected resources. The source code uses the CDI Annotation @ServiceName to lookup the ActiveMQ broker Service name.

The broker service name can be changed here and defaults to @ServiceName("fabric8mq")

This example will connect to the broker and send messages to a queue TEST.FOO

The example can be built with

mvn clean install

It is assumed a running Kubernetes platform is already running. If not you can find details how to get started.

The example can be built and deployed using a single goal:

mvn fabric8:run

When the example runs in fabric8, you can use the OpenShift client tool to inspect the status

To list all the running pods:

oc get pods

Then find the name of the pod that runs this quickstart, and output the logs from the running pods with:

oc logs <name of pod>

You can also use the fabric8 web console to manage the running pods, and view logs and much more.

You can find more details about running this quickstart on the website. This also includes instructions how to change the Docker image user and registry.