property using a custom DecanterCamelEventExtender: public interface DecanterCamelEventExtender { void extend(Map decanterData, Exchange camelExchange); } You can inject your extender inprogressRequests = Gauge.build() .name("inprogress_requests").help("Inprogress requests.").register(); void processRequest() { inprogressRequests.inc(); // Your code here. inprogressRequests.dec(); BundleCollector(Event dispatcher) { this.dispatcher = dispatcher; } @Override public void bundleChanged(BundleEvent bundleEvent) { HashMap data = new HashMap<>();

uri="log:test"/> public interface DecanterCamelEventExtender { void extend(Map decanterData, Exchange camelExchange); } It’s very similar to the Decanter eventAdmin; public BundleCollector(Event eventAdmin) { this.eventAdmin = eventAdmin; } @Override public void bundleChanged(BundleEvent bundleEvent) { HashMap data = new HashMap<>(); data.put("type" ServiceTracker; public class Activator implements BundleActivator { private BundleCollector collector; public void start(final BundleContext bundleContext) { ServiceTracker tracker = new ServiceTracker(bundleContext

cave:* commands: • void createRepository(String name, String location, boolean generate, boolean install) throws Exception; • void destroyRepository(String name) throws Exception; • void installRepository(String throws Exception; • void uninstallRepository(String name) throws Exception; • void populateRepository(String name, String url, boolean generate, String filter) throws Exception; • void proxyRepository(String name, String url, boolean generate, String filter) throws Exception; • void updateRepository(String name) throws Exception; • void uploadArtifact(String repository, String artifactUrl, boolean generate)

commands: • void createRepository(String name, String location, boolean generateObr, boolean install) throws Exception; • void destroyRepository(String name) throws Exception; • void installRepository(String throws Exception; • void uninstallRepository(String name) throws Exception; • void populateRepository(String name, String url, boolean generateObr, String filter) throws Exception; • void proxyRepository(String String url, boolean generateObr, String filter) throws Exception; • void updateRepository(String name) throws Exception; • void uploadArtifact(String repository, String artifactUrl, boolean generateObr)

XPRESSION + "=0 0/10 * * * ?", } ) public class SchedulerPing implements Job { @Override public void execute(JobContext context) { // .. } } karaf@root()> scheduler:list Name │ ", "scheduler.name=PingJob" } ) public class PingThread implements Runnable { @Override public void run() { // .. } } karaf@root()> scheduler:list Name │ Schedule ──────── ", "scheduler.name=PingJob" } ) public class PingThread implements Runnable { @Override public void run() { // .. } } 4.20.4. Schedule a new Job using the Gogo Shell karaf@root()> scheduler:schedule-script

SshClient; import org.apache.sshd.client.future.ConnectFuture; public class Main { public static void main(String[] args) throws Exception { String host = "localhost"; int port = 8101; String user = Apache Karaf remotely via the JMX layer: javax.management.*; public class Main { public static void main(String[] args) throws Exception { JMXServiceURL url = new JMXServiceURL("service:jmx:rmi:/ type("zip").versionAsInProject()) .karafVersion("2.2.4").name("Apache Karaf")}; } @Test public void test() throws Exception { assertTrue(true); } } COMMANDS Basically the Pax Exam - Karaf bridge