Fuse 6 is no longer supported
As of February 2025, Red Hat Fuse 6 is no longer supported. If you are using Fuse 6, please upgrade to Red Hat build of Apache Camel.Fabric Guide
A system for provisioning containers deployed across a network
Copyright © 2011-2015 Red Hat, Inc. and/or its affiliates.
Abstract
Part I. Basic Fabric Deployment
Abstract
Chapter 1. Getting Started with Fuse Fabric
Abstract
1.1. Create a Fabric
Overview
Figure 1.1. A Sample Fabric with Child Containers

Steps to create the fabric
- To create the first fabric container, which acts as the seed for the new fabric, enter this console command:
JBossFuse:karaf@root> fabric:create --new-user AdminUser --new-user-password AdminPass --new-user-role Administrator --zookeeper-password ZooPass --resolver manualip --manual-ip 127.0.0.1 --wait-for-provisioning
The current container, namedroot
by default, becomes a Fabric Server with a registry service installed. Initially, this is the only container in the fabric. The--new-user
,--new-user-password
, and--new-user-role
options specify the credentials for a newAdministrator
user. The Zookeeper password is used to protect sensitive data in the Fabric registry service (all of the nodes under/fabric
). The--manual-ip
option specifies the loopback address,127.0.0.1
, as the Fabric Server's IP address.NoteA Fabric Server requires a static IP address. For simple trials and tests, you can use the loopback address,127.0.0.1
, to work around this requirement. But if you are deploying a fabric in production or if you want to create a distributed ensemble, you must assign a static IP address to the each of the Fabric Server hosts.NoteMost of the time, you are not prompted to enter the Zookeeper password when accessing the registry service, because it is cached in the current session. When you join a container to a fabric, however, you must provide the fabric's Zookeeper password. - Create a child container. Assuming that your root container is named
root
, enter this console command:JBossFuse:karaf@root> fabric:container-create-child root child The following containers have been created successfully: Container: child.
- Invoke the following command to monitor the status of the child container, as it is being provisioned:
JBossFuse:karaf@root> shell:watch container-list
After the deployment of thechild
has completed, you should see a listing something like this:JBossFuse:karaf@root> shell:watch container-list [id] [version] [alive] [profiles] [provision status] root 1.0 true fabric, fabric-ensemble-0000-1, fuse-esb-full success child 1.0 true default success
Type theReturn
key to get back to the JBoss Fuse console prompt.
1.2. Deploy a Profile
Deploy a profile to the child container
- Deploy the
quickstarts-beginner-camel.log
profile into thechild
container by entering this console command:JBossFuse:karaf@root> fabric:container-change-profile child quickstarts-beginner-camel.log
- Verify that the
quickstarts-beginner-camel.log
profile deploys successfully to thechild
container, using thefabric:container-list
command. Enter the following command to monitor the container status:JBossFuse:karaf@root> shell:watch container-list
And wait until thechild
container status changes tosuccess
.
View the sample output
quickstarts-beginner-camel.log
profile writes a message to the container's log every five seconds. To verify that the profile is running properly, you can look for these messages in the child container's log, as follows:
- Connect to the
child
container, by entering the following console command:JBossFuse:karaf@root> container-connect child
- After logging on to the
child
container, view thechild
container's log using thelog:tail
command, as follows:JBossFuse:karaf@root> log:tail
You should see some output like the following:2015-06-16 11:47:51,012 | INFO | #2 - timer://foo | log-route | ? ? | 153 - org.apache.camel.camel-core - 2.15.1.redhat-620123 | >>> Hello from Fabric based Camel route! : child 2015-06-16 11:47:56,011 | INFO | #2 - timer://foo | log-route | ? ? | 153 - org.apache.camel.camel-core - 2.15.1.redhat-620123 | >>> Hello from Fabric based Camel route! : child
- Type Ctrl-C to exit the log view and get back to the child container's console prompt.
- Type Ctrl-D to exit the child container's console, which brings you back to the root container console.
1.3. Update a Profile
Atomic container upgrades
Profile versioning
Upgrade to a new profile
quickstarts-beginner-camel.log
profile, when it is deployed and running in a container, follow the recommended procedure:
- Create a new version, 1.1, to hold the pending changes by entering this console command:
JBossFuse:karaf@root> fabric:version-create Created version: 1.1 as copy of: 1.0
The new version is initialised with a copy of all of the profiles from version 1.0. - Use the
fabric:profile-edit
command to change the message that is written to the container log by the Camel route. Enter the followingprofile-edit
command to edit thecamel.xml
resource:JBossFuse:karaf@root> fabric:profile-edit --resource camel.xml quickstarts-beginner-camel.log 1.1
This opens the built-in text editor for editing profile resources (see Appendix A, Editing Profiles with the Built-In Text Editor).Remember to specify version1.1
to thefabric:profile-edit
command, so that the modifications are applied to version 1.1 of thequickstarts-beginner-camel.log
profile.When you are finished editing, type Ctrl-S to save your changes and then type Ctrl-X to quit the text editor and get back to the console prompt. - Upgrade the
child
container to version1.1
by entering this console command:JBossFuse:karaf@root> fabric:container-upgrade 1.1 child
Roll back to an old profile
quickstarts-beginner-camel.log
profile, using the fabric:container-rollback
command like this:
JBossFuse:karaf@root> fabric:container-rollback 1.0 child
1.4. Shutting Down the Containers
Shutting down the containers
fabric:container-stop
command. For example, to shut down the current fabric completely, enter these console commands:
JBossFuse:karaf@root> fabric:container-stop child JBossFuse:karaf@root> shutdown -f
fabric:container-start
console command.
Chapter 2. Creating a New Fabric
Abstract
Static IP address required for Fabric Server
- For simple examples and tests (with a single Fabric Server) you can work around the static IP requirement by using the loopback address,
127.0.0.1
. - For distributed tests (multiple Fabric Servers) and production deployments, you must assign a static IP address to each of the Fabric Server hosts.
--resolver manualip --manual-ip StaticIPAddress
options to specify the static IP address explicitly, when creating a new Fabric Server.
Procedure
- (Optional) Customise the name of the root container by editing the
InstallDir/etc/system.properties
file and specifying a different name for this property:karaf.name=root
NoteFor the first container in your fabric, this step is optional. But at some later stage, if you want to join a root container to the fabric, you might need to customise the container's name to prevent it from clashing with any existing root containers in the fabric. - Any existing users in the
InstallDir/etc/users.properties
file are automatically used to initialize the fabric's user data, when you create the fabric. You can populate theusers.properties
file, by adding one or more lines of the following form:Username=Password[,RoleA][,RoleB]...
But there must not be any users in this file that have administrator privileges (Administrator
,SuperUser
, oradmin
roles). If theInstallDir/etc/users.properties
already contains users with administrator privileges, you should delete those users before creating the fabric.WarningIf you leave some administrator credentials in theusers.properties
file, this represents a security risk because the file could potentially be accessed by other containers in the fabric.NoteThe initialization of user data fromusers.properties
happens only once, at the time the fabric is created. After the fabric has been created, any changes you make tousers.properties
will have no effect on the fabric's user data. - If you use a VPN (virtual private network) on your local machine, it is advisable to log off VPN before you create the fabric and to stay logged off while you are using the local container.NoteA local Fabric Server is permanently associated with a fixed IP address or hostname. If VPN is enabled when you create the fabric, the underlying Java runtime is liable to detect and use the VPN hostname instead of your permanent local hostname. This can also be an issue with multi-homed machines.
- Start up your local container.In JBoss Fuse, start the local container as follows:
cd InstallDir/bin ./fuse
- Create a new fabric by entering the following command:
JBossFuse:karaf@root> fabric:create --new-user AdminUser --new-user-password AdminPass --new-user-role Administrator --zookeeper-password ZooPass --resolver manualip --manual-ip StaticIPAddress --wait-for-provisioning
The current container, namedroot
by default, becomes a Fabric Server with a registry service installed. Initially, this is the only container in the fabric. The--new-user
,--new-user-password
, and--new-user-role
options specify the credentials for a newAdministrator
user. The Zookeeper password is used to protect sensitive data in the Fabric registry service (all of the nodes under/fabric
). The--manual-ip
option specifies the Fabric Server's static IP addressStaticIPAddress
(see the section called “Static IP address required for Fabric Server”).For more details on fabric:create see section "fabric:create" in "Console Reference".For more details about resolver policies, see section "fabric:container-resolver-list" in "Console Reference" and section "fabric:container-resolver-set" in "Console Reference".
Fabric creation process
- The container installs the requisite OSGi bundles to become a Fabric Server.
- The Fabric Server starts a registry service, which listens on TCP port 2181 (which makes fabric configuration data available to all of the containers in the fabric).NoteYou can customize the value of the registry service port by specifying the
--zookeeper-server-port
option. - The Fabric Server installs a new JAAS realm (based on the ZooKeeper login module), which overrides the default JAAS realm and stores its user data in the ZooKeeper registry.
- The new Fabric Ensemble consists of a single Fabric Server (the current container).
- A default set of profiles is imported from
InstallDir/fabric/import
(can optionally be overridden). - After the standalone container is converted into a Fabric Server, the previously installed OSGi bundles and Karaf features are completely cleared away and replaced by the default Fabric Server configuration. For example, some of the shell command sets that were available in the standalone container are no longer available in the Fabric Server.
Expanding a Fabric
- Child container, created on the local machine as a child process in its own JVM.Instructions on creating a child container are found in Child Containers.
- SSH container, created on any remote machine for which you have
ssh
access.Instructions on creating a SSH container are found in SSH Containers. - Cloud container, created on compute instance in the cloud.Instructions on creating a cloud container are found in Cloud Containers.
Chapter 3. Fabric Containers
3.1. Child Containers
Abstract
Overview
One container or many?
Creating a child container
fabric:container-create-child
command, specifying the parent container name and the name of the new child container. For example, to create the new child container, onlychild
, with root
as its parent, enter the following command:
fabric:container-create-child root onlychild
fabric:container-create-child root child 3
child1 child2 child3
Stopping and starting a child container
fabric:container-stop
command. For example, to shut down the child1
container:
fabric:container-stop child1
fabric:container-start
command, as follows:
fabric:container-start child1
ps
and kill
.
Deleting a child container
fabric:container-delete
command, as follows:
fabric:container-delete child1
3.2. SSH Containers
Abstract
Overview
Prerequisites
- Linux or UNIX operating system,
- SSHD running on the target host and:
- A valid account credentials, or
- Configured public key authentication
- Java 1.7 installed.
- Curl installed.
- GNU tar installed.
- Telnet installed.
Creating an SSH container
fabric:container-create-ssh
console command, for creating SSH containers.
myhost
(accessible from the local network) with the SSH user account, myuser
, and the password, mypassword
, your could create an SSH container on myhost
, using the following console command:
fabric:container-create-ssh --host myhost --user myuser --password mypassword myremotecontainername
myuser
user on myhost
has configured public key authentication for SSH, you can skip the password option:
fabric:container-create-ssh --host myhost --user myuser myremotecontainername
~/.ssh/id_rsa
for authentication. If you need to use a different key, you can specify the key location explicitly with the --private-key
option:
fabric:container-create-ssh --host myhost --user myuser --private-key ~/.ssh/fabric_pk myremotecontainername
--pass-phrase
option, in case your key requires a pass phrase.
Creating a Fabric server using SSH
fabric:container-create-ssh
supports the --ensemble-server
option, which can be invoked to create a container which is a Fabric server. For example, the following container-create-ssh
command creates a new fabric consisting of one Fabric server on the myhost
host:
fabric:container-create-ssh --host myhost --user myuser --ensemble-server myremotecontainername fabric:join myhost:2181
fabric:join
command joins the current container to the new fabric. This has the advantage that it is much easier to administer the new fabric using a container that is joined to the fabric, because the local container then gains access to the connection data stored in the Fabric registry.
fabric:join
is the ZooKeeper server port, Host:Port
. The port number in this example, 2181
, is the standard ZooKeeper port number in Fabric.
fabric:join
command, you will be prompted to enter the ZooKeeper password for the fabric.
Managing remote SSH containers
fabric:container-stop myremotecontainername
fabric:container-start myremotecontainername
fabric:container-delete myremotecontainername
References
3.3. Fabric Containers on Windows
Abstract
Overview
Creating a Fabric container on Windows
- Following the instructions in the JBoss Fuse Installation Guide, manually install the JBoss Fuse product on the Windows target host.
- Open a new command prompt and enter the following commands to start the container on the target host:
cd InstallDir\bin fuse.bat
- If the Fabric servers from the Fabric ensemble are not already running, start them now.
- Join the container to the existing fabric, by entering the following console command:
JBossFuse:karaf@root> fabric:join --zookeeper-password ZooPass RegistryHost
WhereZooPass
is the ZooKeeper password for the Fabric ensemble (as specified when you originally created the fabric withfabric:create
); andRegistryHost
is the hostname or IP address of one of the hosts where a Fabric server is running.NoteBy default, Fabric uses the default IP port number,2181
, to connect to the Fabric server on theRegistryHost
host. If, for some reason, the ZooKeeper service is listening on a different IP port, you can specify the IP port number explicitly using the syntax,RegistryHost:RegistryIPPort
.
default
profile deployed on it.
Creating a Fabric server on Windows
- Following the instructions in the JBoss Fuse Installation Guide, manually install the JBoss Fuse product on the Windows target host.
- To start the container on the target host, open a new command prompt and enter the following commands:
cd InstallDir\bin fuse.bat
- To create a new fabric (thereby turning the current host into a Fabric server), enter the following console command:
JBossFuse:karaf@root> fabric:create --new-user AdminUser --new-user-password AdminPass --new-user-role Administrator --zookeeper-password ZooPass --resolver manualip --manual-ip StaticIPAddress --wait-for-provisioning
The current container, namedroot
by default, becomes a Fabric Server with a registry service installed. Initially, this is the only container in the fabric. The--new-user
,--new-user-password
, and--new-user-role
options specify the credentials for a newAdministrator
user. The Zookeeper password is used to protect sensitive data in the Fabric registry service (all of the nodes under/fabric
). The--manual-ip
option specifies the Fabric Server's static IP addressStaticIPAddress
(see the section called “Static IP address required for Fabric Server”).
Managing remote containers on Windows
fabric:join
), there are certain restrictions on which commands you can use to manage it. In particular, the following commands are not supported:
fabric:container-stop fabric:container-start fabric:container-delete
3.4. Cloud Containers
Abstract
3.4.1. Preparing to use Fabric in the Cloud
Overview
Prerequisites
- A valid account with one of the cloud providers implemented by JClouds. The list of cloud providers can be found at JClouds supported providers.NoteIn the context of JClouds, the term supported provider does not imply commercial support for the listed cloud providers. It just indicates that there is an available implementation.
Hybrid clusters
- Fabric registry is running inside the public cloud.In this case, local containers will have no problem accessing the registry, as long as they are able to connect to the Internet.
- Cloud and local containers are part of a Virtual Private Network (VPN).If the Fabric registry is running on the premises, the cloud containers will not be able to access the registry, unless you set up a VPN (or make the registry accessible from the Internet, which is not recommended).
- Fabric registry is accessible from the Internet (not recommended).
Preparation
fabric:create
command. You cannot access the requisite cloud console commands until you create a Fabric locally.
JBossFuse:karaf@root> fabric:create --new-user AdminUser --new-user-password AdminPass --zookeeper-password ZooPass --wait-for-provisioning
--new-user
and --new-user-password
options specify the credentials for a new administrator user. The ZooPass
password specifies the password that is used to protect the Zookeeper registry.
JBossFuse:karaf@root> profile-list [id] [# containers] [parents] ... cloud-aws.ec2 0 cloud-base ... cloud-openstack 0 cloud-base cloud-servers.uk 0 cloud-base cloud-servers.us 0 cloud-base ...
cloud-aws.ec2
profile, as follows:
fabric:container-add-profile root cloud-aws.ec2
root
is the name of your local container.
Feature naming convention
cloud-aws.ec2
profile is the jclouds-aws-ec2
feature, which provides the necessary bundles for interacting with Amazon EC2:
JBossFuse:karaf@root> profile-display cloud-aws.ec2 Profile id: cloud-aws.ec2 Version : 1.0 ... Container settings ---------------------------- Features : jclouds-aws-ec2 ...
jclouds-aws-ec2
- Feature for the Amazon EC2 cloud provider.
jclouds-cloudservers-us
- Feature for the Rackspace cloud provider.
jclouds-ProviderID
, where ProviderID
is one of the provider IDs listed in the JClouds supported providers page. Or you can list the available JClouds features using the features:list
command:
features:list | grep jclouds
fabric:profile-edit --features jclouds-ProviderID MyProfile fabric:container-add-profile root MyProfile
Registering a cloud provider
fabric:cloud-service-add
console command (the registration process will store the provider credentials in the Fabric registry, so that they are available from any Fabric container).
fabric:cloud-service-add --name aws-ec2 --provider aws-ec2 --identity AccessKeyID --credential SecretAccessKey
--name
option is an alias that you use to refer to this registered cloud provider instance. It is possible to register the same cloud provider more than once, with different user accounts. The cloud provider alias thus enables you distinguish between multiple accounts with the same cloud provider.
3.4.2. Administering Cloud Containers
Creating a new fabric in the cloud
fabric:container-create-cloud
with the --ensemble-server
option, which creates a new Fabric server. For example, to create a Fabric server on Amazon EC2:
fabric:container-create-cloud --ensemble-server --name aws-ec2 --new-user AdminUser --new-user-password AdminPass --zookeeper-password ZooPass mycontainer
Basic security
fabric:container-create-cloud
command, to ensure that the new fabric is adequately protected. You need to specify the following security data:
- JAAS credentials—the
--new-user
and--new-user-password
options define JAAS credentials for a new user with administrative privileges on the fabric. These credentials can subsequently be used to log on to the JMX port or the SSH port of the newly created Fabric server. - ZooKeeper password—is used to protect the data stored in the ZooKeeper registry in the Fabric server. The only time you will be prompted to enter the ZooKeeper password is when you try to join a container to the fabric using the
fabric:join
command.
Joining a standalone container to the fabric
fabric:join -n --zookeeper-password ZooPass PublicIPAddress
PublicIPAddress
is the public host name or the public IP address of the compute instance that hosts the Fabric server (you can get this address either from the JBoss Fuse console output or from the Amazon EC2 console).
Creating a cloud container
fabric:container-create-cloud
command to create new Fabric containers in the cloud. For example to create a container on Amazon EC2:
fabric:container-create-cloud --name aws-ec2 mycontainer
fabric:container-create-cloud
command with the --os-family
option as follows:
fabric:container-create-cloud --name aws-ec2 --os-family centos mycontainer
--os-version
option:
fabric:container-create-cloud --name aws-ec2 --os-family centos --os-version 5 mycontainer
--image
option.
fabric:container-create-cloud --name aws-ec2 --image myimageid mycontainer
Looking up for compute service. Creating 1 nodes in the cloud. Using operating system: ubuntu. It may take a while ... Node fabric-f674a68f has been created. Configuring firewall. Installing fabric agent on container cloud. It may take a while... Overriding resolver to publichostname. [id] [container] [public addresses] [status] us-east-1/i-f674a68f cloud [23.20.114.82] success
Images
- Linux O/S
- RedHat or Debian packaging style
- Either no Java installed or Java 1.7+ installed. If there is no Java installed on the image, Fabric will install Java for you. If the wrong Java version is installed, however, the container installation will fail.
fabric:cloud-service-add --name aws-ec2 --provider aws-ec2 --identity AccessKeyID --credential SecretAccessKey --owner myownerid
Locations and hardware
jclouds:location-list
jclouds:hardware-list
fabric:container-create-cloud
command. For example:
fabric:container-create-cloud --name aws-ec2 --location eu-west-1 --hardware m2.4xlarge mycontainer
Chapter 4. Fabric Profiles
Abstract
4.1. Introduction to Profiles
Overview
What is in a profile?
- OSGi bundle URLs
- Web ARchive (WAR) URLs
- Fuse Application Bundle (FAB) URLs
- OSGi Configuration Admin PIDs
- Apache Karaf feature repository URLs
- Apache Karaf features
- Maven artifact repository URLs
- Blueprint XML files or Spring XML files (for example, for defining broker configurations or Camel routes)
- Any kind of resource that might be needed by an application (for example, Java properties file, JSON file, XML file, YML file)
- System properties that affect the Apache Karaf container (analogous to editing
etc/config.properties
) - System properties that affect installed bundles (analogous to editing
etc/system.properties
)
Profile hierarchies
Some basic profiles
- [default]
- The
default
profile defines all of the basic requirements for a Fabric container. For example it specifies thefabric-agent
feature, the Fabric registry URL, and the list of Maven repositories from which artifacts can be downloaded. - [karaf]
- Inherits from the
default
profile and defines the Karaf feature repositories, which makes the Apache Karaf features accessible. - [feature-camel]
- Inherits from
karaf
, defines the Camel feature repositories, and installs some core Camel features: such ascamel-core
andcamel-blueprint
. If you are deploying a Camel application, it is recommended that you inherit from this profile. - [feature-cxf]
- Inherits from
karaf
, defines the CXF feature repositories, and installs some core CXF features. If you are deploying a CXF application, it is recommended that you inherit from this profile. - [mq-base]
- Inherits from the
karaf
profile and installs themq-fabric
feature - [mq-default]
- Inherits from the
mq-base
profile and provides the configuration for an A-MQ broker. Use this profile, if you want to deploy a minimal installation of an ActiveMQ broker. - [jboss-fuse-full]
- Includes all of the features and bundles required for the JBoss Fuse full container.
4.2. Working with Profiles
Changing the profiles in a container
fabric:container-change-profile
command as follows:
fabric:container-change-profile mycontainer myprofile
myprofile
profile to the mycontainer
container. All profiles previously assigned to the container are removed. You can also deploy multiple profiles to the container, with the following command:
fabric:container-change-profile mycontainer myprofile myotherprofile
Adding a profile to a container
fabric:container-add-profile
command gives you a simple way to add profiles to a container, without having to list all of the profiles that were already assigned. For example, to add the example-camel
profile to the mycontainer
container:
fabric:container-add-profile mycontainer example-camel
Listing available profiles
fabric:profile-list
console command:
fabric:profile-list
Inspecting profiles
fabric:profile-display
command. For example, to display what is defined in the feature-camel
profile, enter the following command:
fabric:profile-display feature-camel
Profile id: feature-camel Version : 1.0 Attributes: parents: karaf Containers: Container settings ---------------------------- Repositories : mvn:org.apache.camel.karaf/apache-camel/${version:camel}/xml/features Features : camel-core camel-blueprint fabric-camel Configuration details ---------------------------- Other resources ---------------------------- Resource: org.fusesource.insight.metrics.json
feature-camel
profile, taking into account all of its ancestors, you must specify the --overlay
switch, as follows:
fabric:profile-display --overlay feature-camel
--display-resources
switch (or -r
for short) to the profile-display
command, as follows:
fabric:profile-display -r feature-camel
Creating a new profile
fabric:profile-create
command, as follows:
fabric:profile-create myprofile
--parents
option to the command:
fabric:profile-create --parents feature-camel myprofile
Adding or removing features
fabric:profile-edit
command. For example, to add the camel-jclouds
feature to the feature-camel
profile.
fabric:profile-edit --feature camel-jclouds feature-camel
fabric:profile-display
command to see what the camel profile looks like now. You should see that the camel-jclouds
feature appears in the list of features for the feature-camel
profile.
Features : camel-jclouds camel-blueprint/2.9.0.fuse-7-061 camel-core/2.9.0.fuse-7-061 fabric-camel/99-master-SNAPSHOT
--delete
option. For example, if you need to remove the camel-jclouds
feature, you could use the following command:
fabric:profile-edit --delete --feature camel-jclouds feature-camel
Editing PID properties
- Edit the PID using the built-in text editor—the Karaf console has a built-in text editor which you can use to edit profile resources such as PID properties. To start editing a PID using the text editor, enter the following console command:
fabric:profile-edit --pid PID ProfileName
For more details about the built-in text editor, see Appendix A, Editing Profiles with the Built-In Text Editor. - Edit the PID inline, using console commands—alternatively, you can edit PIDs directly from the console, using the appropriate form of the
fabric:profile-edit
command. This approach is particularly useful for scripting. For example, to set a specific key-value pair,Key=Value
, in a PID, enter the following console command:fabric:profile-edit --pid PID/Key=Value ProfileName
Editing a PID inline
fabric:profile-edit
command:
- Assign a value to a PID property, as follows:
fabric:profile-edit --pid PID/Key=Value ProfileName
- Append a value to a delimited list (that is, where the property value is a comma-separated list), as follows:
fabric:profile-edit --append --pid PID/Key=ListItem ProfileName
- Remove a value from a delimited list, as follows:
fabric:profile-edit --remove --pid PID/Key=ListItem ProfileName
- Delete a specific property key, as follows:
fabric:profile-edit --delete --pid PID/Key ProfileName
- Delete a complete PID, as follows:
fabric:profile-edit --delete --pid PID ProfileName
Example of editing a PID inline
io.fabric8.agent
PID, changing the Maven repository list setting. The default
profile contains a section like this:
Agent Properties : org.ops4j.pax.url.mvn.repositories = http://repo1.maven.org/maven2, http://repo.fusesource.com/nexus/content/repositories/releases, http://repo.fusesource.com/nexus/content/groups/ea, http://repository.springsource.com/maven/bundles/release, http://repository.springsource.com/maven/bundles/external, http://scala-tools.org/repo-releases
io.fabric8.agent
PID. So, by modifying the io.fabric8.agent
PID, we effectively change the agent properties. You can modify the list of Maven repositories in the agent properties PID as follows:
fabric:profile-edit --pid io.fabric8.agent/org.ops4j.pax.url.mvn.repositories=http://repositorymanager.mylocalnetwork.net default
fabric:profile-display
on the default
profile, you should see agent properties similar to the following:
Agent Properties : org.ops4j.pax.url.mvn.repositories = http://repositorymanager.mylocalnetwork.net
Setting encrypted PID property values
- Use the
fabric:encrypt-message
command to encrypt the property value, as follows:fabric:encrypt-message PropValue
This command returns the encrypted property value,EncryptedValue
.NoteThe default encryption algorithm used by Fabric isPBEWithMD5AndDES
. - You can now set the property to the encrypted value,
EncryptedValue
, using the following syntax:my.sensitive.property = ${crypt:EncryptedValue}
For example, using thefabric:profile-edit
command, you can set an encrypted value as follows:fabric:profile-edit --pid com.example.my.pid/my.sensitive.property=${crypt:EncryptedValue} Profile
Alternative method for encrypting PID property values
- Use the Jasypt
encrypt
command-line tool to encrypt the property value, as follows:./encrypt.sh input="Property value to be encrypted" password=ZooPass verbose=false
This command returns the encrypted property value,EncryptedValue
.NoteThe default encryption algorithm used by Fabric isPBEWithMD5AndDES
. You must ensure that theencrypt.sh
utility is using the same algorithm as Fabric.
Customizing the PID property encryption mechanism
- Customize the master password for encryption—using the following console command:
fabric:crypt-password-set MasterPassword
You can retrieve the current master password by entering thefabric:crypt-password-get
command. The default value is the ensemble password (as returned byfabric:ensemble-password
). - Customize the encryption algorithm—using the following console command:
fabric:crypt-algorithm-set Algorithm
Where the encryption algorithm must be one of the algorithms supported by the underlying Jasypt encryption toolkit. You can retrieve the current encryption algorithm by entering thefabric:crypt-algorithm-get
command. The default isPBEWithMD5AndDES
.
Profile editor
fabric:profile-edit
command without any options, as follows:
fabric:profile-edit Profile [Version]
Editing resources with the profile editor
broker.xml
file in the mq-amq
profile, enter the following console command:
fabric:profile-edit --resource broker.xml mq-amq
4.3. Profile Versions
Overview
fabric-agent
, will choose the defined version and retrieve all the information provided by the specific version of the profile.
Creating a new version
fabric:version-create
command (analogous to creating a new branch in the underlying Git repository). The default version is 1.0. To create version 1.1, enter the following command:
fabric:version-create 1.1
fabric:version-create --description "expanding all camel routes" 1.1
.
feature-camel
profile:
fabric:profile-display --version 1.1 feature-camel
fabric:profile-edit
command, specifying the version right after the profile argument. For example, to add the camel-jclouds
feature to version 1.1 of the feature-camel
profile, enter the following command:
fabric:profile-edit --feature camel-jclouds feature-camel 1.1
Rolling upgrades and rollbacks
mycontainer
container to the 1.1 version, invoke the fabric:container-upgrade
command as follows:
fabric:container-upgrade 1.1 mycontainer
mycontainer
to use version 1.1 of all the profiles currently assigned to it.
fabric:container-rollback
command, as follows:
fabric:container-rollback 1.0 mycontainer
--all
option, as follows:
fabric:container-upgrade --all 1.1 mycontainer
Chapter 5. Fabric8 Maven Plug-In
Abstract
5.1. Preparing to Use the Plug-In
Edit your Maven settings
~/.m2/settings.xml
file to add the fabric server's user and password so that the maven plugin can log in to the fabric. For example, you could add the following server
element to your settings.xml
file:
<settings> <servers> <server> <id>fabric8.upload.repo</id> <username>Username</username> <password>Password</password> </server> ... </servers> </settings>
Username
and Password
are the credentials of a Fabric user with administrative privileges (for example, the credentials you would use to log on to the Management Console).
Customising the repository ID
fabric8.upload.repo
. You can specify additional server
elements in your settings.xml
file for each of the fabrics you need to work with. To select the relevant credentials, you can set the serverId
property in the Fabric8 Maven plug-in configuration
section (see Section 5.4, “Configuration Properties”) or set the fabric8.serverId
Maven property.
5.2. Using the Plug-In to Deploy a Maven Project
Prerequisites
- Your Maven
~/.m2/settings.xml
file is configured as described in Section 5.1, “Preparing to Use the Plug-In”. - A JBoss Fuse container instance is running on your local machine (alternatively, if the container instance is running on a remote host, you must configure the plug-in's
jolokiaUrl
property appropriately).
Running the plug-in on any Maven project
mvn io.fabric8:fabric8-maven-plugin:1.0.0.redhat-355:deploy
Adding the plug-in to a Maven POM
pom.xml
file as follows:
<plugins> <plugin> <groupId>io.fabric8</groupId> <artifactId>fabric8-maven-plugin</artifactId> <version>1.2.0.redhat-133</version> <configuration> <profile>testprofile</profile> <version>1.2</version> </configuration> </plugin> </plugins>
plugin/configuration/version
element specifies the Fabric8 version of the target system (which is not necessarily the same as the version of the Fabric8 Maven plug-in).
mvn fabric8:deploy
What does the plug-in do?
- Uploads any artifacts into the fabric's maven repository,
- Lazily creates the Fabric profile or version you specify,
- Adds/updates the maven project artifact into the profile configuration,
- Adds any additional parent profile, bundles or features to the profile.
Example
quickstart
examples, as follows:
cd InstallDir/quickstarts/rest mvn io.fabric8:fabric8-maven-plugin:1.0.0.redhat-355:deploy
5.3. Configuring the Plug-In
Specifying profile information
configuration
element to the plug-in configuration in your pom.xml
file, as follows:
<plugins>
<plugin>
<groupId>io.fabric8</groupId>
<artifactId>fabric8-maven-plugin</artifactId>
<configuration>
<profile>my-thing</profile>
</configuration>
</plugin>
</plugins>
Multi-module Maven projects
pom.xml foo/ pom.xml a/pom.xml b/pom.xml ... bar/ pom.xml c/pom.xml d/pom.xml ...
pom.xml
file, as follows:
<plugins> <plugin> <groupId>io.fabric8</groupId> <artifactId>fabric8-maven-plugin</artifactId> </plugin> </plugins>
foo/pom.xml
file you need only define the fabric8.profile
property, as follows:
<project> ... <properties> <fabric8.profile>my-foo</fabric8.profile> ... </properties> ... </project>
foo
folder, such as foo/a
and foo/b
, will deploy to the same profile (in this case the profile, my-foo
). You can use the same approach to put all of the projects under the bar
folder into a different profile too.
fabric8.profile
property to specify exactly where it gets deployed; along with any other property on the plug-in (see the Property Reference below).
Specifying features, additional bundles, repositories and parent profiles
<plugins> <plugin> <groupId>io.fabric8</groupId> <artifactId>fabric8-maven-plugin</artifactId> <configuration> <profile>my-rest</profile> <features>fabric-cxf-registry fabric-cxf cxf war swagger</features> <featureRepos>mvn:org.apache.cxf.karaf/apache-cxf/${version:cxf}/xml/features</featureRepos> </configuration> </plugin> </plugins>
features
element allows you to specify a space-separated list of features to include in the profile.
Configuring with Maven properties
fabric8.
. For example, to deploy a maven project to the cheese
profile name, enter the command:
mvn fabric8:deploy -Dfabric8.profile=cheese
fabric8.upload=false
—for example:
mvn fabric8:deploy -Dfabric8.upload=false
Specifying profile resources
src/main/fabric8
, in your Maven project and add any resource files or a ReadMe.md
file to your project, they will automatically be uploaded into the profile as well. For example, if you run the following commands from your Maven project directory:
mkdir -p src/main/fabric8 echo "## Hello World" >> src/main/fabric8/ReadMe.md mvn fabric8:deploy
ReadMe.md
wiki page.
5.4. Configuration Properties
Specifying properties
configuration
element of the plug-in in your project's pom.xml
file. For example, the profile
property can be set as follows:
<plugins> <plugin> <groupId>io.fabric8</groupId> <artifactId>fabric8-maven-plugin</artifactId> <configuration> <profile>${fabric8.profile}</profile> </configuration> </plugin> </plugins>
fabric8.
. For example, to set the profile name, you could add the following property to your pom.xml
file:
<project> ... <properties> <fabric8.profile>my-foo</fabric8.profile> ... </properties> ...
mvn fabric8:deploy -Dfabric8.profile=my-foo
Property reference
configuration
element in the pom.xml
file or as Maven properties, when prefixed by fabric8.
):
Parameter | Description |
---|---|
profile
|
The name of the Fabric profile to deploy your project to. Defaults to the groupId-artifactId of your Maven project.
|
serverId
|
The server ID used to lookup in ~/.m2/settings/xml for the server element to find the username and password to log in to the fabric. Defaults to fabric8.upload.repo .
|
jolokiaUrl
|
The Jolokia URL of the JBoss Fuse Management Console. Defaults to http://localhost:8181/jolokia .
|
version
|
The Fabric version in which to update the profile. Defaults to the current version of the fabric. |
baseVersion
|
If the version does not exist, the baseVersion provides the initial values for the newly created version. This is like creating a branch from the baseVersion for a new version branch in git.
|
parentProfiles
|
Space-separated list of parent profile IDs to be added to the newly created profile. Defaults to karaf .
|
features
|
Space-separated list of features to add to the profile. For example, the following setting would include both the camel feature and the cxf feature: <features>camel cxf</features>
|
featureRepos
|
Space-separated list of feature repository URLs to add to the profile. The URL has the general form mvn:groupId/artifactId/version/xml/features .
|
bundles
|
Space-separated list of additional bundle URLs (of the form mvn:groupId/artifactId/version ) to add to the newly created profile. Note you do not have to include the current Maven project artifact; this configuration is intended as a way to list dependent required bundles.
|
upload
|
Whether or not the deploy goal should upload the local builds to the fabric's Maven repository. You can disable this step if you have configured your fabric's Maven repository to reuse your local maven repository. Defaults to true .
|
profileConfigDir
|
The folder in your maven project containing resource files to be deployed into the profile, along with the artifact configuration. Defaults to src/main/fabric8 . You should create the directory and add any configuration files or documentation you wish to add to your profile.
|
Chapter 6. ActiveMQ Brokers and Clusters
Abstract
fabric:mq-create
command to create and deploy clusters of brokers.
6.1. Creating a Standalone Broker Instance
MQ profiles
mq-base
- An abstract profile, which defines some important properties and resources for the broker, but should never be used directly to instantiate a broker.
mq-default
- A basic standalone broker, which inherits most of its properties from the
mq-base
profile.
fabric:profile-display
command, as follows:
JBossFuse:karaf@root> fabric:profile-display mq-default ... JBossFuse:karaf@root> fabric:profile-display mq-base ...
Creating a new broker instance
mq-default
profile.
mq-default
broker instance called broker1
, enter the following console command:
JBossFuse:karaf@root>fabric:container-create-child --profile mq-default root broker1 The following containers have been created successfully: broker1
broker1
with a broker of the same name running on it.
fabric:mq-create command
fabric:mq-create
command provides a short cut to creating a broker, but with more flexibility, because it also creates a new profile. To create a new broker instance called brokerx
using fabric:mq-create
, enter the following console command:
JBossFuse:karaf@root> fabric:mq-create --create-container broker --replicas 1 brokerx MQ profile mq-broker-default.brokerx ready
fabric:container-create-child
command, fabric:mq-create
creates a container called broker1
and runs a broker instance on it. There are some differences, however:
- The new
broker1
container is implicitly created as a child of the current container, - The new broker has its own profile,
mq-broker-default.brokerx
, which is based on themq-base
profile template, - It is possible to edit the
mq-broker-default.brokerx
profile, to customize the configuration of this new broker. - The
--replicas
option lets you specify the number of master/slave broker replicas (for more details, see Section 6.3.2, “Master-Slave Cluster”). In this example, we specify one replica (the default is two).
mq-broker-Group.BrokerName
by default. If you want the profile to have the same name as the broker (which was the default in JBoss Fuse version 6.0), you can specify the profile name explicitly using the --profile
option.
Starting a broker on an existing container
fabric:mq-create
command can be used to deploy brokers on existing containers. Consider the following example, which creates a new Fuse MQ broker in two steps:
JBossFuse:karaf@root> fabric:container-create-child root broker1 The following containers have been created successfully: broker1 JBossFuse:karaf@root> fabric:mq-create --assign-container broker1 brokerx MQ profile mq-broker-default.brokerx ready
mq-broker-default.brokerx
profile to the container, by invoking fabric:mq-create
with the --assign-container
option. Of course, instead of deploying to a local child container (as in this example), we could assign the broker to an SSH container or a cloud container.
Broker groups
fabric:mq-create
command are always registered with a specific broker group. If you do not specify the group name explicitly at the time you create the broker, the broker gets registered with the default
group by default.
--group
option of the fabric:mq-create
command. For example, to create a new broker that registers with the west-coast
group, enter the following console command:
JBossFuse:karaf@root> fabric:mq-create --create-container broker --replicas 1 --group west-coast brokery MQ profile mq-broker-default.brokery ready
west-coast
group does not exist prior to running this command, it is automatically created by Fabric. Broker groups are important for defining clusters of brokers, providing the underlying mechanism for creating load-balancing clusters and master-slave clusters. For details, see Section 6.3, “Topologies”.
6.2. Connecting to a Broker
Overview
default
group.
Client URL
discovery:(fabric:GroupName)
default
group, the client would use the following URL:
discovery:(fabric:default)
Example client profiles
example-mq
profile into a container. The example-mq
profile instantiates a pair of messaging clients: a producer client, that sends messages continuously to the FABRIC.DEMO
queue on the broker; and a consumer client, that consumes messages from the FABRIC.DEMO
queue.
example-mq
profile, by entering the following command:
JBossFuse:karaf@root> fabric:container-create-child --profile example-mq root example
example
container is successfully provisioned, using the following console command:
JBossFuse:karaf@root> watch container-list
JBossFuse:karaf@root> container-connect example JBossFuse:karaf@example> log:display
6.3. Topologies
6.3.1. Load-Balancing Cluster
Overview
loadbal
, and with three brokers registered in the group: brokerx
, brokery
, and brokerz
. This type of topology is ideal for load balancing non-persistent messages across brokers and for providing high-availability.
Figure 6.1. Load-Balancing Cluster
Create brokers in a load-balancing cluster
- Choose a group name for the load-balancing cluster.
- Each broker in the cluster registers with the chosen group.
- Each broker must be identified by a unique broker name.
- Normally, each broker is deployed in a separate container.
loadbal
and the cluster consists of three broker instances with broker names: brokerx
, brokery
, and brokerz
.
- First of all create some containers:
JBossFuse:karaf@root> container-create-child root broker 3 The following containers have been created successfully: Container: broker1. Container: broker2. Container: broker3.
- Wait until the containers are successfully provisioned. You can conveniently monitor them using the
watch
command, as follows:JBossFuse:karaf@root> watch container-list
- You can then assign broker profiles to each of the containers, using the
fabric:mq-create
command, as follows:JBossFuse:karaf@root> mq-create --group loadbal --assign-container broker1 brokerx MQ profile mq-broker-loadbal.brokerx ready JBossFuse:karaf@root> mq-create --group loadbal --assign-container broker2 brokery MQ profile mq-broker-loadbal.brokery ready JBossFuse:karaf@root> mq-create --group loadbal --assign-container broker3 brokerz MQ profile mq-broker-loadbal.brokerz ready
- You can use the
fabric:profile-list
command to see the new profiles created for these brokers:JBossFuse:karaf@root> profile-list --hidden [id] [# containers] [parents] ... mq-broker-loadbal.brokerx 1 mq-base mq-broker-loadbal.brokery 1 mq-base mq-client-loadbal ...
- You can use the
fabric:cluster-list
command to view the cluster configuration for this load balancing cluster:JBossFuse:karaf@root> cluster-list [cluster] [masters] [slaves] [services] ... fusemq/loadbal brokerx broker1 - tcp://MyLocalHost:50394 brokery broker2 - tcp://MyLocalHost:50604 brokerz broker3 - tcp://MyLocalHost:50395
Configure clients of a load-balancing cluster
discovery:(fabric:GroupName)
, which automatically load balances the client across the available brokers in the cluster. For example, to connect a client to the loadbal
cluster, you would use a URL like the following:
discovery:(fabric:loadbal)
mq-create
command automatically generates a profile named mq-client-GroupName
, which you can combine either with the example-mq-consumer
profile or with the example-mq-producer
profile to create a client of the load-balancing cluster.
loadbal
group, you can deploy the mq-client-loadbal
profile and the example-mq-consumer
profile together in a child container, by entering the following command:
JBossFuse:karaf@root> container-create-child --profile mq-client-loadbal --profile example-mq-consumer root consumer The following containers have been created successfully: Container: consumer.
loadbal
group, you can deploy the mq-client-loadbal
profile and the example-mq-producer
profile together in a child container, by entering the following command:
JBossFuse:karaf@root> container-create-child --profile mq-client-loadbal --profile example-mq-producer root producer The following containers have been created successfully: Container: producer.
JBossFuse:karaf@root> container-connect consumer JBossFuse:admin@consumer> log:display 2014-01-16 14:31:41,776 | INFO | Thread-42 | ConsumerThread | io.fabric8.mq.ConsumerThread 54 | 110 - org.jboss.amq.mq-client - 6.1.0.redhat-312 | Received test message: 982 2014-01-16 14:31:41,777 | INFO | Thread-42 | ConsumerThread | io.fabric8.mq.ConsumerThread 54 | 110 - org.jboss.amq.mq-client - 6.1.0.redhat-312 | Received test message: 983
6.3.2. Master-Slave Cluster
Overview
masterslave
, and three brokers that compete with each other to register as the broker, hq-broker
. A broker becomes the master by acquiring a lock (where the lock implementation is provided by the underlying ZooKeeper registry). The other two brokers that fail to acquire the lock remain as slaves (but they continue trying to acquire the lock, at regular time intervals).
Figure 6.2. Master-Slave Cluster
Create brokers in a master-slave cluster
- Choose a group name for the master-slave cluster.
- Each broker in the cluster registers with the chosen group.
- Each broker must be identified by the same virtual broker name.
- Normally, each broker is deployed in a separate container.
masterslave
and the cluster consists of three broker instances, each with the same broker name: hq-broker
. You can create this cluster by entering a single fabric:mq-create
command, as follows:
JBossFuse:karaf@root> mq-create --create-container broker --replicas 3 --group masterslave hq-broker
broker1
, broker2
and broker3
(possibly running on separate machines), you can deploy a cluster of three brokers to the containers by entering the following command:
JBossFuse:karaf@root> mq-create --assign-container broker1,broker2,broker3 --group masterslave hq-broker
Configure clients of a master-slave cluster
discovery:(fabric:GroupName)
, which automatically connects the client to the current master server. For example, to connect a client to the masterslave
cluster, you would use a URL like the following:
discovery:(fabric:masterslave)
mq-client-masterslave
, to create sample clients. For example, to create an example consumer client in its own container, enter the following console command:
JBossFuse:karaf@root> container-create-child --profile mq-client-masterslave --profile example-mq-consumer root consumer The following containers have been created successfully: Container: consumer.
JBossFuse:karaf@root> container-create-child --profile mq-client-masterslave --profile example-mq-producer root producer The following containers have been created successfully: Container: producer.
Locking mechanism
Re-using containers for multiple clusters
broker1
, broker2
, and broker3
, already running the hq-broker
cluster, it is possible to reuse the same containers for another highly available broker cluster, web-broker
. You can assign the web-broker
profile to the existing containers with the following command:
mq-create --assign-container broker1,broker2,broker3 web-broker
web-broker
profile to the same containers already running hq-broker
. Fabric automatically prevents two masters from running on the same container, so the master for hq-broker
will run on a different container from the master for web-broker
. This arrangement makes optimal use of the available resources.
Configuring persistent data
fabric:mq-create
command enables you to specify the location of the data directory, as follows:
mq-create --assign-container broker1 --data /var/activemq/hq-broker hq-broker
hq-broker
virtual broker, which uses the /var/activemq/hq-broker
directory for the data (and store) location. You can then mount some shared storage to this path and share the storage amongst the brokers in the master-slave cluster.
6.3.3. Broker Networks
Overview
Broker networks
Creating network connectors
--network
option to the fabric:mq-create
command.
Example broker network
Figure 6.3. Broker Network with Master-Slave Clusters
- The first cluster has the group name,
us-west
, and provides high-availability with a master-slave cluster of two brokers,us-west1
andus-west2
. - The second cluster has the group name,
us-east
, and provides high-availability with a master-slave cluster of two brokers,us-east1
andus-east2
.
us-east
group (consisting of the two containers us-east1
and us-east2
), you would log on to a root container running in the US East location and enter a command like the following:
mq-create --group us-east --network us-west --networks-username User --networks-password Pass --create-container us-east us-east
--network
option specifies the name of the broker group you want to connect to, and the User
and Pass
are the credentials required to log on to the us-west
broker cluster. By default, the fabric:mq-create
command creates a master/slave pair of brokers.
us-west
group (consisting of the two containers us-west1
and us-west2
), you would log on to a root container running in the US West location and enter a command like the following:
mq-create --group us-west --network us-east --networks-username User --networks-password Pass --create-container us-west us-west
User
and Pass
are the credentials required to log on to the us-east
broker cluster.
--assign-container
option in place of --create-container
.
Connecting to the example broker network
discovery:(fabric:us-east)
discovery:(fabric:us-west)
6.4. Broker Configuration
Overview
Setting OSGi Config Admin properties
broker1
profile created by entering the following fabric:mq-create
command:
fabric:mq-create --create-container broker --replicas 1 --network us-west brokerx
mq-broker-default.brokerx
, and assigns this profile to the newly created broker1
container.
mq-broker-Group.BrokerName
by default. If you want the profile to have the same name as the broker (which was the default in JBoss Fuse version 6.0), you can specify the profile name explicitly using the --profile
option.
mq-broker-default.brokerx
profile using the fabric:profile-display
command, as follows:
JBossFuse:karaf@root> profile-display mq-broker-default.brokerx Profile id: broker1 Version : 1.0 Parents : mq-base Associated Containers : Container settings ---------------------------- Configuration details ---------------------------- PID: io.fabric8.mq.fabric.server-brokerx standby.pool default connectors openwire broker-name broker1 data /opt/fuse-fabric/data/broker1 config profile:broker.xml group default network us-west
io.fabric8.mq.fabric.server-brokerx
PID are a variety of property settings, such as network
and group
. You can now add more properties to this PID to customize the broker configuration.
Setting network connector properties
network.NetworkPropName
. For example, to add the setting, network.bridgeTempDestinations=false
, to the PID for brokerx
, enter the following console command:
profile-edit --pid io.fabric8.mq.fabric.server-brokerx/network.bridgeTempDestinations=false brokerx
Network connector properties by reflection
network.OptionName
can be used to set the corresponding OptionName
property on the org.apache.activemq.network.NetworkBridgeConfiguration
class. In particular, this implies you can set any of the following network.OptionName
properties:
Property | Default | Description |
---|---|---|
name | bridge | Name of the network - for more than one network connector between the same two brokers, use different names |
userName | None | Username for logging on to the remote broker port, if authentication is enabled. |
password | None | Password for logging on to the remote broker port, if authentication is enabled. |
dynamicOnly | false | If true , only activate a networked durable subscription when a corresponding durable subscription reactivates, by default they are activated on start-up. |
dispatchAsync | true | Determines how the network bridge sends messages to the local broker. If true , the network bridge sends messages asynchronously. |
decreaseNetworkConsumerPriority | false | If true , starting at priority -5 , decrease the priority for dispatching to a network Queue consumer the further away it is (in network hops) from the producer. If false , all network consumers use same default priority (that is, 0 ) as local consumers. |
consumerPriorityBase | -5 | Sets the starting priority for consumers. This base value will be decremented by the length of the broker path when decreaseNetworkConsumerPriority is set. |
networkTTL | 1 | The number of brokers in the network that messages and subscriptions can pass through (sets both messageTTL and consumerTTL ) |
messageTTL | 1 | The number of brokers in the network that messages can pass through. |
consumerTTL | 1 | The number of brokers in the network that subscriptions can pass through (keep to 1 in a mesh). |
conduitSubscriptions | true | Multiple consumers subscribing to the same destination are treated as one consumer by the network. |
duplex | false | If true , a network connection is used both to produce and to consume messages. This is useful for hub and spoke scenarios, when the hub is behind a firewall, and so on. |
prefetchSize | 1000 | Sets the prefetch size on the network connector's consumer. It must be greater than 0 , because network consumers do not poll for messages |
suppressDuplicateQueueSubscriptions | false | If true , duplicate subscriptions in the network that arise from network intermediaries are suppressed. For example, consider brokers A , B , and C , networked using multicast discovery. A consumer on A gives rise to a networked consumer on B and C . In addition, C networks to B (based on the network consumer from A ) and B networks to C . When true , the network bridges between C and B (being duplicates of their existing network subscriptions to A ) will be suppressed. Reducing the routing choices in this way provides determinism when producers or consumers migrate across the network as the potential for dead routes (stuck messages) are eliminated. The networkTTL value needs to match or exceed the broker count to require this intervention. |
suppressDuplicateTopicSubscriptions | true | If true , duplicate network topic subscriptions (in a cyclic network) are suppressed. |
bridgeTempDestinations | true |
Whether to broadcast advisory messages for temporary destinations created in the network of brokers. Temporary destinations are typically created for request-reply messages. Broadcasting the information about temp destinations is turned on by default, so that consumers of a request-reply message can be connected to another broker in the network and still send back the reply on the temporary destination specified in the
JMSReplyTo header. In an application scenario where most or all of the messages use the request-reply pattern, this generates additional traffic on the broker network, because every message typically sets a unique JMSReplyTo address (which causes a new temp destination to be created and broadcasted with an advisory message in the network of brokers).
If you disable this feature, this network traffic can be reduced, but in this case the producers and consumers of a request-reply message need to be connected to the same broker. Remote consumers (that is, connected through another broker in your network) will not be able to send the reply message, but instead will raise a
temp destination does not exist exception.
|
alwaysSyncSend | false | If true , non-persistent messages are sent to the remote broker using request/reply semantics instead of oneway message semantics. This setting affects both persistent and non-persistent messages the same way. |
staticBridge | false | If true , the broker does not respond dynamically to new consumers. It uses only staticallyIncludedDestinations to create demand subscriptions. |
useCompression | false | Compresses the message body when sending it over the network. |
advisoryForFailedForward | false | If true , send an advisory message when the broker fails to forward the message to the temporary destination across the bridge. |
useBrokerNamesAsIdSeed | true | Add the broker name as a prefix to connections and consumers created by the network bridge. It helps with visibility. |
gcDestinationViews | true | If true , remove any MBeans for destinations that have not been used for a while. |
gcSweepTime | 60000 | The period of inactivity in milliseconds, after which we remove MBeans. |
checkDuplicateMessagesOnDuplex | false | If true , check for duplicates on the duplex connection. |
Broker configuration file
mq-base
profile. That is, in the ZooKeeper registry, the broker.xml
file is stored in the following location:
/fabric/configs/versions/1.0/profiles/mq-base/broker.xml
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:amq="http://activemq.apache.org/schema/core" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd"> <!-- Allows us to use system properties and fabric as variables in this configuration file --> <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"> <property name="properties"> <bean class="io.fabric8.mq.fabric.ConfigurationProperties"/> </property> </bean> <broker xmlns="http://activemq.apache.org/schema/core" brokerName="${broker-name}" dataDirectory="${data}" start="false"> <destinationPolicy> <policyMap> <policyEntries> <policyEntry topic=">" producerFlowControl="true" memoryLimit="1mb"> <pendingSubscriberPolicy> <vmCursor /> </pendingSubscriberPolicy> </policyEntry> <policyEntry queue=">" producerFlowControl="true" memoryLimit="1mb"> </policyEntry> </policyEntries> </policyMap> </destinationPolicy> <managementContext> <managementContext createConnector="false"/> </managementContext> <persistenceAdapter> <kahaDB directory="${data}/kahadb"/> </persistenceAdapter> <transportConnectors> <transportConnector name="openwire" uri="tcp://0.0.0.0:0"/> </transportConnectors> </broker> </beans>
broker-name
and data
) and it's important that you reuse them properly. The easiest way to edit this configuration is to use the Fuse Management Console (see "Management Console User Guide") or the built-in profile text editor (see Appendix A, Editing Profiles with the Built-In Text Editor).
Additional broker configuration files
mq-base
profile, for example:
/fabric/configs/versions/1.0/profiles/mq-base/mybroker.xml
mybroker.xml
configuration by invoking the fabric:mq-create
command with the --config
option, as follows:
fabric:mq-create --config mybroker.xml brokerx
--config
option assumes that the configuration file is stored in the current version of the mq-base
profile, so you need to specify only the file name (that is, the full ZooKeeper path is not required).
Part II. Fabric in Production
Abstract
Chapter 7. Fabric Ensemble and Registry
Abstract
7.1. Fabric Registry
Overview
Registry structure
fabric | +----registry (runtime registry) | | | +----containers | | | +----root | +----configs (configuration registry) | +----versions | | | +----1.0 | | | +----profiles | | | +----default | +----containers
Parts of the registry
- Configuration Registry—the logical configuration of your fabric, which typically contains no physical machine information. It contains details of the applications to be deployed and their dependencies.
- Runtime Registry—contains details of how many machines are actually running, their physical location, and what services they are implementing.
Making the registry highly available
7.2. Administering a Fabric Ensemble
Recommendations for an ensemble in production
- Deploy a minimum of five Fabric servers in production (if one server is taken down for maintenance, one other server can fail, and the Fabric registry will still be available).
- Fabric servers should be deployed on separate host machines.
- Each Fabric server should only have a Fabric registry agent deployed inside it. No other profiles should be deployed in it.
- The size of the ensemble should be fixed at the outset, and not changed later (if you subsequently add or remove containers from the ensemble, the ZooKeeper IP ports would be re-assigned).
Creating an ensemble
- Create an initial ensemble, consisting of one Fabric server.
- Expand the ensemble, by adding an even number of containers.
Creating an initial ensemble
fabric:create
console command (which converts the current container into a Fabric server, which is a sole member of the newly created ensemble). Alternatively, when creating a new container with the fabric:container-create-ssh
or fabric:container-create-cloud
commands, you can pass the --ensemble-server
option.
fabric:create
command, see Chapter 2, Creating a New Fabric.
Expanding the ensemble
fabric:ensemble-add
command. To expand the ensemble, perform the following steps:
- Create some new managed containers in the current fabric, which you can then add to the ensemble. Use the default profile for these new containers. For a production environment, it is recommended that you create at least four new managed containers (must be an even number), each running on their own host.
- While logged on to a container in the fabric, use the
fabric:ensemble-add
command to add the managed containers to the ensemble. For example, given the four managed containers,container1
,container2
,container3
, andcontainer4
, you would enter the following command:fabric:ensemble-add container1 container2 container3 container4
NoteYou must specify an even number of containers to thefabric:ensemble-add
command. - To check that the ensemble has been successfully created, invoke the
fabric:container-list
command.
Taking a Fabric server down for maintenance
fabric:container-stop
command, specifying the name of the Fabric server.
Chapter 8. Fabric Agents
Abstract
8.1. Introduction
Fabric agent
- Retrieves the profiles and versions assigned to the container on which it is running.
- Reconfigures the container.
- Calculates what needs to be installed, removed or updated on the container.
- Performs the requisite install, remove, and update actions.
Agent modules
- [fabric-configadmin]
- The Fabric configuration admin bridge. Translates the registry information into configuration information.
- [fabric-agent]
- The deployment agent. Reads the translated configuration and provisions the container accordingly.
8.2. The Configuration Admin Bridge
Overview
Information in a profile
- Configuration information—which includes:
- System configuration
- OSGi configuration
- Provisioning information—which includes lists of:
- Bundles
- Karaf features
Actions performed
io.fabric8.agent
PID (in the context of the OSGi Configuration Admin service, a PID is a named collection of property settings).
io.fabric8.agent
PID, even when there are multiple assigned profiles.
io.fabric8.agent
PID.
Configuration updates
8.3. The Deployment Agent
Actions performed
io.fabric8.agent
PID. Any change in that configuration will trigger the deployment agent.
- The deployment agent reads the whole
io.fabric8.agent
PID and calculates what bundles are to be installed in the container. - If the profiles assigned to the container specify any Karaf features, the deployment agent translates them into a list of bundles, so that the agent obtains a complete list of bundles to install.
- The deployment agent compares the list of bundles to install with the list of bundles currently installed, in order to identify:
- Bundles to uninstall,
- Bundles to install,
- Bundles to update.
- The deployment agent then performs the bundle uninstalling, installing, and updating in the container.
Downloading artifacts
- Registered Fabric Maven proxies
- Configured Maven repositories (any Maven repository configured in the profile overlay).
org.ops4j.pax.url.mvn.repositories
property of the io.fabric8.agent
PID.
org.ops4j.pax.url.mvn.repositories
property using the fabric:profile-edit
command:
fabric:profile-edit --pid io.fabric8.agent/org.ops4j.pax.url.mvn.repositories=http://repositorymanager.mylocalnetwork.net default
default
profile, which is the ancestor of all of the standard profiles, is the ideal place for this.
Container restarts
- Changes to the OSGi framework;
- Changes to the OSGi framework configuration.
Monitoring the provisioning status
fabric:container-list
command.
JBossFuse:karaf@root> fabric:container-list [id] [version] [alive] [profiles] [provision status] root* 1.0 true fabric, fabric-ensemble-0000-1 success mq1 1.0 true mq success mq2 1.0 true mq downloading billing-broker 1.0 true billing success admin-console 1.0 true web, admin-console success
fabric:container-list
command as an argument to the shell:watch
command, as follows:
shell:watch fabric:container-list
Resolution and startup ordering
Import-Package
- For each package listed here, the OBR resolver searches for a bundle that declares the package in a corresponding
Export-Package
header. Import-Service
- For each service listed here, the OBR resolver searches for a bundle that declares the service in a corresponding
Export-Service
header.
Export-Service
header to bundles that implement services. Blueprint configuration files with mandatory references to services will automatically be packaged with the Import-Service
bundle header (assuming that you use the maven-bundle-plugin
). If the bundle that exports the service does not explicitly specify an Export-Service
header, resolution will fail. To fix this error, either the exporter bundle must add an Export-Service
declaration, or the importer bundle must remove the Import-Service
directive.
Chapter 9. Allocating Ports
Abstract
9.1. The Port Service
What is the port service?
- Ports clashing with third-party services—a server machine in a production environment often has multiple services deployed on it, with a wide range of IP ports in use. In this environment, there is a relatively large risk that a Fabric container could clash with existing IP ports.
- Ports clashing with other Fabric containers—when multiple Fabric containers are deployed on the same host, it is necessary to configure their standard services with different IP ports. Setting the IP ports manually would be a considerable nuisance (and error prone).
- Ports clashing within a container—a port clash can also occur within a single container, if multiple services are competing for the same ports (for example, multiple routes binding to the same ports). Because Fabric containers are highly dynamic, we need to be able to prevent port clashes in this case, and ports must be allocated and de-allocated as services come and go.
Benefits of the port service
- Avoiding port clashes for standard container services
- Avoiding port clashes for custom services
Avoiding port clashes for standard container services
Avoiding port clashes for custom services
Using the port service in your own applications
- Use the OSGi Config Admin service to define a key, whose value is a port range. Use the following syntax to define a key:
KeyID = ${port:MinValue,MaxValue}
The preceding syntax defines the key,KeyID
, whereMinValue
specifies the minimum value of the IP port, andMaxValue
specifies the maximum value of the IP port. You can create this key using the standard Karaf commands for editing persistent IDs (PIDs) and their keys (using thefabric:profile-edit
command with the--pid
option in a Fabric container).For example, if you are logged into a Fabric container, you can see that thedefault
profile defines the key,org.osgi.service.http.port
, which specifies the container's Jetty port, as follows:FuseFabric:karaf@root> fabric:profile-display default ... PID: org.ops4j.pax.web org.ops4j.pax.web.config.checksum ${checksum:profile:jetty.xml} org.ops4j.pax.web.config.url profile:jetty.xml javax.servlet.context.tempdir ${karaf.data}/pax-web-jsp org.osgi.service.http.port ${port:8181,8282}
- In your application's XML configuration (either Spring XML or Blueprint XML), replace the literal port value in the service's address by a property placeholder—for example,
${org.osgi.service.http.port}
—which substitutes the value of the key defined in step 1.For a complete example of how to configure the property placeholder, see Section 9.2, “Using the Port Service”.
How the port service allocates a port
${port:9090,9190}
) running on a specific target host, when you start up the service for the first time, the port service allocates a port as follows:
- Determines which ports in the range are already in use on the target host (whether local or remote), by actually trying to bind to the ports.
- Checks the registered ports in the ZooKeeper registry for all of the containers deployed on the target host (even if the containers are currently not running).
- Allocates the first free port, within the specified range, that does not clash with any of the ports discovered in steps 1 and 2.
How allocated ports are stored
/fabric/registry/ports/
KeyID
, is filed under its corresponding persistent ID, PID
, and container name, ContainerName
, as follows:
/fabric/registry/ports/containers/ContainerName/PID/KeyID
Child1
, the key for the child container's Jetty port would be stored in the following ZooKeeper node:
/fabric/registry/ports/containers/Child1/org.ops4j.pax.web/org.osgi.service.http.port
Keys used by the standard container services
/fabric/registry/ports/containers/ContainerName/org.apache.karaf.shell/sshPort /fabric/registry/ports/containers/ContainerName/org.ops4j.pax.web/org.osgi.service.http.port /fabric/registry/ports/containers/ContainerName/org.apache.karaf.management/rmiServerPort /fabric/registry/ports/containers/ContainerName/org.apache.karaf.management/rmiRegistryPort
Behavior upon stopping and restarting a container
- The ports used by the container's services remain constant (after the initial allocation has occurred). You can advertise the ports to clients and be confident that the ports will remain valid over the long term.
- If, while the container is stopped, another service binds to one of the container's ports, there is a port clash when the container restarts, and the affected service fails to start (but at least we can guarantee that Fabric will not cause such a clash, because Fabric deliberately avoids re-using allocated container ports).
Deallocating ports
fabric:container-delete
command), Fabric deallocates all of the ports assigned to that container, so that they become available for use again by services in other containers. In other words, when the ContainerName
container is deleted, all of the key entries under /fabric/registry/ports/containers/ContainerName
are deleted from the ZooKeeper registry.
9.2. Using the Port Service
Overview
example-camel-cxf
profile as an example. There are two basic steps to configuring the port service in your application:
- At development time—using the property placeholder service, replace a service's fixed port number by a key.
- At deployment time—using the OSGi Config Admin service, specify the key value as a port range. For example, you can specify the key value as a PID property setting in a Fabric profile.
Demonstration code
example-camel-cxf
profile. The source code for the example is taken from the fabric-camel-cxf
example on Github, which is available from the following URL:
https://github.com/fabric8io/fabric8/tree/1.x/fabric/fabric-examples/fabric-camel-cxf
Property placeholder in XML configuration
src/main/resources/OSGI-INF/blueprint/cxf.xml
, in the fabric-camel-cxf
demonstration):
<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:cxf="http://camel.apache.org/schema/blueprint/cxf" xmlns:cm="http://aries.apache.org/blueprint/xmlns/blueprint-cm/v1.1.0" xsi:schemaLocation=" http://www.osgi.org/xmlns/blueprint/v1.0.0 http://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd http://camel.apache.org/schema/blueprint/cxf http://camel.apache.org/schema/blueprint/cxf/camel-cxf.xsd"> <cm:property-placeholder id="placeholder" persistent-id="io.fabric8.examples.camel.cxf" update-strategy="reload"> <cm:default-properties> <cm:property name="greeterPort" value="9090"/> </cm:default-properties> </cm:property-placeholder> <cxf:cxfEndpoint id="greeterEndpoint" address="http://localhost:${greeterPort}/greeter" serviceClass="io.fabric8.examples.camelcxf.Greeter"> <cxf:features> <bean class="io.fabric8.cxf.endpoint.ManagedApiFeature"/> </cxf:features> </cxf:cxfEndpoint> ... </blueprint>
cxf:cxfEndpoint
element. In the address
attribute, the port number is specified by substituting the greeterPort
key, ${greeterPort}
. The property placeholder mechanism is configured by the cm:property-placeholder
element, which specifies that the greeterPort
property belongs to the io.fabric8.examples.camel.cxf
PID. The property placeholder mechanism is integrated with the OSGi Config Admin service, which allows you to override the port number at deployment time.
Specifying a port range using OSGi Config Admin
example-camel-cxf
profile, the port number is integrated with the port service and specified as a port range.
example-camel-cxf
Fabric profile. You can see the configured port range by entering the following console command:
JBossFuse:karaf@root> fabric:profile-display example-camel-cxf
io.fabric8.examples.camel.cxf
persistent ID:
... Configuration details ---------------------------- PID: io.fabric8.examples.camel.cxf greeterPort ${port:9090,9190} ...
greeterPort
key is set to ${port:9090,9190}
.
Modifying the port range
example-camel-cxf
profile, you can do so using the fabric:profile-edit
console command. For example, to change the value of greeterPort
to the range, ${port:7070,7170}
, you would enter the following console command:
JBossFuse:karaf@root> fabric:profile-edit --pid io.fabric8.examples.camel.cxf/greeterPort=\$\{port:7070,7170\} example-camel-cxf
$
sign and the curly braces, { }
, must be escaped by the backslash character, \
, as shown. Alternatively, if you prefer to edit the port range using the built-in text editor, you can enter the following console command instead:
JBossFuse:karaf@root> fabric:profile-edit --pid io.fabric8.examples.camel.cxf example-camel-cxf
Chapter 10. Gateway
Abstract
10.1. Gateway Architecture
Deployment strategies
- Run the gateway on each machine that needs to discover services and communicate with it through
localhost
. In this case, you do not need to hard code any host names in your messaging or Web clients and the connection to the gateway onlocalhost
is nice and fast. - Run the gateway on one or more known hosts using DNS or VIP load balancing (mapping host names to machines). In thise case, you can use a fixed host name for all your services
How the gateway works
10.2. Running the Gateway
Deploy a gateway profile
gateway-mq
- Profile for a messaging gateway (for accessing Apache ActiveMQ brokers in the fabric).
gateway-http
- Profile for a HTTP gateway (for Web applications or Web services).
10.3. Configuring the Gateway
Configuring with the Management Console
HTTP mapping rules
example-quickstarts-rest
profile, that uses a URI like /cxf/crm/customerservice/customers/123
on whatever host and port it is deployed on. Hence, by default, it is visible on the gateway at http://localhost:9000/cxf/crm/customerservice/customers/123. For this example, the URI template is:
{contextPath}/
/cxf/crm
) and append /
, giving /cxf/crm/
. Any request within that path is then passed to an instance of the CXF crm
service.
Selecting part of the ZooKeeper registry
ZooKeeper Path | Description |
---|---|
/fabric/registry/clusters/apis/rest
|
REST based web services |
/fabric/registry/clusters/apis/ws
|
SOAP based web services |
/fabric/registry/clusters/servlets
|
Servlets (registered usually individually via the OSGI APIs) |
/fabric/registry/clusters/webapps
|
Web Applications (i.e. WARs) |
Segregating URI paths
/api/
and Web applications to be available under /app/
, update the URI templates as follows:
ZooKeeperPath: /fabric/registry/clusters/apis URI template: /api{contextPath}/
ZooKeeperPath: /fabric/registry/clusters/webapps URI template: /app{contextPath}/
ZooKeeperPath: /fabric/registry/clusters/apis/rest URI template: /rest{contextPath}/ ZooKeeperPath: /fabric/registry/clusters/apis/ws URI template: /ws{contextPath}/
10.4. Versioning
Explicit URIs
/version/{version}{contextPath}/
1.0
and 1.1
versions of a profile that packages Web services or Web applications, you can now access the different versions using version-specific URIs. For example, if you are running version 1.0
and version 1.1
implementations of the example-quickstarts-rest
profile, you can access either one through the following URIs:
- Version 1.0 through http://localhost:9000/version/1.0/cxf/crm/customerservice/customers/123
- Version 1.1 through http://localhost:9000/version/1.1/cxf/crm/customerservice/customers/123
Rolling upgrades
1.0
version of the gateway-http
profile and run a few services, you will see all 1.0
versions of them. If you run some 1.1
versions of these services, the gateway will not see them. If you now do a rolling upgrade of your gateway to version 1.1
, it will switch to showing only the 1.1
versions of the services.
10.5. URI Template Expressions
Variables
Expression | Description |
---|---|
{bundleName}
|
The name of the bundle that registers the Web service, servlet or application. This variable is currently not supported for Web services, but works for Web applications and servlets in an OSGi container. |
{bundleVersion}
|
The version of the bundle that registers the Web service, servlet or application. This variable is currently not supported for Web services, but works for Web applications and servlets in an OSGi container. |
{container}
|
The container ID of the container where the Web service or Web application is deployed. |
{contextPath}
|
The context path (the part of the URL after the host and port) of the Web service or Web application implementation. |
{servicePath}
|
The relative path within ZooKeeper that a service is registered. This is usually is made up of, for web services as the service name and version. For web applications its often the maven coordinates |
{version}
|
The profile version of the Web service or Web application. |
Chapter 11. Securing Fabric Containers
Abstract
Default authentication system
io.fabric8.jaas.ZookeeperLoginModule
). This system allows you to define user accounts and assign passwords and roles to the users. Out of the box, the user credentials are stored in the Fabric registry, unencrypted.
Managing users
jaas:*
family of console commands. First of all you need to attach the jaas:*
commands to the ZookeeperLoginModule
login module, as follows:
JBossFuse:karaf@root> jaas:realms Index Realm Module Class 1 karaf org.apache.karaf.jaas.modules.properties.PropertiesLoginModule 2 karaf org.apache.karaf.jaas.modules.publickey.PublickeyLoginModule 3 karaf io.fabric8.jaas.ZookeeperLoginModule JBossFuse:karaf@root> jaas:manage --index 3
jaas:*
commands to the ZookeeperLoginModule
login module. You can then add users and roles, using the jaas:useradd
and jaas:roleadd
commands. Finally, when you are finished editing the user data, you must commit the changes by entering the jaas:update
command, as follows:
JBossFuse:karaf@root> jaas:update
jaas:cancel
.
Obfuscating stored passwords
ZookeeperLoginModule
stores passwords in plain text. You can provide additional protection to passwords by storing them in an obfuscated format. This can be done by adding the appropriate configuration properties to the io.fabric8.jaas
PID and ensuring that they are applied to all of the containers in the fabric.
Enabling LDAP authentication
LDAPLoginModule
), which you can enable by adding the requisite configuration to the default profile.
Chapter 12. Configuring a Fabric's Maven Proxy
Abstract
Overview
Default repositories
- Maven Central (http://repo1.maven.org/maven2)
- Fuse Public (
https://repo.fusesource.com/nexus/content/groups/public
) - Fuse Releases (https://repo.fusesource.com/nexus/content/repositories/releases)
- Fuse Early Access (https://repo.fusesource.com/nexus/content/groups/ea)
- JBoss Public (
https://repository.jboss.org/nexus/content/repositories/public
) - SpringSource (http://repository.springsource.com/maven/bundles/release, http://repository.springsource.com/maven/bundles/external)
- User's Local (~/.m2/repository)
Changing the repositories
- Create a new profile version. From the command console this is done using the fabric:version-create command. See section "fabric:version-create" in "Console Reference" for more information.
- Change the
org.ops4j.pax.url.mvn.repositories
property in theio.fabric8.agent
PID of thedefault
profile. Example 12.1, “Configuring the Maven Proxy URL” shows the console command for editing this property.Example 12.1. Configuring the Maven Proxy URL
JBossFuse:karaf@root> fabric:profile-edit -p io.fabric8.agent/org.ops4j.pax.url.mvn.repositories = file:${runtime.home}/${karaf.default.repository}@snapshots@id=karaf-default, file:${runtime.data}/maven/upload@snapshots@id=fabric-upload, http://repo1.maven.org/maven2@id=central, https://repo.fusesource.com/nexus/content/groups/public@id=fusepublic, https://repository.jboss.org/nexus/content/repositories/public@id=jbosspublic, https://repo.fusesource.com/nexus/content/repositories/releases@id=jbossreleases, https://repo.fusesource.com/nexus/content/groups/ea@id=jbossearlyaccess, http://repository.springsource.com/maven/bundles/release@id=ebrreleases, http://repository.springsource.com/maven/bundles/external@id=ebrexternal
NoteTheio.fabric8.agent
PID is refined in all of the fabric profiles. Setting the proxy URL, theorg.ops4j.pax.url.mvn.repositories
property, in thedefault
profile ensures that all of the other fabric profiles share the same Maven proxy setting.ImportantThefabric
profile'sio.fabric8.maven
PID, which ultimately controls the Maven proxy, imports its value from thedefault
profile'sio.fabric8.agent
PID. You should not change the settings of theio.fabric8.maven
PID.Alternatively, instead of resetting the entire list of repositories, you can append a new entry to the repository list by invokingfabric:profile-edit
with the--append
option, as follows:JBossFuse:karaf@root> profile-edit --pid io.fabric8.agent/org.ops4j.pax.url.mvn.repositories='http://fusewin.tpb.lab.eng.brq.redhat.com:8081/nexus/content/repositories/fuse-qe-repo@id=fuse-qa' --append default 1.1
- Roll the changes out the fabric by upgrading the containers to the new profile version.ImportantYou cannot test this configuration change out on a few containers to validate it. The change must be made to the entire fabric or it will result in conflicts.
Using an HTTP proxy with the Maven proxy
settings.xml
file that includes an HTTP proxy configuration.
- Prepare an HTTP proxy settings file (see Example 12.2, “Example HTTP proxy settings
.xml
file” for example content), and put it in the Red Hat JBoss Fuse InstallDir/fuse/
directory. - Start up JBoss Fuse, and create a fabric. For details, see the section called “Steps to create the fabric”.
- Specify the name and location of the HTTP settings file. At the
JBossFuse:karaf@root>
command line, type:profile-edit --pid io.fabric8.maven/io.fabric8.maven.settings=/home/fuse/http-proxy-settings.xml default
- Remove the org.ops4j.pax,url.mvn.repositories property from the
default
profile. At theJBossFuse:karaf@root>
command line, type:profile-edit --delete --pid io.fabric8.agent/org.ops4j.pax.url.mvn.repositories default
Removing this property causes the Maven proxy to pick up repositories from Maven's/home/.m2/settings.xml
file, pointed to in the/home/fuse/http-proxy-settings.xml
file.All fabric Maven proxy requests for remote repositories will now be redirected to the HTTP proxy server.
Example 12.2. Example HTTP proxy settings .xml
file
<settings xmlns="http://maven.apache.org/SETTINGS/1.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/SETTINGS/1.0.0 http://maven.apache.org/xsd/settings-1.0.0.xsd"> <!-- localRepository contains the path to the local repository maven will use to store artifacts. Default: ~/.m2/repository --> <localRepository>/home/fuse/.m2/repository</localRepository> <proxies> <proxy> <id>qeos-proxy-1</id> <active>true</active> <protocol>http</protocol> <host>10.8.50.13</host> <port>3128</port> </proxy> </proxies> <profiles> <profile> <id>fuse-repo</id> <repositories> <repository> <id>fuse-qe-repo</id> <url>http://fusewin.tpb.lab.eng.brq.redhat.com:8081/nexus/content/repositories/fuse-qe-repo</url> <layout>default</layout> </repository> <repository> <id>central</id> <url>http://repo1.maven.org/maven2@id=maven.central.repo</url> <layout>default</layout> </repository> </repositories> </profile> </profiles> <activeProfiles> <activeProfile>fuse-repos</activeProfile> </activeProfiles> </settings>
Chapter 13. Offline Repositories
Abstract
13.1. Offline Repository for a Profile
Download into a specified directory
ProfileName
, enter the following console command:
fabric:profile-download --profile ProfileName /tmp/myrepo
/tmp/myrepo
directory.
Download into the system folder
fabric:profile-download
command installs the files to the system
folder inside the current Fuse container (thereby populating the local maven repository for the container). For example:
fabric:profile-download --profile ProfileName
13.2. Offline Repository for a Version
Download the current version
fabric:profile-download /tmp/myrepo
Download a specific version
--version
option, as follows:
fabric:profile-download --version 1.0 /tmp/myrepo
fabric:profile-download
command installs the files into thesystem
folder inside the current Fuse container (thereby populating the local maven repository for the container).
13.3. Offline Repository for a Maven Project
Download repository for Maven project
pom.xml
file), you should be able to run the following Maven command:
mvn org.apache.maven.plugins:maven-dependency-plugin:2.8:go-offline -Dmaven.repo.local=/tmp/cheese
/tmp/cheese
directory.
Chapter 14. Configuring with Git
Abstract
14.1. How Git Works inside Fabric
Cluster architecture
- Each Fabric server has its own clone of the Git configuration.
- One Fabric server is elected to be the master instance, and serves as the master remote repository for the other Fabric servers.
- All configuration changes made in the other Fabric servers (the slave instances) are pushed to the master instance.
- When changes occur in the master, the slaves automatically pull the new configuration from the master.
- If the master instance is stopped, another container is elected to be the master (failover).
- An administrator can access the Git configuration layer by cloning a local Git repository from the master instance. By pushing updates from this local repository, the administrator can change the configuration of the fabric.
External Git repository architecture
- The external Git repository is created in an external Git server (for example, using a service such as GitLab or Gerrit).
- When the Fabric is created, it automatically populates the external Git repository with the default configuration (which is initialized by reading the
InstallDir/fabric/import
directory). - Each Fabric server maintains a synchronized state with the external Git repository.
- All configuration changes made in the Fabric servers are pushed to the external Git repository.
- When changes occur in the external Git repository, the Fabric servers automatically pull the new configuration from the external Git repository.
- An administrator can access the Git configuration layer by cloning a local Git repository from the external Git repository. By pushing updates from this local repository to the external Git repository, the administrator can change the configuration of the fabric.
What is stored in the Git repositories?
Git branches
JBossA-MQ:karaf@root> fabric:version-create Created version: 1.1 as copy of: 1.0
1.1
. In fact, most of the Fabric version commands are approximately equivalent to a corresponding git
command, as shown in the following table:
Fabric Version Command | Analogous Git Command |
---|---|
fabric:version-create NewBranch
|
git branch NewBranch
|
fabric:version-list
|
git branch
|
fabric:version-set-default Branch
|
git checkout Branch
|
fabric:version-delete Branch
|
git branch -d Branch
|
Configuring through the console commands
fabric:profile-create
, new files are added to the Git repository, and the changes are committed. Similarly, when you edit a profile using the fabric:profile-edit
command, these changes are added and committed to the underlying Git repository.
Prerequisites
git
binaries to be installed on your system, because it is implemented using the JGit library. You will need to install Git binaries on your local system, however, if you want to configure Fabric directly through Git, using a clone of the Git repository.
Configuring directly through Git
14.2. Using a Git Cluster
Overview
Figure 14.1. Git Cluster Architecture

Clone the Git repository
$ git clone -b 1.0 http://Hostname:Port/git/fabric
Hostname
and Port
are the hostname and IP port of the master Fabric server. Note the following points:
- The port number,
Port
, is usually8181
, by default. But if you deploy multiple Fabric containers on the same host, their HTTP ports are automatically incremented, 8182, 8183, (or whichever is the next available port number at the time the container is created). - The
-b
option is used to check out the1.0
Git branch, which corresponds to version 1.0 of the Fabric profile data. There is also amaster
branch, but it is normally not used by the Fabric servers. - You can also see a sample clone command in the Fuse Management Console, if you navigate to the Container: page for the relevant container, click on the URLs tag, and go to the Git: field. Note, however, that if you try to clone from a slave instance, you will get an error (the Fuse Management Console currently does not indicate whether the container is a slave or a master).
InstallDir/data/git/local/fabric
directory (which holds the container's local Git repository). This approach does not work. When you push and pull to the container's HTTP port, it automatically triggers synchronization events within the Git cluster. These necessary synchronizations would be bypassed, if you cloned from a directory.
Authentication
- Let Git prompt you for credentials—this is the default, if you use a Git URL of the form,
http://Hostname:Port/git/fabric
. - Embed credentials in the Git URL—you can embed the credentials directly in the Git URL, using the following syntax:
http://User:Pass@Hostname:Port/git/fabric
Basic tasks with Git
- Push to the Fabric Git server—you can use your local Git repository to edit profile configurations and push the changes up to the fabric. For example, to edit the Camel route in the
example-camel-twitter
profile:- Make sure that you are working in the correct branch (initially, this should be branch
1.0
):$ cd LocalGitRepo $ git checkout 1.0
- Edit the following Blueprint XML file in your local Git repository, to alter the Camel route:
LocalGitRepo/fabric/profiles/example/camel/twitter.profile/camel.xml
- Add and commit the changes locally, using Git commands:
$ git add -u $ git commit -m "Changed the route in example-camel-twitter"
- Push the changes to the fabric:
$ git push
This updates the configuration in all of the Fabric servers in the Git cluster. If any of the containers in your fabric have deployed theexample-camel-twitter
profile, they will immediately be updated with the changes.
- Pull from the Fabric Git server—if you change the profile configuration using commands in the Karaf console, you can synchronize those changes with your local Git repository by doing a
git pull
. For example, to edit the Camel route in theexample-camel-twitter
profile from the Karaf console:- In the Karaf console, you can edit the Camel route from the
example-camel-twitter
profile by entering the following console command:fabric:profile-edit --resource camel.xml example-camel-twitter
- You can now synchronize your local Git repository to these changes. Open a command prompt, and enter the following commands:
$ cd LocalGitRepo $ git checkout 1.0
- Pull the changes from the fabric:
$ git pull
What happens after a failover?
origin
upstream repository. But what happens if there is a failover? For example, if the Fabric server that is the master instance is stopped and restarted. If your ensemble consists of only one Fabric server, this makes no difference, because there is no other server to fail over to. But if there are three (or five) servers in your ensemble, one of the other Fabric servers will automatically be elected as the new master.
git push
or a git pull
after failover, you will get the following error:
$ git pull fatal: repository 'http://Hostname:8181/git/fabric/' not found
Adding multiple upstream repositories
$ git remote add ensemble2 Ensemble2GitURL $ git remote add ensemble3 Ensemble2GitURL
$ git push UpstreamName BranchName
1.0
of the ensemble2
Git server:
$ git push ensemble2 1.0
origin
, ensemble2
, ensemble3
, is accessible at one time, however (whichever is the master).
Git cluster tutorial
- (Optional) Prepare the container for a cold start. Delete the following directories:
InstallDir/data InstallDir/instances
WarningPerforming a cold start completely wipes the current state of the root container, including all of the deployed bundles, and features, and most of the stored data. Do not perform this operation on a production system. - Start up the container, by entering the following command:
./bin/fuse
- Create a new fabric. At the container prompt, enter the following console command:
fabric:create --new-user admin --new-user-password AdminPass --new-user-role Administrator \ --zookeeper-password ZooPass --global-resolver manualip \ --resolver manualip --manual-ip 127.0.0.1 --wait-for-provisioning
You need to substitute your own values forAdminPass
andZooPass
. This sample command uses the--manual-ip
option to assign the loopback address,127.0.0.1
, to the root container. If your host has a static IP address and hostname assigned to it, however, it would be better to use the assigned hostname here instead.You need to wait a minute or two for this command to complete. - Create two new child containers in the fabric, by entering the following console command:
fabric:container-create-child --profile fabric root ensemble 2
This command returns quickly, with the following message:The following containers have been created successfully: Container: ensemble. Container: ensemble2.
But it takes a couple of more minutes for the new child containers to be completely provisioned. Check the status of the child containers, by entering the following command:fabric:container-list
Wait until the child containers have a[provision status]
ofsuccess
before proceeding. - Add the two child containers to the Fabric ensemble, so that the Fabric ensemble consists of three containers in all:
root
,ensemble
, andensemble2
. Enter the following console command:fabric:ensemble-add ensemble ensemble2
Wait until the ensemble containers have been successfully provisioned before proceeding. - Clone the Git repository. The three containers in the Fabric ensemble now constitute a Git cluster. Initially, the
root
container is the master instance of the cluster, so you should attempt to clone the Git repository from the HTTP port exposed by theroot
container.Open a new command prompt and, at a convenient location in the file system, enter the following command:git clone -b 1.0 http://127.0.0.1:8181/git/fabric
This command clones the Fabric Git repository and checks out the1.0
branch. You should now be able to see the profile configuration files under thefabric/profiles
subdirectory.If theroot
container is not the current master, you can expect to see an error message like the following when you attempt to clone:Cloning into 'fabric'... fatal: repository 'http://127.0.0.1:8181/git/fabric/' not found
- In the next few steps, we explore the failover behaviour of the Git cluster. First of all, we stop the
root
container (the current Git master), in order to force a failover. In the root container console, enter theshutdown
command, as follows:JBossA-MQ:karaf@root> shutdown Confirm: shutdown instance root (yes/no): yes
- Now restart the root container, by entering the following command:
./bin/fuse
- Return to the command prompt where you cloned the Git repository and try to do a
git pull
, as follows:cd fabric git pull
You will get an error like the following:$ git pull fatal: repository 'http://127.0.0.1:8181/git/fabric/' not found
Because the root container (listening on IP port 8181) is no longer the master.NoteIn this example, because all of the ensemble containers are running on the same host, the ensemble containers are distinguished by having different IP port numbers (8181, 8182, and 8183). If you created the other ensemble containers on separate hosts, however, they would all have the same port number (8181), but different host names. - One of the other Fabric servers (
ensemble
orensemble2
) is now the master. To gain access to the master, try adding both of the alternative Git URLs as upstream repositories. From a directory in the cloned Git repository, enter the following commands:$ git remote add ensemble http://127.0.0.1:8182/git/fabric $ git remote add ensemble2 http://127.0.0.1:8183/git/fabric
- You can now try pulling from one of the other Fabric servers. You can either pull from the
ensemble
container (pulling branch1.0
), as follows:$ git pull ensemble 1.0
Or from theensemble2
container (pulling branch1.0
), as follows:$ git pull ensemble2 1.0
Only one of these alternatives can succeed (pulling from the master). Pulling from the slave instance returns an error. - After you have identified the current master, you can proceed to push and pull using the long form of the
git
commands (for example,git pull RemoteName BranchName
).
14.3. Using a Git HTTP Proxy
Configuring a Git HTTP proxy
GitProxyService
.
$ fabric:profile-edit --pid io.fabric8.git.proxy/proxyHost=servername default $ fabric:profile-edit --pid io.fabric8.git.proxy/proxyPort=portNumber default
14.4. Using an External Git Repository
Overview
Figure 14.2. External Git Repository Architecture

External git repository architecture
data/
directories), but this local copy is kept up-to-date by regularly polling the external Git repository for updates. If a change is detected in the external Git repository, every Fabric server will do a git pull
to update it's local copy of the Git repository.
git
commands, the administrator can now edit the configuration files in the local copy and push the changes to the external Git repository. As soon as those changes are received by the external Git repository, the Fabric servers will detect that an update has occurred and pull the latest configuration.
Preparing an external Git repository
- The Git repository must be initialized. For example, if you were creating a new Git repository on your local file system, you would initialize it using the command
git init
. If you are using a Git server to host your repository (for example, Gerrit, GitLab, or GitHub), the Git repository is usually initialized automatically, after you create it. - You must ensure that all of your Fabric servers are able to access the external Git repository. For example, if your Git server uses a HTTP based protocol to access the repository, you are generally required to have username/password credentials for the HTTP BASIC authentication protocol.
Authentication
- HTTP URL—in this case, the Git server is likely to use HTTP with TLS (HTTPS), to verify the server identity, and HTTP BASIC authentication, to verify the client identity. When creating the fabric (with the
fabric:create
command), you need to specify the following additional options in this case:--external-git-url ExternalGitHttpUrl
--external-git-user ExternalGitUser
--external-git-password ExternalGitPass
- File URL—in this case, no authentication is required. You can specify the Git URL either in the form
/path/to/repo
(recommended) orfile:///path/to/repo
(slower). If the Fabric servers are deployed on separate hosts, you must make sure that they all have access to the specified directory (for example, through a Network File Server). When creating the fabric (with thefabric:create
command), you need to specify the following additional options in this case:--external-git-url ExternalGitFileUrl
Creating a fabric with an external Git repository
fabric:create --new-user admin --new-user-password AdminPass --new-user-role Administrator \ --zookeeper-password ZooPass --global-resolver manualip \ --resolver manualip --manual-ip StaticIPAddress --wait-for-provisioning \ --external-git-url ExternalGitHttpUrl \ --external-git-user ExternalGitUser --external-git-password ExternalGitPass
- A new user is created with username,
admin
, password,AdminPass
, and role,Administrator
. You can use these JAAS credentials to log on to any of the containers in the fabric. - The Zookeeper password is set to
ZooPass
(the only time you are prompted to enter the Zookeeper password is when joining a container to the fabric). - The resolver policy for the root container is set to
manualip
(using the--resolver
option) and the global resolver policy (which becomes the default resolver policy for containers created in this fabric) is also set tomanualip
. This enables you to specify the root container's IP address,StaticIPAddress
, explicitly. It is essential that you assign a static IP address to the Fabric server host (for demonstrations and tests on a single machine, you can use the loopback address,127.0.0.1
). - The Git URL,
ExternalGitHttpUrl
, is specified through the--external-git-url
option. - Assuming that you use a HTTP Git URL with BASIC authentication enabled, you will also need to specify credentials, using the
--external-git-user
and--external-git-password
options.
What happens if the external Git repository fails?
External Git repository tutorial
- Create a new (empty) Git repository, which you can use as the external Git repository. Typically, you would create the Git repository in a hosting service, such as GitLab, Gerrit, or GitHub. Make a note of the new repository's HTTP URL,
ExternalGitHttpUrl
, and make sure that it is possible to access the external Git repository from the hosts where you will be deploying your Fabric servers. - (Optional) Prepare the container for a cold start. Delete the following directories:
InstallDir/data InstallDir/instances
WarningPerforming a cold start completely wipes the current state of the root container, including all of the deployed bundles, and features, and most of the stored data. Do not perform this operation on a production system. - Start up the container, by entering the following command:
./bin/fuse
- Create a new fabric. At the container prompt, enter the following console command:
fabric:create --new-user admin --new-user-password AdminPass --new-user-role Administrator \ --zookeeper-password ZooPass --global-resolver manualip \ --resolver manualip --manual-ip 127.0.0.1 --wait-for-provisioning \ --external-git-url ExternalGitHttpUrl \ --external-git-user ExternalGitUser --external-git-password ExternalGitPass
You need to substitute your own values forAdminPass
andZooPass
. TheExternalGitHttpUrl
is the HTTP URL of the external Git repository you created earlier and theExternalGitUser
value and theExternalGitPass
value are the username/password credentials required to access the external Git repository (using HTTP BASIC authentication).This sample command uses the--manual-ip
option to assign the loopback address,127.0.0.1
, to the root container. If your host has a static IP address and hostname assigned to it, however, it would be better to use the assigned hostname here instead.You need to wait a minute or two for this command to complete. - After your fabric has been created, navigate to the contents of the external Git repository in your browser (assuming that your Git server supports this functionality). The external repository should now be populated with the default configuration of your fabric, with two branches available:
master
and1.0
. The1.0
branch is the branch that is initially used by your fabric. - Create a local clone of the external Git repository, which you can then use to push or pull profile configurations. Open a new command prompt and, in a convenient location on the file system, enter the following command:
git clone -b 1.0
ExternalGitHttpUrl
Thisgit
command will prompt you to enter the username and password credentials for the external Git repository.This command clones the Fabric Git repository and checks out the1.0
branch. You should now be able to see the profile configuration files under thefabric/profiles
subdirectory. - You can now use regular
git
commands to configure your Fabric profiles. Simply edit the files in your local Git repository, add the changes, commit, and then push the changes to the external Git repository (working in the1.0
branch). Shortly after the changes are pushed to the external Git repository, the containers in your Fabric ensemble (the Fabric servers) will poll the repository, pull the changes, and redeploy any changed profiles..
14.5. Using an HTTP Proxy with a Git Cluster
- Start up JBoss Fuse, and create a fabric. For details, see the section called “Steps to create the fabric”.
- At the
JBossFuse:karaf@root>
command line, type:profile-edit --pid io.fabric8.git.proxy/proxyHost=serverName default profile-edit --pid io.fabric8.git.proxy/proxyPort=portNumber default
These commands specify the hostname and port to use, and thedefault
profile is updated with the new configuration.For example:profile-edit --pid io.fabric8.git.proxy/proxyHost=10.8.50.60 default profile-edit --pid io.fabric8.git.proxy/proxyPort=3128 default
All changes made to the fabric configuration will now be redirected to the Git HTTP proxy on host10.8.50.60
's port3128
.
Chapter 15. Patching
15.1. Patching a Container in a Fabric
Abstract
Overview
Is it necessary to patch the underlying container?
fabric:create
command). Always read the patch README
file to find out whether there are any special steps required to install a particular patch.
Using the management console
Using the command console
- Before you proceed to install the patch, make sure to read the text of the
README
file that comes with the patch, as there might be additional manual steps required to install a particular patch. - Create a new version, using the
fabric:version-create
command:JBossFuse:karaf@root> fabric:version-create 1.1 Created version: 1.1 as copy of: 1.0
ImportantThe version name must be a pure numeric string, such as1.1
,1.2
,2.1
, or2.2
. You cannot incorporate alphabetic characters in the version name (such as1.0.patch
). - Apply the patch to the new version, using the
fabric:patch-apply
command. For example, to apply theactivemq.zip
patch file to version1.1
:JBossFuse:karaf@root> fabric:patch-apply --version 1.1 file:///patches/activemq.zip
- Upgrade the container using the
fabric:container-upgrade
command, specifying which container you want to upgrade. For example, to upgrade theroot
container, enter the following command:JBossFuse:karaf@root> fabric:container-upgrade 1.1 root Upgraded container root from version 1.0 to 1.1
ImportantIt is recommended that you upgrade only one or two containers to the patched profile version, to ensure that the patch does not introduce any new issues. When you are certain that the patch works as expected, upgrade the remaining containers in the fabric. - You can check that the new patch profile has been created using the
fabric:profile-list
command, as follows:BossFuse:karaf@root> fabric:profile-list --version 1.1 | grep patch default 0 patch-activemq-patch patch-activemq-patch
Where we presume that the patch was applied to profile version 1.1.TipIf you want to avoid specifying the profile version (with--version
) every time you invoke a profile command, you can change the default profile version using thefabric:version-set-default Version
command.You can also check whether specific JARs are included in the patch, for example:JBossFuse:karaf@root> list | grep -i activemq [ 131] [Active ] [Created ] [ ] [ 50] activemq-osgi (5.9.0.redhat-61037X) [ 139] [Active ] [Created ] [ ] [ 50] activemq-karaf (5.9.0.redhat-61037X) [ 207] [Active ] [ ] [ ] [ 60] activemq-camel (5.9.0.redhat-61037X)
Appendix A. Editing Profiles with the Built-In Text Editor
Abstract
profile-edit
command with no arguments except for the profile's name (and optionally, version); or adding the --pid
option for editing OSGi PID properties; or adding the --resource
option for editing general resources.
A.1. Editing Agent Properties
Overview
Open the agent properties resource
JBossFuse:karaf@root> profile-edit Profile [Version]
Profile
is the name of the profile to edit and you can optionally specify the profile version, Version, as well. The text editor opens in the console window, showing the current profile name and version in the top-left corner of the Window. The bottom row of the editor screen summarizes the available editing commands and you can use the arrow keys to move about the screen.
Specifying feature repository locations
repository.ID=URL
ID
is an arbitrary unique identifier and URL
gives the location of a single feature repository (only one repository URL can be specified on a line).
Specifying deployed features
feature.ID=FeatureName
ID
is an arbitrary unique identifier and FeatureName
is the name of a feature.
Specifying deployed bundles
bundle.ID=URL
ID
is an arbitrary unique identifier and URL
specifies the bundle's location.
blueprint:
(or spring:
) URL handler to deploy a Blueprint XML resource (or a Spring XML resource) as an OSGi bundle.
Specifying bundle overrides
override.ID=URL
ID
is an arbitrary unique identifier and URL
specifies the bundle's location.
Specifying etc/config.properties properties
etc/config.properties
in a standalone container), add a line in the following format:
config.Property=Value
Specifying etc/system.properties properties
etc/system.properties
in a standalone container), add a line in the following format:
system.Property=Value
Property
, is already set at the JVM level (for example, through the --jvm-opts
option to the fabric:container-create
command), the preceding fabric:profile-edit
command will not override the JVM level setting. To override a JVM level setting, set the system property as follows:
system.karaf.override.Property=Value
Specifying libraries to add to Java runtime lib/
lib/
directory of the underlying Java runtime), add a line in the following format:
lib.ID=URL
ID
is an arbitrary unique identifier and URL
specifies the library's location.
Specifying libraries to add to Java runtime lib/ext/
lib/ext/
directory of the underlying Java runtime), add a line in the following format:
ext.ID=URL
ID
is an arbitrary unique identifier and URL
specifies the extension library's location.
Specifying libraries to add to Java runtime lib/endorsed/
lib/endorsed/
directory of the underlying Java runtime), add a line in the following format:
endorsed.ID=URL
ID
is an arbitrary unique identifier and URL
specifies the endorsed library's location.
Example
mq-client
profile's agent properties for editing, enter the following console command:
JBossFuse:karaf@root> profile-edit mq-client
Profile:mq-client 1.0 L:1 C:1 # # Copyright (C) Red Hat, Inc. # http://redhat.com # # 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. # repository.activemq=mvn:org.apache.activemq/activemq-karaf/${version:activemq}/xml/features repository.karaf-standard=mvn\:org.apache.karaf.assemblies.features/standard/${version:karaf}/ xml/features ^X Quit ^S Save ^Z Undo ^R Redo ^G Go To ^F Find ^N Next ^P Previous
^X
to quit the text editor and get back to the console prompt.
A.2. Editing OSGi Config Admin Properties
Overview
Persistent ID
PID
persistent ID are defined in the PID.properties
resource.
Open the Config Admin properties resource
PID
persistent ID, enter the following console command:
JBossFuse:karaf@root> profile-edit --pid PID Profile [Version]
--resource PID.properties
in the profile-edit
command, instead of using the --pid PID
option.
Specifying OSGi config admin properties
PID.properties
resource (which is actually stored in the ZooKeeper registry). To edit the properties, add, modify, or delete lines of the following form:
Property=Value
Example
io.fabric8.hadoop
PID in the hadoop-base
profile, enter the following console command:
JBossFuse:karaf@root> profile-edit --resource io.fabric8.hadoop.properties hadoop-base 1.0
Profile:hadoop-base 1.0 L:1 C:1 # # Copyright (C) Red Hat, Inc. # http://redhat.com # # 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. # fs.default.name=hdfs\://localhost\:9000 dfs.replication=1 mapred.job.tracker=localhost\:9001 dfs.name.dir=${karaf.data}/hadoop/dfs/name dfs.http.address=0.0.0.0\:9002 dfs.data.dir=${karaf.data}/hadoop/dfs/data dfs.name.edits.dir=${karaf.data}/hadoop/dfs/name ^X Quit ^S Save ^Z Undo ^R Redo ^G Go To ^F Find ^N Next ^P Previous
\:
). Strictly speaking, it is only necessary to escape a colon if it appears as part of a property name (left hand side of the equals sign), but the profile-edit
command automatically escapes all colons when it writes to a resource. When manually editing resources using the text editor, however, you do not need to escape colons in URLs appearing on the right hand side of the equals sign.
^X
to quit the text editor and get back to the console prompt.
A.3. Editing Other Resources
Overview
Creating and editing an arbitrary resource
JBossFuse:karaf@root> profile-edit --resource Resource Profile [Version]
Resource
is the name of the profile resource you want to edit. If Resource
does not already exist, it will be created.
broker.xml example
mq-base
profile has the broker.xml
resource, which stores the contents of an Apache ActiveMQ broker configuration file. To edit the broker.xml
resource, enter the following console command:
JBossFuse:karaf@root> profile-edit --resource broker.xml mq-base 1.0
Profile:mq-base 1.0 L:1 C:1 <!-- Copyright (C) FuseSource, Inc. http://fusesource.com 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. --> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:amq="http://activemq.apache.org/schema/core" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd"> <!-- Allows us to use system properties and fabric as variables in this configuration file --> <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"> <property name="properties"> <bean class="org.fusesource.mq.fabric.ConfigurationProperties"/> </property> ^X Quit ^S Save ^Z Undo ^R Redo ^G Go To ^F Find ^N Next ^P Previous
^X
to quit the text editor and get back to the console prompt.
Referencing a profile resource
broker.xml
resource from the previous example is stored under the following ZooKeeper location:
zk:/fabric/configs/versions/1.0/profiles/mq-base/broker.xml
Version
, of the Profile
profile's Resource
resource at the following location:
zk:/fabric/configs/versions/Version/profiles/Profile/Resource
mq
profile's org.fusesource.mq.fabric.server-broker
PID defines the following properties, where the config
property references the broker.xml
resource:
connectors=openwire
config=zk\:/fabric/configs/versions/1.0/profiles/mq-base/broker.xml
group=default
standby.pool=default
A.4. Profile Attributes
Overview
parents attribute
parents
attribute is a list of one or more parent profiles. This attribute can be set using the profile-change-parents
console command. For example, to assign the parent profiles camel
and cxf
to the my-camel-cxf-profile
profile, you would enter the following console command:
JBossFuse:karaf@root> profile-change-parents --version 1.0 my-camel-cxf-profile camel cxf
abstract attribute
abstract
attribute is set to true
, the profile cannot be directly deployed to a container. This is useful for profiles that are only intended to be the parents of other profiles—for example, mq-base
. You can set the abstract attribute from the Management Console.
locked attribute
hidden attribute
hidden
attribute is a flag that is typically set on profiles that Fabric creates automatically (for example, to customize the setup of a registry server). By default, hidden profiles are not shown when you run the profile-list
command, but you can see them when you add the --hidden
flag, as follows:
JBossFuse:karaf@root> profile-list --hidden ... fabric 1 karaf fabric-ensemble-0000 0 fabric-ensemble-0000-1 1 fabric-ensemble-0000 fmc 0 default ...
Appendix B. Fabric URL Handlers
Abstract
B.1. Profile URL handler
profile:ResourceName
- The profile URL handler first tries to find the named resource,
ResourceName
, in the current version of the current profile (where the current version is a property of the container in which the profile is running). - If the specified resource is not found in the current profile, the profile URL tries to find the resource in the current version of the parent profile.
fabric:container-upgrade
or fabric:container-rollback
console commands), the referenced resources are also, automatically, upgraded or rolled back.
B.2. Zk URL handler
zk:/PathToNode
zk:ContainerName/Property
zk:/fabric/registry/containers/config/ContainerName/Property
B.3. Blueprint URL handler
blueprint:
scheme can be prefixed to any of the usual location URL handlers (for example, file:
, http:
, profile:
, zk:
).
bundle
entry in the agent properties (equivalent to the io.fabric8.agent
PID) in the following format:
bundle.ID=blueprint:LocationScheme:LocationOfBlueprintXML
camel.xml
resource (Blueprint file) from the current profile, you would add the following bundle
entry:
bundle.camel-fabric=blueprint:profile:camel.xml
B.4. Spring URL handler
spring:
scheme can be prefixed to any of the usual location URL handlers (for example, file:
, http:
, profile:
, zk:
).
bundle
entry in the agent properties (equivalent to the io.fabric8.agent
PID) in the following format:
bundle.ID=spring:LocationScheme:LocationOfBlueprintXML
camel-spring.xml
, from the current profile, you could add the following entry to the profile's agent properties:
bundle.spring-resource=spring:profile:camel-spring.xml
Appendix C. Profile Property Resolvers
Abstract
${ResourceReference}
. This variable substitution mechanism can be used in any profile resource, including the agent properties, PID properties, and other resources—for example, the mq-base
profile's broker.xml
resource references the ${broker.name}
and ${data}
variables.
C.1. Substituting system properties
Syntax
${PropName}
PropName
can be the name of any Java system property. In particular, Java system properties can be defined in the following locations:
- The
etc/system.properties
file, relative to the container's home directory. - System property settings in the profile's agent properties.
etc/system.properties
file are, as follows:
System Property | Description |
---|---|
${karaf.home} | The directory where Red Hat JBoss Fuse is installed. |
${karaf.data} | Location of the current container's data directory, which is usually ${karaf.home}/data for a main container or ${karaf.home}/instances/InstanceName/data for a child container. |
${karaf.name} | The name of the current container. |
C.2. Substituting environment variables
Syntax
${env:VarName}
C.3. Substituting container attributes
Syntax
${container:Attribute}
Attribute | Description |
---|---|
${container:resolver} | The effective resolver policy for the current container. Possible values are: localip , localhostname , publicip , publichostname , manualip . |
${container:ip} | The effective IP address used by the current container, which has been selected by applying the resolver policy. This is the form of host address that is advertised to other containers and applications. |
${container:localip} | The numerical IP address of the current container, which is suitable for accessing the container on a LAN. |
${container:localhostname} | The host name of the current container, which is suitable for accessing the container on a LAN. |
${container:publicip} | The numerical IP address of the current container, which is suitable for accessing the container from a WAN (on the Internet). |
${container:publichostname} | The host name of the current container, which is suitable for accessing the container from a WAN (on the Internet). |
${container:manualip} | An IP address that is specified manually, by setting the value of the relevant node in the ZooKeeper registry. |
${container:bindaddress} | |
${container:sshurl} | The URL of the SSH service, which can be used to log on to the container console. |
${container:jmxurl} | The URL of the JMX service, which can be used to monitor the container. |
${container:jolokiaurl} | The URL of the Jolokia service, which is used by the Fuse Management Console to access the container. |
${container:httpurl} | The base URL of the container's default Jetty HTTP server. |
${container:domains} | List of JMX domains registered by the container. |
${container:processid} | Returns the process ID of the container process (on Linux-like and UNIX-like operating systems). |
${container:openshift} | A boolean flag that returns true , if the container is running on OpenShift; otherwise, false . |
${container:blueprintstatus} | The aggregate status of all the deployed Blueprint contexts. If all of the deployed contexts are ok, the status is ok ; if one or more deployed contexts have failed, the status is failed . |
${container:springstatus} | The aggregate status of all the deployed Spring contexts. If all of the deployed contexts are ok, the status is ok ; if one or more deployed contexts have failed, the status is failed . |
${container:provisionstatus} | Returns the container provision status. |
${container:provisionexception} | If the container provisioning has failed, this variable returns the provisioning exception. |
${container:provisionlist} | The list of provisioned artefacts in the container. |
${container:geolocation} | The geographic location of the container (which is obtained by making a Web request to a public service that gives the GPS coordinates of the container host). |
C.4. Substituting PID properties
Syntax
${profile:PID/Property}
Example using a profile property resolver
fabric
profile's io.fabric8.maven.properties
PID resource includes the following property setting:
remoteRepositories=${profile:io.fabric8.agent/org.ops4j.pax.url.mvn.repositories}
remoteRepositories
property is set to the value of the org.ops4j.pax.url.mvn.repositories
agent property (io.fabric8.agent
is the PID for the agent properties).
C.5. Substituting ZooKeeper node contents
Syntax
${zk:/PathToNode}
${zk:ContainerName/Property}
${zk:/fabric/registry/containers/config/ContainerName/Property}
Recursive variable substitution
dosgi
profile's io.fabric8.dosgi.properties
resource defines the following property:
exportedAddress=${zk:${karaf.name}/ip}
How to reference the current version of a resource
my-profile
profile's my-resource
resource, which can be done using the following ZooKeeper URL:
${zk:/fabric/configs/versions/1.0/profiles/my-profile/my-resource}
1.0
, is embedded in this path. But if you decide to upgrade this profile to version 1.1
, this means you must manually edit all occurrences of this ZooKeeper URL, changing the version number to 1.1
in order to reference the upgraded resource. To avoid this extra work, and to ensure that the resolver always references the current version of the resource, you can use the following trick which exploits recursive variable substitution:
${zk:/fabric/configs/versions/${zk:/fabric/configs/containers/${karaf.name}}/profiles/my-profile/my-resource}
/fabric/configs/containers/${karaf.name}
ZooKeeper node contains the current profile version deployed in the container.
C.6. Checksum property resolver
Syntax
checksum:
scheme can be prefixed to any of the usual location URL handlers (for example, file:
, http:
, profile:
, zk:
).
default
profile defines the following checksum property in the org.ops4j.pax.web
PID:
org.ops4j.pax.web.config.checksum=${checksum:profile\:jetty.xml}
C.7. Port property resolver
Syntax
${port:Min,Max}
Min
and Max
specify the minimum and maximum values of the allocated IP port.
Legal Notice
Trademark Disclaimer