--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/agent/command/pom.xml	Tue Jun 12 14:02:16 2012 -0400
@@ -0,0 +1,116 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!-- 
+
+ Copyright 2012 Red Hat, Inc.
+
+ This file is part of Thermostat.
+
+ Thermostat is free software; you can redistribute it and/or modify
+ it under the terms of the GNU General Public License as published
+ by the Free Software Foundation; either version 2, or (at your
+ option) any later version.
+
+ Thermostat is distributed in the hope that it will be useful, but
+ WITHOUT ANY WARRANTY; without even the implied warranty of
+ MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ General Public License for more details.
+
+ You should have received a copy of the GNU General Public License
+ along with Thermostat; see the file COPYING.  If not see
+ <http://www.gnu.org/licenses />.
+
+ Linking this code with other modules is making a combined work
+ based on this code.  Thus, the terms and conditions of the GNU
+ General Public License cover the whole combination.
+
+ As a special exception, the copyright holders of this code give
+ you permission to link this code with independent modules to
+ produce an executable, regardless of the license terms of these
+ independent modules, and to copy and distribute the resulting
+ executable under terms of your choice, provided that you also
+ meet, for each linked independent module, the terms and conditions
+ of the license of that module.  An independent module is a module
+ which is not derived from or based on this code.  If you modify
+ this code, you may extend this exception to your version of the
+ library, but you are not obligated to do so.  If you do not wish
+ to do so, delete this exception statement from your version.
+
+-->
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+  <modelVersion>4.0.0</modelVersion>
+
+  <parent>
+    <groupId>com.redhat.thermostat</groupId>
+    <artifactId>thermostat-agent</artifactId>
+    <version>0.3-SNAPSHOT</version>
+  </parent>
+
+  <artifactId>thermostat-agent-command</artifactId>
+  <packaging>jar</packaging>
+
+  <name>Thermostat Command Channel Server</name>
+
+  <dependencies>
+    <dependency>
+      <groupId>junit</groupId>
+      <artifactId>junit</artifactId>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.mockito</groupId>
+      <artifactId>mockito-core</artifactId>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.powermock</groupId>
+      <artifactId>powermock-api-mockito</artifactId>
+      <version>${powermock.version}</version>
+    </dependency>
+    <dependency>
+      <groupId>org.powermock</groupId>
+      <artifactId>powermock-module-junit4</artifactId>
+      <version>${powermock.version}</version>
+    </dependency>
+    <dependency>
+      <groupId>org.jboss.netty</groupId>
+      <artifactId>netty</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.osgi</groupId>
+      <artifactId>org.osgi.core</artifactId>
+      <scope>provided</scope>
+    </dependency>
+
+    <dependency>
+      <groupId>com.redhat.thermostat</groupId>
+      <artifactId>thermostat-common-command</artifactId>
+      <version>${project.version}</version>
+      <type>jar</type>
+    </dependency>
+    
+  </dependencies>
+
+  <!-- build>
+    <plugins>
+      <plugin>
+        <groupId>org.apache.felix</groupId>
+        <artifactId>maven-bundle-plugin</artifactId>
+        <version>1.4.0</version>
+        <extensions>true</extensions>
+        <configuration>
+          <instructions>
+            <Bundle-Vendor>Red Hat, Inc.</Bundle-Vendor>
+            <Bundle-Activator>com.redhat.thermostat.agent.config.command.Activator</Bundle-Activator>
+            <Export-Package>
+              com.redhat.thermostat.agent.command
+            </Export-Package>
+            <Private-Package>
+              com.redhat.thermostat.agent.command.osgi
+            </Private-Package>
+          </instructions>
+        </configuration>
+      </plugin>
+    </plugins>
+  </build -->
+
+</project>

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/agent/command/src/main/java/com/redhat/thermostat/agent/command/ConfigurationServer.java	Tue Jun 12 14:02:16 2012 -0400
@@ -0,0 +1,60 @@
+/*
+ * Copyright 2012 Red Hat, Inc.
+ *
+ * This file is part of Thermostat.
+ *
+ * Thermostat is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published
+ * by the Free Software Foundation; either version 2, or (at your
+ * option) any later version.
+ *
+ * Thermostat is distributed in the hope that it will be useful, but
+ * WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with Thermostat; see the file COPYING.  If not see
+ * <http://www.gnu.org/licenses/>.
+ *
+ * Linking this code with other modules is making a combined work
+ * based on this code.  Thus, the terms and conditions of the GNU
+ * General Public License cover the whole combination.
+ *
+ * As a special exception, the copyright holders of this code give
+ * you permission to link this code with independent modules to
+ * produce an executable, regardless of the license terms of these
+ * independent modules, and to copy and distribute the resulting
+ * executable under terms of your choice, provided that you also
+ * meet, for each linked independent module, the terms and conditions
+ * of the license of that module.  An independent module is a module
+ * which is not derived from or based on this code.  If you modify
+ * this code, you may extend this exception to your version of the
+ * library, but you are not obligated to do so.  If you do not wish
+ * to do so, delete this exception statement from your version.
+ */
+
+package com.redhat.thermostat.agent.command;
+
+import org.jboss.netty.bootstrap.ServerBootstrap;
+
+public class ConfigurationServer {
+
+    private final ConfigurationServerContext ctx;
+
+    public ConfigurationServer(ConfigurationServerContext ctx) {
+        this.ctx = ctx;
+    }
+
+    public void startup() {
+
+        ServerBootstrap bootstrap = (ServerBootstrap) ctx.getBootstrap();
+
+        // Bind and start to accept incoming connections.
+        bootstrap.bind(ctx.getAddress());
+    }
+
+    public void shutdown() {
+        ctx.getChannelGroup().close().awaitUninterruptibly();
+    }
+}

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/agent/command/src/main/java/com/redhat/thermostat/agent/command/ConfigurationServerContext.java	Tue Jun 12 14:02:16 2012 -0400
@@ -0,0 +1,106 @@
+/*
+ * Copyright 2012 Red Hat, Inc.
+ *
+ * This file is part of Thermostat.
+ *
+ * Thermostat is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published
+ * by the Free Software Foundation; either version 2, or (at your
+ * option) any later version.
+ *
+ * Thermostat is distributed in the hope that it will be useful, but
+ * WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with Thermostat; see the file COPYING.  If not see
+ * <http://www.gnu.org/licenses/>.
+ *
+ * Linking this code with other modules is making a combined work
+ * based on this code.  Thus, the terms and conditions of the GNU
+ * General Public License cover the whole combination.
+ *
+ * As a special exception, the copyright holders of this code give
+ * you permission to link this code with independent modules to
+ * produce an executable, regardless of the license terms of these
+ * independent modules, and to copy and distribute the resulting
+ * executable under terms of your choice, provided that you also
+ * meet, for each linked independent module, the terms and conditions
+ * of the license of that module.  An independent module is a module
+ * which is not derived from or based on this code.  If you modify
+ * this code, you may extend this exception to your version of the
+ * library, but you are not obligated to do so.  If you do not wish
+ * to do so, delete this exception statement from your version.
+ */
+
+package com.redhat.thermostat.agent.command;
+
+import java.util.concurrent.Executors;
+
+import org.jboss.netty.bootstrap.Bootstrap;
+import org.jboss.netty.bootstrap.ServerBootstrap;
+import org.jboss.netty.channel.ChannelPipeline;
+import org.jboss.netty.channel.ChannelPipelineFactory;
+import org.jboss.netty.channel.Channels;
+import org.jboss.netty.channel.group.ChannelGroup;
+import org.jboss.netty.channel.group.DefaultChannelGroup;
+import org.jboss.netty.channel.socket.nio.NioServerSocketChannelFactory;
+
+import com.redhat.thermostat.common.command.ConfigurationCommandContext;
+
+public class ConfigurationServerContext extends ConfigurationCommandContext {
+
+    final ServerBootstrap bootstrap;
+    final ChannelGroup channels;
+
+    public ConfigurationServerContext() {
+        bootstrap = createBootstrap();
+        channels = createChannelGroup();
+    }
+
+    @Override
+    public Bootstrap getBootstrap() {
+        return bootstrap;
+    }
+
+    private ChannelGroup createChannelGroup() {
+        return new DefaultChannelGroup(ConfigurationServer.class.getName());
+    }
+
+    private ServerBootstrap createBootstrap() {
+        ServerBootstrap bootstrap = new ServerBootstrap(
+                new NioServerSocketChannelFactory(
+                        Executors.newCachedThreadPool(),
+                        Executors.newCachedThreadPool()));
+
+        // Set up the pipeline factory.
+        bootstrap.setPipelineFactory(new ServerPipelineFactory());
+
+        bootstrap.setOption("child.tcpNoDelay", true);
+        bootstrap.setOption("child.keepAlive", true);
+        bootstrap.setOption("child.reuseAddress", true);
+        bootstrap.setOption("child.connectTimeoutMillis", 100);
+        bootstrap.setOption("child.readWriteFair", true);
+        
+        return bootstrap;
+    }
+
+    private class ServerPipelineFactory implements ChannelPipelineFactory {
+
+        @Override
+        public ChannelPipeline getPipeline() throws Exception {
+            ChannelPipeline pipeline = Channels.pipeline();
+            pipeline.addLast("decoder", new RequestDecoder());
+            pipeline.addLast("encoder", new ResponseEncoder());
+            pipeline.addLast("handler", new ServerHandler());
+            return pipeline;
+        }
+        
+    }
+
+    public ChannelGroup getChannelGroup() {
+        return channels;
+    }
+
+}

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/agent/command/src/main/java/com/redhat/thermostat/agent/command/RequestDecoder.java	Tue Jun 12 14:02:16 2012 -0400
@@ -0,0 +1,60 @@
+/*
+ * Copyright 2012 Red Hat, Inc.
+ *
+ * This file is part of Thermostat.
+ *
+ * Thermostat is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published
+ * by the Free Software Foundation; either version 2, or (at your
+ * option) any later version.
+ *
+ * Thermostat is distributed in the hope that it will be useful, but
+ * WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with Thermostat; see the file COPYING.  If not see
+ * <http://www.gnu.org/licenses/>.
+ *
+ * Linking this code with other modules is making a combined work
+ * based on this code.  Thus, the terms and conditions of the GNU
+ * General Public License cover the whole combination.
+ *
+ * As a special exception, the copyright holders of this code give
+ * you permission to link this code with independent modules to
+ * produce an executable, regardless of the license terms of these
+ * independent modules, and to copy and distribute the resulting
+ * executable under terms of your choice, provided that you also
+ * meet, for each linked independent module, the terms and conditions
+ * of the license of that module.  An independent module is a module
+ * which is not derived from or based on this code.  If you modify
+ * this code, you may extend this exception to your version of the
+ * library, but you are not obligated to do so.  If you do not wish
+ * to do so, delete this exception statement from your version.
+ */
+
+package com.redhat.thermostat.agent.command;
+
+import org.jboss.netty.buffer.ChannelBuffer;
+import org.jboss.netty.channel.Channel;
+import org.jboss.netty.channel.ChannelHandlerContext;
+
+import com.redhat.thermostat.common.command.DecodingHelper;
+import com.redhat.thermostat.common.command.MessageDecoder;
+import com.redhat.thermostat.common.command.Request;
+import com.redhat.thermostat.common.command.Request.RequestType;
+
+class RequestDecoder extends MessageDecoder {
+
+    @Override
+    protected Object decode(ChannelHandlerContext ctx, Channel channel,
+            ChannelBuffer buffer) {
+        String typeAsString = DecodingHelper.decodeString(buffer);
+        if (typeAsString == null) {
+            return null;
+        }
+        return new Request(RequestType.valueOf(typeAsString), channel.getRemoteAddress());
+    }
+
+}
\ No newline at end of file

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/agent/command/src/main/java/com/redhat/thermostat/agent/command/ResponseEncoder.java	Tue Jun 12 14:02:16 2012 -0400
@@ -0,0 +1,68 @@
+/*
+ * Copyright 2012 Red Hat, Inc.
+ *
+ * This file is part of Thermostat.
+ *
+ * Thermostat is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published
+ * by the Free Software Foundation; either version 2, or (at your
+ * option) any later version.
+ *
+ * Thermostat is distributed in the hope that it will be useful, but
+ * WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with Thermostat; see the file COPYING.  If not see
+ * <http://www.gnu.org/licenses/>.
+ *
+ * Linking this code with other modules is making a combined work
+ * based on this code.  Thus, the terms and conditions of the GNU
+ * General Public License cover the whole combination.
+ *
+ * As a special exception, the copyright holders of this code give
+ * you permission to link this code with independent modules to
+ * produce an executable, regardless of the license terms of these
+ * independent modules, and to copy and distribute the resulting
+ * executable under terms of your choice, provided that you also
+ * meet, for each linked independent module, the terms and conditions
+ * of the license of that module.  An independent module is a module
+ * which is not derived from or based on this code.  If you modify
+ * this code, you may extend this exception to your version of the
+ * library, but you are not obligated to do so.  If you do not wish
+ * to do so, delete this exception statement from your version.
+ */
+
+package com.redhat.thermostat.agent.command;
+
+import org.jboss.netty.buffer.ChannelBuffer;
+import static org.jboss.netty.buffer.ChannelBuffers.wrappedBuffer;
+import org.jboss.netty.channel.ChannelHandlerContext;
+import org.jboss.netty.channel.Channels;
+import org.jboss.netty.channel.MessageEvent;
+
+import com.redhat.thermostat.common.command.EncodingHelper;
+import com.redhat.thermostat.common.command.MessageEncoder;
+import com.redhat.thermostat.common.command.Response;
+
+
+class ResponseEncoder extends MessageEncoder {
+
+    @Override
+    public void writeRequested(ChannelHandlerContext ctx, MessageEvent e) {
+
+        Response response = (Response) e.getMessage();
+
+        // Response Type
+        String responseType = EncodingHelper.trimType(response.getType().toString());
+        byte[] message = responseType.getBytes();
+        ChannelBuffer typeBuffer = EncodingHelper.encode(message);
+
+        // Compose the full message.
+        ChannelBuffer buf = wrappedBuffer(typeBuffer);
+        Channels.write(ctx, e.getFuture(), buf);
+        
+    }
+
+}
\ No newline at end of file

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/agent/command/src/main/java/com/redhat/thermostat/agent/command/ServerHandler.java	Tue Jun 12 14:02:16 2012 -0400
@@ -0,0 +1,91 @@
+/*
+ * Copyright 2012 Red Hat, Inc.
+ *
+ * This file is part of Thermostat.
+ *
+ * Thermostat is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published
+ * by the Free Software Foundation; either version 2, or (at your
+ * option) any later version.
+ *
+ * Thermostat is distributed in the hope that it will be useful, but
+ * WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with Thermostat; see the file COPYING.  If not see
+ * <http://www.gnu.org/licenses/>.
+ *
+ * Linking this code with other modules is making a combined work
+ * based on this code.  Thus, the terms and conditions of the GNU
+ * General Public License cover the whole combination.
+ *
+ * As a special exception, the copyright holders of this code give
+ * you permission to link this code with independent modules to
+ * produce an executable, regardless of the license terms of these
+ * independent modules, and to copy and distribute the resulting
+ * executable under terms of your choice, provided that you also
+ * meet, for each linked independent module, the terms and conditions
+ * of the license of that module.  An independent module is a module
+ * which is not derived from or based on this code.  If you modify
+ * this code, you may extend this exception to your version of the
+ * library, but you are not obligated to do so.  If you do not wish
+ * to do so, delete this exception statement from your version.
+ */
+
+package com.redhat.thermostat.agent.command;
+
+import java.util.logging.Level;
+import java.util.logging.Logger;
+
+import org.jboss.netty.channel.Channel;
+import org.jboss.netty.channel.ChannelFuture;
+import org.jboss.netty.channel.ChannelFutureListener;
+import org.jboss.netty.channel.ChannelHandlerContext;
+import org.jboss.netty.channel.ExceptionEvent;
+import org.jboss.netty.channel.MessageEvent;
+import org.jboss.netty.channel.SimpleChannelHandler;
+
+import com.redhat.thermostat.common.command.Request;
+import com.redhat.thermostat.common.command.Response;
+import com.redhat.thermostat.common.command.Request.RequestType;
+import com.redhat.thermostat.common.command.Response.ResponseType;
+
+public class ServerHandler extends SimpleChannelHandler {
+
+    private static final Logger logger = Logger.getLogger(ServerHandler.class.getName());
+
+    @Override
+    public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) {
+        Request request = (Request) e.getMessage();
+        logger.info("Request received: " + request.getType().toString());
+        Response response = doRequest(request);
+        Channel channel = ctx.getChannel();
+        if (channel.isConnected()) {
+            logger.info("Sending response: " + response.getType().toString());
+            ChannelFuture f = channel.write(response);
+
+            f.addListener(ChannelFutureListener.CLOSE);
+        } else {
+            logger.warning("Channel not connected.");
+        }
+    }
+
+    @Override
+    public void exceptionCaught(ChannelHandlerContext ctx, ExceptionEvent e) {
+        logger.log(Level.WARNING, "Unexpected exception from downstream.", e.getCause());
+        e.getChannel().close();
+    }
+
+    private Response doRequest(Request request) {
+        Response response = new Response(ResponseType.ERROR);
+        switch ((RequestType) request.getType()) {
+        case PING:
+            response = new Response(ResponseType.PONG);
+            break;
+        default:
+        }
+        return response;
+    }
+}

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/agent/command/src/main/java/com/redhat/thermostat/agent/command/osgi/Activator.java	Tue Jun 12 14:02:16 2012 -0400
@@ -0,0 +1,75 @@
+/*
+ * Copyright 2012 Red Hat, Inc.
+ *
+ * This file is part of Thermostat.
+ *
+ * Thermostat is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published
+ * by the Free Software Foundation; either version 2, or (at your
+ * option) any later version.
+ *
+ * Thermostat is distributed in the hope that it will be useful, but
+ * WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with Thermostat; see the file COPYING.  If not see
+ * <http://www.gnu.org/licenses/>.
+ *
+ * Linking this code with other modules is making a combined work
+ * based on this code.  Thus, the terms and conditions of the GNU
+ * General Public License cover the whole combination.
+ *
+ * As a special exception, the copyright holders of this code give
+ * you permission to link this code with independent modules to
+ * produce an executable, regardless of the license terms of these
+ * independent modules, and to copy and distribute the resulting
+ * executable under terms of your choice, provided that you also
+ * meet, for each linked independent module, the terms and conditions
+ * of the license of that module.  An independent module is a module
+ * which is not derived from or based on this code.  If you modify
+ * this code, you may extend this exception to your version of the
+ * library, but you are not obligated to do so.  If you do not wish
+ * to do so, delete this exception statement from your version.
+ */
+
+package com.redhat.thermostat.agent.command.osgi;
+
+import java.util.Hashtable;
+import java.util.logging.Level;
+import java.util.logging.Logger;
+
+import org.osgi.framework.BundleActivator;
+import org.osgi.framework.BundleContext;
+
+import com.redhat.thermostat.agent.command.ConfigurationServer;
+import com.redhat.thermostat.agent.command.ConfigurationServerContext;
+
+public class Activator implements BundleActivator {
+
+    private static final Logger logger = Logger.getLogger(Activator.class.getSimpleName());
+    private static final String SERVICE_NAME = "com.redhat.thermostat.agent.config.netty.ConfigurationServer";
+
+    private ConfigurationServer confServer;
+
+    public Activator() {
+        confServer = new ConfigurationServer(new ConfigurationServerContext());
+    }
+
+    @Override
+    public void start(BundleContext context) throws Exception {    
+        logger.log(Level.INFO, "activating thermostat-agent-confserver");
+
+        Hashtable<String, String> props = new Hashtable<String, String>();
+        props.put(SERVICE_NAME, SERVICE_NAME);
+        context.registerService(ConfigurationServer.class.getName(), confServer, props);
+        confServer.startup();
+    }
+
+    @Override
+    public void stop(BundleContext context) throws Exception {
+        confServer.shutdown();
+    }
+
+}

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/agent/command/src/test/java/com/redhat/thermostat/agent/command/ConfigurationServerContextTest.java	Tue Jun 12 14:02:16 2012 -0400
@@ -0,0 +1,107 @@
+/*
+ * Copyright 2012 Red Hat, Inc.
+ *
+ * This file is part of Thermostat.
+ *
+ * Thermostat is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published
+ * by the Free Software Foundation; either version 2, or (at your
+ * option) any later version.
+ *
+ * Thermostat is distributed in the hope that it will be useful, but
+ * WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with Thermostat; see the file COPYING.  If not see
+ * <http://www.gnu.org/licenses/>.
+ *
+ * Linking this code with other modules is making a combined work
+ * based on this code.  Thus, the terms and conditions of the GNU
+ * General Public License cover the whole combination.
+ *
+ * As a special exception, the copyright holders of this code give
+ * you permission to link this code with independent modules to
+ * produce an executable, regardless of the license terms of these
+ * independent modules, and to copy and distribute the resulting
+ * executable under terms of your choice, provided that you also
+ * meet, for each linked independent module, the terms and conditions
+ * of the license of that module.  An independent module is a module
+ * which is not derived from or based on this code.  If you modify
+ * this code, you may extend this exception to your version of the
+ * library, but you are not obligated to do so.  If you do not wish
+ * to do so, delete this exception statement from your version.
+ */
+
+package com.redhat.thermostat.agent.command;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertTrue;
+
+import org.jboss.netty.bootstrap.Bootstrap;
+import org.jboss.netty.channel.ChannelHandler;
+import org.jboss.netty.channel.ChannelPipeline;
+import org.jboss.netty.channel.ChannelPipelineFactory;
+import org.jboss.netty.channel.group.ChannelGroup;
+import org.junit.Before;
+import org.junit.Test;
+
+import com.redhat.thermostat.agent.command.ConfigurationServer;
+import com.redhat.thermostat.agent.command.ConfigurationServerContext;
+import com.redhat.thermostat.agent.command.RequestDecoder;
+import com.redhat.thermostat.agent.command.ResponseEncoder;
+import com.redhat.thermostat.agent.command.ServerHandler;
+
+public class ConfigurationServerContextTest {
+
+    ConfigurationServerContext ctx;
+
+    @Before
+    public void setUp() {
+        ctx = new ConfigurationServerContext();
+    }
+
+    @Test
+    public void testBootstrap() {
+        Bootstrap bootstrap = ctx.getBootstrap();
+        assertNotNull(bootstrap);
+
+        assertTrue((Boolean) bootstrap.getOption("child.tcpNoDelay"));
+        assertTrue((Boolean) bootstrap.getOption("child.keepAlive"));
+        assertTrue((Boolean) bootstrap.getOption("child.reuseAddress"));
+        assertEquals(100, bootstrap.getOption("child.connectTimeoutMillis"));
+        assertTrue((Boolean) bootstrap.getOption("child.readWriteFair"));
+
+        ChannelPipelineFactory pf = bootstrap.getPipelineFactory();
+        assertNotNull(pf);
+
+        ChannelPipeline p = null;
+        try {
+            p = pf.getPipeline();
+        } catch (Exception e) {
+            // Do nothing
+        }
+        assertNotNull(p);
+
+        ChannelHandler encoder = p.get("encoder");
+        assertNotNull(encoder);
+        assertTrue(encoder instanceof ResponseEncoder);
+
+        ChannelHandler decoder = p.get("decoder");
+        assertNotNull(decoder);
+        assertTrue(decoder instanceof RequestDecoder);
+
+        ChannelHandler handler = p.get("handler");
+        assertNotNull(handler);
+        assertTrue(handler instanceof ServerHandler);
+    }
+
+    @Test
+    public void testChannelGroup() {
+        ChannelGroup cg = ctx.getChannelGroup();
+        assertNotNull(cg);
+        assertEquals(ConfigurationServer.class.getName(), cg.getName());
+    }
+}

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/agent/command/src/test/java/com/redhat/thermostat/agent/command/ConfigurationServerTest.java	Tue Jun 12 14:02:16 2012 -0400
@@ -0,0 +1,95 @@
+/*
+ * Copyright 2012 Red Hat, Inc.
+ *
+ * This file is part of Thermostat.
+ *
+ * Thermostat is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published
+ * by the Free Software Foundation; either version 2, or (at your
+ * option) any later version.
+ *
+ * Thermostat is distributed in the hope that it will be useful, but
+ * WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with Thermostat; see the file COPYING.  If not see
+ * <http://www.gnu.org/licenses/>.
+ *
+ * Linking this code with other modules is making a combined work
+ * based on this code.  Thus, the terms and conditions of the GNU
+ * General Public License cover the whole combination.
+ *
+ * As a special exception, the copyright holders of this code give
+ * you permission to link this code with independent modules to
+ * produce an executable, regardless of the license terms of these
+ * independent modules, and to copy and distribute the resulting
+ * executable under terms of your choice, provided that you also
+ * meet, for each linked independent module, the terms and conditions
+ * of the license of that module.  An independent module is a module
+ * which is not derived from or based on this code.  If you modify
+ * this code, you may extend this exception to your version of the
+ * library, but you are not obligated to do so.  If you do not wish
+ * to do so, delete this exception statement from your version.
+ */
+
+package com.redhat.thermostat.agent.command;
+
+import java.net.InetSocketAddress;
+
+import org.jboss.netty.bootstrap.ServerBootstrap;
+import org.jboss.netty.channel.group.ChannelGroup;
+import org.jboss.netty.channel.group.ChannelGroupFuture;
+import org.junit.Before;
+import org.junit.Test;
+import org.mockito.ArgumentCaptor;
+
+import com.redhat.thermostat.agent.command.ConfigurationServer;
+import com.redhat.thermostat.agent.command.ConfigurationServerContext;
+
+import static org.junit.Assert.assertEquals;
+import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+
+public class ConfigurationServerTest {
+
+    private ConfigurationServerContext ctx;
+    ChannelGroup cg;
+    ServerBootstrap bootstrap;
+    InetSocketAddress addr;
+
+    @Before
+    public void setUp() {
+        cg = mock(ChannelGroup.class);
+        ChannelGroupFuture future = mock(ChannelGroupFuture.class);
+        when(cg.close()).thenReturn(future);
+        bootstrap = mock(ServerBootstrap.class);
+        addr = new InetSocketAddress(123);
+        ctx = mock(ConfigurationServerContext.class);
+        when(ctx.getBootstrap()).thenReturn(bootstrap);
+        when(ctx.getChannelGroup()).thenReturn(cg);
+        when(ctx.getAddress()).thenReturn(addr);
+    }
+
+    @Test
+    public void testStartup() {
+        ConfigurationServer server = new ConfigurationServer(ctx);
+        server.startup();
+
+
+        ArgumentCaptor<InetSocketAddress> argument = ArgumentCaptor.forClass(InetSocketAddress.class);
+        verify(bootstrap).bind(argument.capture());
+        assertEquals(addr, argument.getValue());
+    }
+
+    @Test
+    public void testShutdown() {
+        ConfigurationServer server = new ConfigurationServer(ctx);
+        server.shutdown();
+
+        verify(cg).close();
+    }
+    
+}

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/agent/command/src/test/java/com/redhat/thermostat/agent/command/RequestDecoderTest.java	Tue Jun 12 14:02:16 2012 -0400
@@ -0,0 +1,74 @@
+/*
+ * Copyright 2012 Red Hat, Inc.
+ *
+ * This file is part of Thermostat.
+ *
+ * Thermostat is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published
+ * by the Free Software Foundation; either version 2, or (at your
+ * option) any later version.
+ *
+ * Thermostat is distributed in the hope that it will be useful, but
+ * WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with Thermostat; see the file COPYING.  If not see
+ * <http://www.gnu.org/licenses/>.
+ *
+ * Linking this code with other modules is making a combined work
+ * based on this code.  Thus, the terms and conditions of the GNU
+ * General Public License cover the whole combination.
+ *
+ * As a special exception, the copyright holders of this code give
+ * you permission to link this code with independent modules to
+ * produce an executable, regardless of the license terms of these
+ * independent modules, and to copy and distribute the resulting
+ * executable under terms of your choice, provided that you also
+ * meet, for each linked independent module, the terms and conditions
+ * of the license of that module.  An independent module is a module
+ * which is not derived from or based on this code.  If you modify
+ * this code, you may extend this exception to your version of the
+ * library, but you are not obligated to do so.  If you do not wish
+ * to do so, delete this exception statement from your version.
+ */
+
+package com.redhat.thermostat.agent.command;
+
+import org.jboss.netty.buffer.ChannelBuffer;
+import org.jboss.netty.buffer.ChannelBuffers;
+import org.jboss.netty.channel.Channel;
+import org.junit.Before;
+import org.junit.Test;
+
+import com.redhat.thermostat.agent.command.RequestDecoder;
+import com.redhat.thermostat.common.command.Request;
+import com.redhat.thermostat.common.command.Request.RequestType;
+
+import static org.junit.Assert.assertTrue;
+import static org.mockito.Mockito.mock;
+
+public class RequestDecoderTest {
+    private static final byte[] PING = "PING".getBytes();
+
+    private ChannelBuffer buffer;
+    private Channel channel;
+
+    @Before
+    public void setUp() {
+        channel = mock(Channel.class);
+        
+        buffer = ChannelBuffers.dynamicBuffer();
+        buffer.writeInt(PING.length);
+        buffer.writeBytes(PING);
+    }
+
+    @Test
+    public void testDecode() {
+        RequestDecoder decoder = new RequestDecoder();
+        Request request = (Request) decoder.decode(null, channel, buffer);
+
+        assertTrue(RequestType.PING == (RequestType) request.getType());
+    }
+}

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/agent/command/src/test/java/com/redhat/thermostat/agent/command/ResponseEncoderTest.java	Tue Jun 12 14:02:16 2012 -0400
@@ -0,0 +1,98 @@
+/*
+ * Copyright 2012 Red Hat, Inc.
+ *
+ * This file is part of Thermostat.
+ *
+ * Thermostat is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published
+ * by the Free Software Foundation; either version 2, or (at your
+ * option) any later version.
+ *
+ * Thermostat is distributed in the hope that it will be useful, but
+ * WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with Thermostat; see the file COPYING.  If not see
+ * <http://www.gnu.org/licenses/>.
+ *
+ * Linking this code with other modules is making a combined work
+ * based on this code.  Thus, the terms and conditions of the GNU
+ * General Public License cover the whole combination.
+ *
+ * As a special exception, the copyright holders of this code give
+ * you permission to link this code with independent modules to
+ * produce an executable, regardless of the license terms of these
+ * independent modules, and to copy and distribute the resulting
+ * executable under terms of your choice, provided that you also
+ * meet, for each linked independent module, the terms and conditions
+ * of the license of that module.  An independent module is a module
+ * which is not derived from or based on this code.  If you modify
+ * this code, you may extend this exception to your version of the
+ * library, but you are not obligated to do so.  If you do not wish
+ * to do so, delete this exception statement from your version.
+ */
+
+package com.redhat.thermostat.agent.command;
+
+import java.nio.ByteBuffer;
+
+import org.jboss.netty.buffer.ChannelBuffer;
+import org.jboss.netty.channel.ChannelFuture;
+import org.jboss.netty.channel.ChannelHandlerContext;
+import org.jboss.netty.channel.Channels;
+import org.jboss.netty.channel.MessageEvent;
+import org.junit.Before;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.mockito.ArgumentCaptor;
+import org.powermock.api.mockito.PowerMockito;
+import org.powermock.core.classloader.annotations.PrepareForTest;
+import org.powermock.modules.junit4.PowerMockRunner;
+
+import com.redhat.thermostat.agent.command.ResponseEncoder;
+import com.redhat.thermostat.common.command.Response;
+import com.redhat.thermostat.common.command.Response.ResponseType;
+
+import static org.junit.Assert.assertEquals;
+import static org.mockito.Mockito.any;
+import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.when;
+
+@RunWith(PowerMockRunner.class)
+@PrepareForTest(Channels.class)
+public class ResponseEncoderTest {
+
+    private MessageEvent e;
+
+    @Before
+    public void setUp() {
+        Response r = new Response(ResponseType.PONG);
+        e = mock(MessageEvent.class);
+        when(e.getMessage()).thenReturn(r);
+        when(e.getFuture()).thenReturn(null);
+        
+    }
+
+    @Test
+    public void testWriteRequested() {
+        PowerMockito.mockStatic(Channels.class);
+        ArgumentCaptor<Object> argument = ArgumentCaptor.forClass(Object.class);
+
+        ResponseEncoder encoder = new ResponseEncoder();
+        ChannelHandlerContext ctx = mock(ChannelHandlerContext.class);
+        encoder.writeRequested(ctx, e);
+        
+        PowerMockito.verifyStatic();
+        Channels.write(any(ChannelHandlerContext.class), any(ChannelFuture.class), argument.capture());
+
+        ChannelBuffer buf = (ChannelBuffer) argument.getValue();
+        int messageLength = buf.readInt();
+        assertEquals(4, messageLength);
+        ByteBuffer bbuf = ByteBuffer.allocate(buf.readableBytes());
+        buf.readBytes(bbuf);
+        String message = new String(bbuf.array());
+        assertEquals("PONG", message);
+    }
+}

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/agent/core/pom.xml	Tue Jun 12 14:02:16 2012 -0400
@@ -0,0 +1,109 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!-- 
+
+ Copyright 2012 Red Hat, Inc.
+
+ This file is part of Thermostat.
+
+ Thermostat is free software; you can redistribute it and/or modify
+ it under the terms of the GNU General Public License as published
+ by the Free Software Foundation; either version 2, or (at your
+ option) any later version.
+
+ Thermostat is distributed in the hope that it will be useful, but
+ WITHOUT ANY WARRANTY; without even the implied warranty of
+ MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ General Public License for more details.
+
+ You should have received a copy of the GNU General Public License
+ along with Thermostat; see the file COPYING.  If not see
+ <http://www.gnu.org/licenses />.
+
+ Linking this code with other modules is making a combined work
+ based on this code.  Thus, the terms and conditions of the GNU
+ General Public License cover the whole combination.
+
+ As a special exception, the copyright holders of this code give
+ you permission to link this code with independent modules to
+ produce an executable, regardless of the license terms of these
+ independent modules, and to copy and distribute the resulting
+ executable under terms of your choice, provided that you also
+ meet, for each linked independent module, the terms and conditions
+ of the license of that module.  An independent module is a module
+ which is not derived from or based on this code.  If you modify
+ this code, you may extend this exception to your version of the
+ library, but you are not obligated to do so.  If you do not wish
+ to do so, delete this exception statement from your version.
+
+-->
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+  <modelVersion>4.0.0</modelVersion>
+
+  <parent>
+    <groupId>com.redhat.thermostat</groupId>
+    <artifactId>thermostat-agent</artifactId>
+    <version>0.3-SNAPSHOT</version>
+  </parent>
+
+  <artifactId>thermostat-agent-core</artifactId>
+  <packaging>bundle</packaging>
+
+  <name>Thermostat Agent Core</name>
+
+  <dependencies>
+    <dependency>
+      <groupId>junit</groupId>
+      <artifactId>junit</artifactId>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.mockito</groupId>
+      <artifactId>mockito-core</artifactId>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>com.redhat.thermostat</groupId>
+      <artifactId>thermostat-common-core</artifactId>
+      <version>${project.version}</version>
+      <type>bundle</type>
+    </dependency>
+    <dependency>
+      <groupId>org.osgi</groupId>
+      <artifactId>org.osgi.core</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>com.sun</groupId>
+      <artifactId>tools</artifactId>
+      <scope>system</scope>
+      <systemPath>${java.home}/../lib/tools.jar</systemPath>
+    </dependency>
+  </dependencies>
+
+  <build>
+    <plugins>
+      <plugin>
+        <groupId>org.apache.felix</groupId>
+        <artifactId>maven-bundle-plugin</artifactId>
+        <version>1.4.0</version>
+        <extensions>true</extensions>
+        <configuration>
+          <instructions>
+            <Bundle-Vendor>Red Hat, Inc.</Bundle-Vendor>
+            <Bundle-Activator>com.redhat.thermostat.agent.Activator</Bundle-Activator>
+            <Export-Package>
+              com.redhat.thermostat.agent,
+              com.redhat.thermostat.backend,
+            </Export-Package>
+            <Private-Package>
+              com.redhat.thermostat,
+              com.redhat.thermostat.agent.config,
+              com.redhat.thermostat.backend.sample,
+              com.redhat.thermostat.backend.system,
+            </Private-Package>
+          </instructions>
+        </configuration>
+      </plugin>
+    </plugins>
+  </build>
+
+</project>

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/agent/core/src/main/java/com/redhat/thermostat/agent/Activator.java	Tue Jun 12 14:02:16 2012 -0400
@@ -0,0 +1,62 @@
+/*
+ * Copyright 2012 Red Hat, Inc.
+ *
+ * This file is part of Thermostat.
+ *
+ * Thermostat is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published
+ * by the Free Software Foundation; either version 2, or (at your
+ * option) any later version.
+ *
+ * Thermostat is distributed in the hope that it will be useful, but
+ * WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with Thermostat; see the file COPYING.  If not see
+ * <http://www.gnu.org/licenses/>.
+ *
+ * Linking this code with other modules is making a combined work
+ * based on this code.  Thus, the terms and conditions of the GNU
+ * General Public License cover the whole combination.
+ *
+ * As a special exception, the copyright holders of this code give
+ * you permission to link this code with independent modules to
+ * produce an executable, regardless of the license terms of these
+ * independent modules, and to copy and distribute the resulting
+ * executable under terms of your choice, provided that you also
+ * meet, for each linked independent module, the terms and conditions
+ * of the license of that module.  An independent module is a module
+ * which is not derived from or based on this code.  If you modify
+ * this code, you may extend this exception to your version of the
+ * library, but you are not obligated to do so.  If you do not wish
+ * to do so, delete this exception statement from your version.
+ */
+
+package com.redhat.thermostat.agent;
+
+import java.util.Arrays;
+
+import org.osgi.framework.BundleActivator;
+import org.osgi.framework.BundleContext;
+
+import com.redhat.thermostat.common.cli.CommandRegistry;
+import com.redhat.thermostat.common.cli.CommandRegistryImpl;
+
+public class Activator implements BundleActivator {
+
+    private CommandRegistry reg;
+
+    @Override
+    public void start(BundleContext context) throws Exception {
+        reg = new CommandRegistryImpl(context);
+        reg.registerCommands(Arrays.asList(new AgentApplication()));
+    }
+
+    @Override
+    public void stop(BundleContext context) throws Exception {
+        reg.unregisterCommands();
+    }
+
+}

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/agent/core/src/main/java/com/redhat/thermostat/agent/Agent.java	Tue Jun 12 14:02:16 2012 -0400
@@ -0,0 +1,162 @@
+/*
+ * Copyright 2012 Red Hat, Inc.
+ *
+ * This file is part of Thermostat.
+ *
+ * Thermostat is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published
+ * by the Free Software Foundation; either version 2, or (at your
+ * option) any later version.
+ *
+ * Thermostat is distributed in the hope that it will be useful, but
+ * WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with Thermostat; see the file COPYING.  If not see
+ * <http://www.gnu.org/licenses/>.
+ *
+ * Linking this code with other modules is making a combined work
+ * based on this code.  Thus, the terms and conditions of the GNU
+ * General Public License cover the whole combination.
+ *
+ * As a special exception, the copyright holders of this code give
+ * you permission to link this code with independent modules to
+ * produce an executable, regardless of the license terms of these
+ * independent modules, and to copy and distribute the resulting
+ * executable under terms of your choice, provided that you also
+ * meet, for each linked independent module, the terms and conditions
+ * of the license of that module.  An independent module is a module
+ * which is not derived from or based on this code.  If you modify
+ * this code, you may extend this exception to your version of the
+ * library, but you are not obligated to do so.  If you do not wish
+ * to do so, delete this exception statement from your version.
+ */
+
+package com.redhat.thermostat.agent;
+
+import java.util.UUID;
+import java.util.logging.Logger;
+
+import com.redhat.thermostat.agent.config.AgentStartupConfiguration;
+import com.redhat.thermostat.agent.config.ConfigurationWatcher;
+import com.redhat.thermostat.backend.Backend;
+import com.redhat.thermostat.backend.BackendRegistry;
+import com.redhat.thermostat.common.LaunchException;
+import com.redhat.thermostat.common.dao.DAOFactory;
+import com.redhat.thermostat.common.storage.AgentInformation;
+import com.redhat.thermostat.common.storage.BackendInformation;
+import com.redhat.thermostat.common.storage.Storage;
+import com.redhat.thermostat.common.utils.LoggingUtils;
+
+/**
+ * Represents the Agent running on a host.
+ */
+public class Agent {
+
+    private static final Logger logger = LoggingUtils.getLogger(Agent.class);
+
+    private final UUID id;
+    private final BackendRegistry backendRegistry;
+    private final AgentStartupConfiguration config;
+
+    private AgentInformation agentInfo;
+    
+    private Storage storage;
+    private Thread configWatcherThread = null;
+
+    public Agent(BackendRegistry backendRegistry, AgentStartupConfiguration config, DAOFactory daos) {
+        this(backendRegistry, UUID.randomUUID(), config, daos);
+    }
+
+    public Agent(BackendRegistry registry, UUID agentId, AgentStartupConfiguration config, DAOFactory daos) {
+        this.id = agentId;
+        this.backendRegistry = registry;
+        this.config = config;
+        this.storage = daos.getStorage();
+        this.storage.setAgentId(agentId);
+    }
+
+    private void startBackends() throws LaunchException {
+        for (Backend be : backendRegistry.getAll()) {
+            logger.fine("Attempting to start backend: " + be.getName());
+            if (!be.activate()) {
+                logger.warning("Issue while starting backend: " + be.getName());
+                // When encountering issues during startup, we should not attempt to continue activating.
+                stopBackends();
+                throw new LaunchException("Could not activate backend: " + be.getName());
+            }
+        }
+    }
+
+    private void stopBackends() {
+        for (Backend be : backendRegistry.getAll()) {
+            logger.fine("Attempting to stop backend: " +be.getName());
+            if (!be.deactivate()) {
+                // When encountering issues during shutdown, we should attempt to shut down remaining backends.
+                logger.warning("Issue while deactivating backend: " + be.getName());
+            }
+        }
+    }
+
+    public synchronized void start() throws LaunchException {
+        if (configWatcherThread == null) {
+            startBackends();
+            agentInfo = createAgentInformation();
+            storage.addAgentInformation(agentInfo);
+            configWatcherThread = new Thread(new ConfigurationWatcher(storage, backendRegistry), "Configuration Watcher");
+            configWatcherThread.start();
+        } else {
+            logger.warning("Attempt to start agent when already started.");
+        }
+    }
+
+    private AgentInformation createAgentInformation() {
+        AgentInformation agentInfo = new AgentInformation();
+        agentInfo.setStartTime(config.getStartTime());
+        for (Backend backend : backendRegistry.getAll()) {
+            BackendInformation backendInfo = new BackendInformation();
+            backendInfo.setName(backend.getName());
+            backendInfo.setDescription(backend.getDescription());
+            backendInfo.setObserveNewJvm(backend.getObserveNewJvm());
+            agentInfo.addBackend(backendInfo);
+        }
+        agentInfo.setAlive(true);
+        return agentInfo;
+    }
+
+    public synchronized void stop() {
+        if (configWatcherThread != null) {
+            configWatcherThread.interrupt(); // This thread checks for its own interrupted state and ends if interrupted.
+            while (configWatcherThread.isAlive()) {
+                try {
+                    configWatcherThread.join();
+                } catch (InterruptedException e) {
+                    logger.fine("Interrupted while waiting for ConfigurationWatcher to die.");
+                }
+            }
+            configWatcherThread = null;
+
+            stopBackends();
+            if (config.purge()) {
+                System.out.println("purging database");
+                logger.info("purging database");
+                storage.removeAgentInformation();
+                storage.purge();
+            } else {
+                agentInfo.setStopTime(System.currentTimeMillis());
+                agentInfo.setAlive(false);
+                storage.updateAgentInformation(agentInfo);
+            }
+            
+        } else {
+            logger.warning("Attempt to stop agent which is not active");
+        }
+    }
+
+    public UUID getId() {
+        return id;
+    }
+
+}

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/agent/core/src/main/java/com/redhat/thermostat/agent/AgentApplication.java	Tue Jun 12 14:02:16 2012 -0400
@@ -0,0 +1,215 @@
+/*
+ * Copyright 2012 Red Hat, Inc.
+ *
+ * This file is part of Thermostat.
+ *
+ * Thermostat is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published
+ * by the Free Software Foundation; either version 2, or (at your
+ * option) any later version.
+ *
+ * Thermostat is distributed in the hope that it will be useful, but
+ * WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with Thermostat; see the file COPYING.  If not see
+ * <http://www.gnu.org/licenses/>.
+ *
+ * Linking this code with other modules is making a combined work
+ * based on this code.  Thus, the terms and conditions of the GNU
+ * General Public License cover the whole combination.
+ *
+ * As a special exception, the copyright holders of this code give
+ * you permission to link this code with independent modules to
+ * produce an executable, regardless of the license terms of these
+ * independent modules, and to copy and distribute the resulting
+ * executable under terms of your choice, provided that you also
+ * meet, for each linked independent module, the terms and conditions
+ * of the license of that module.  An independent module is a module
+ * which is not derived from or based on this code.  If you modify
+ * this code, you may extend this exception to your version of the
+ * library, but you are not obligated to do so.  If you do not wish
+ * to do so, delete this exception statement from your version.
+ */
+
+package com.redhat.thermostat.agent;
+
+import java.util.Collection;
+import java.util.concurrent.CountDownLatch;
+import java.util.logging.Level;
+import java.util.logging.Logger;
+
+import com.redhat.thermostat.agent.config.AgentConfigsUtils;
+import com.redhat.thermostat.agent.config.AgentOptionParser;
+import com.redhat.thermostat.agent.config.AgentStartupConfiguration;
+import com.redhat.thermostat.backend.BackendLoadException;
+import com.redhat.thermostat.backend.BackendRegistry;
+import com.redhat.thermostat.common.Constants;
+import com.redhat.thermostat.common.LaunchException;
+import com.redhat.thermostat.common.ThreadPoolTimerFactory;
+import com.redhat.thermostat.common.TimerFactory;
+import com.redhat.thermostat.common.appctx.ApplicationContext;
+import com.redhat.thermostat.common.cli.ArgumentSpec;
+import com.redhat.thermostat.common.cli.Arguments;
+import com.redhat.thermostat.common.cli.CommandContext;
+import com.redhat.thermostat.common.cli.CommandException;
+import com.redhat.thermostat.common.config.InvalidConfigurationException;
+import com.redhat.thermostat.common.dao.DAOFactory;
+import com.redhat.thermostat.common.dao.MongoDAOFactory;
+import com.redhat.thermostat.common.storage.Connection;
+import com.redhat.thermostat.common.storage.Connection.ConnectionListener;
+import com.redhat.thermostat.common.storage.Connection.ConnectionStatus;
+import com.redhat.thermostat.common.storage.MongoStorageProvider;
+import com.redhat.thermostat.common.storage.StorageProvider;
+import com.redhat.thermostat.common.tools.BasicCommand;
+import com.redhat.thermostat.common.utils.LoggingUtils;
+
+import sun.misc.Signal;
+import sun.misc.SignalHandler;
+
+@SuppressWarnings("restriction")
+public final class AgentApplication extends BasicCommand {
+
+    private static final String NAME = "agent";
+
+    // TODO: Use LocaleResources for i18n-ized strings.
+    private static final String DESCRIPTION = "starts and stops the thermostat agent";
+
+    private static final String USAGE = DESCRIPTION;
+
+    private AgentStartupConfiguration configuration;
+    private AgentOptionParser parser;
+    
+    private void parseArguments(Arguments args) throws InvalidConfigurationException {
+        configuration = AgentConfigsUtils.createAgentConfigs();
+        parser = new AgentOptionParser(configuration, args);
+        parser.parse();
+    }
+
+    @Override
+    public AgentStartupConfiguration getConfiguration() {
+        return configuration;
+    }
+    
+    private void runAgent(CommandContext ctx) {
+        long startTime = System.currentTimeMillis();
+        configuration.setStartTime(startTime);
+        
+        if (configuration.isDebugConsole()) {
+            LoggingUtils.useDevelConsole();
+        }
+        final Logger logger = LoggingUtils.getLogger(AgentApplication.class);
+
+        StorageProvider connProv = new MongoStorageProvider(configuration);
+        DAOFactory daoFactory = new MongoDAOFactory(connProv);
+        ApplicationContext.getInstance().setDAOFactory(daoFactory);
+        TimerFactory timerFactory = new ThreadPoolTimerFactory(1);
+        ApplicationContext.getInstance().setTimerFactory(timerFactory);
+
+        Connection connection = daoFactory.getConnection();
+        ConnectionListener connectionListener = new ConnectionListener() {
+            @Override
+            public void changed(ConnectionStatus newStatus) {
+                switch (newStatus) {
+                case DISCONNECTED:
+                    logger.warning("Unexpected disconnect event.");
+                    break;
+                case CONNECTING:
+                    logger.fine("Connecting to storage.");
+                    break;
+                case CONNECTED:
+                    logger.fine("Connected to storage.");
+                    break;
+                case FAILED_TO_CONNECT:
+                    logger.warning("Could not connect to storage.");
+                    System.exit(Constants.EXIT_UNABLE_TO_CONNECT_TO_DATABASE);
+                default:
+                    logger.warning("Unfamiliar ConnectionStatus value");
+                }
+            }
+        };
+
+        connection.addListener(connectionListener);
+        connection.connect();
+        logger.fine("Connecting to storage...");
+
+        BackendRegistry backendRegistry = null;
+        try {
+            backendRegistry = new BackendRegistry(configuration);
+        } catch (BackendLoadException ble) {
+            logger.log(Level.SEVERE, "Could not get BackendRegistry instance.", ble);
+            System.exit(Constants.EXIT_BACKEND_LOAD_ERROR);
+        }
+
+        final Agent agent = new Agent(backendRegistry, configuration, daoFactory);
+        try {
+            logger.fine("Starting agent.");
+            agent.start();
+        } catch (LaunchException le) {
+            logger.log(Level.SEVERE,
+                    "Agent could not start, probably because a configured backend could not be activated.",
+                    le);
+            System.exit(Constants.EXIT_BACKEND_START_ERROR);
+        }
+        logger.fine("Agent started.");
+
+        ctx.getConsole().getOutput().println("Agent id: " + agent.getId());
+        ctx.getConsole().getOutput().println("agent started.");
+        logger.fine("Agent id: " + agent.getId());
+
+        final CountDownLatch shutdownLatch = new CountDownLatch(1);
+        Signal.handle(new Signal("INT"), new SignalHandler() {
+            public void handle(sun.misc.Signal sig) {
+                agent.stop();
+                logger.fine("Agent stopped.");       
+                shutdownLatch.countDown();
+            }
+        });
+        try {
+            shutdownLatch.await();
+            logger.fine("terimating agent cmd");
+        } catch (InterruptedException e) {
+            return;
+        }
+    }
+    
+    @Override
+    public void run(CommandContext ctx) throws CommandException {
+        try {
+            parseArguments(ctx.getArguments());
+            if (!parser.isHelp()) {
+                runAgent(ctx);
+            }
+        } catch (InvalidConfigurationException ex) {
+            throw new CommandException(ex);
+        }
+    }
+
+    @Override
+    public void disable() {
+        /* NO-OP */
+    }
+
+    @Override
+    public String getName() {
+        return NAME;
+    }
+
+    @Override
+    public String getDescription() {
+        return DESCRIPTION;
+    }
+
+    @Override
+    public String getUsage() {
+        return USAGE;
+    }
+
+    @Override
+    public Collection<ArgumentSpec> getAcceptedArguments() {
+        return AgentOptionParser.getAcceptedArguments();
+    }
+
+}

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/agent/core/src/main/java/com/redhat/thermostat/agent/JvmStatusListener.java	Tue Jun 12 14:02:16 2012 -0400
@@ -0,0 +1,44 @@
+/*
+ * Copyright 2012 Red Hat, Inc.
+ *
+ * This file is part of Thermostat.
+ *
+ * Thermostat is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published
+ * by the Free Software Foundation; either version 2, or (at your
+ * option) any later version.
+ *
+ * Thermostat is distributed in the hope that it will be useful, but
+ * WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with Thermostat; see the file COPYING.  If not see
+ * <http://www.gnu.org/licenses/>.
+ *
+ * Linking this code with other modules is making a combined work
+ * based on this code.  Thus, the terms and conditions of the GNU
+ * General Public License cover the whole combination.
+ *
+ * As a special exception, the copyright holders of this code give
+ * you permission to link this code with independent modules to
+ * produce an executable, regardless of the license terms of these
+ * independent modules, and to copy and distribute the resulting
+ * executable under terms of your choice, provided that you also
+ * meet, for each linked independent module, the terms and conditions
+ * of the license of that module.  An independent module is a module
+ * which is not derived from or based on this code.  If you modify
+ * this code, you may extend this exception to your version of the
+ * library, but you are not obligated to do so.  If you do not wish
+ * to do so, delete this exception statement from your version.
+ */
+
+package com.redhat.thermostat.agent;
+
+public interface JvmStatusListener {
+
+    public void jvmStarted(int pid);
+
+    public void jvmStopped(int pid);
+}

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/agent/core/src/main/java/com/redhat/thermostat/agent/JvmStatusNotifier.java	Tue Jun 12 14:02:16 2012 -0400
@@ -0,0 +1,55 @@
+/*
+ * Copyright 2012 Red Hat, Inc.
+ *
+ * This file is part of Thermostat.
+ *
+ * Thermostat is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published
+ * by the Free Software Foundation; either version 2, or (at your
+ * option) any later version.
+ *
+ * Thermostat is distributed in the hope that it will be useful, but
+ * WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with Thermostat; see the file COPYING.  If not see
+ * <http://www.gnu.org/licenses/>.
+ *
+ * Linking this code with other modules is making a combined work
+ * based on this code.  Thus, the terms and conditions of the GNU
+ * General Public License cover the whole combination.
+ *
+ * As a special exception, the copyright holders of this code give
+ * you permission to link this code with independent modules to
+ * produce an executable, regardless of the license terms of these
+ * independent modules, and to copy and distribute the resulting
+ * executable under terms of your choice, provided that you also
+ * meet, for each linked independent module, the terms and conditions
+ * of the license of that module.  An independent module is a module
+ * which is not derived from or based on this code.  If you modify
+ * this code, you may extend this exception to your version of the
+ * library, but you are not obligated to do so.  If you do not wish
+ * to do so, delete this exception statement from your version.
+ */
+
+package com.redhat.thermostat.agent;
+
+public interface JvmStatusNotifier {
+
+    /**
+     * Request to be informed when JVM processes are started or stopped.
+     * 
+     * @param listener the receiver of future {@link JvmStatusListener.jvmStarted()}
+     * and {@link JvmStatusListener.jvmStopped()} calls
+     */
+    public void addJvmStatusListener(JvmStatusListener listener);
+
+    /**
+     * Request to no longer be informed when JVM processes are started or stopped.
+     * @param listener the {@link JvmStatusListener} to be unregistered.
+     */
+    public void removeJvmStatusListener(JvmStatusListener listener);
+
+}

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/agent/core/src/main/java/com/redhat/thermostat/agent/config/AgentConfigsUtils.java	Tue Jun 12 14:02:16 2012 -0400
@@ -0,0 +1,91 @@
+/*
+ * Copyright 2012 Red Hat, Inc.
+ *
+ * This file is part of Thermostat.
+ *
+ * Thermostat is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published
+ * by the Free Software Foundation; either version 2, or (at your
+ * option) any later version.
+ *
+ * Thermostat is distributed in the hope that it will be useful, but
+ * WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with Thermostat; see the file COPYING.  If not see
+ * <http://www.gnu.org/licenses/>.
+ *
+ * Linking this code with other modules is making a combined work
+ * based on this code.  Thus, the terms and conditions of the GNU
+ * General Public License cover the whole combination.
+ *
+ * As a special exception, the copyright holders of this code give
+ * you permission to link this code with independent modules to
+ * produce an executable, regardless of the license terms of these
+ * independent modules, and to copy and distribute the resulting
+ * executable under terms of your choice, provided that you also
+ * meet, for each linked independent module, the terms and conditions
+ * of the license of that module.  An independent module is a module
+ * which is not derived from or based on this code.  If you modify
+ * this code, you may extend this exception to your version of the
+ * library, but you are not obligated to do so.  If you do not wish
+ * to do so, delete this exception statement from your version.
+ */
+
+package com.redhat.thermostat.agent.config;
+
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.IOException;
+import java.util.Properties;
+
+import com.redhat.thermostat.common.config.ConfigUtils;
+import com.redhat.thermostat.common.config.InvalidConfigurationException;
+
+public class AgentConfigsUtils {
+
+    public static AgentStartupConfiguration createAgentConfigs() throws InvalidConfigurationException {
+        
+        AgentStartupConfiguration config = new AgentStartupConfiguration();
+        
+        File propertyFile = ConfigUtils.getAgentConfigurationFile();
+        readAndSetProperties(propertyFile, config);
+        
+        return config;
+    }
+    
+    private static void readAndSetProperties(File propertyFile, AgentStartupConfiguration configuration)
+            throws InvalidConfigurationException
+    {
+        Properties properties = new Properties();
+        try {
+            properties.load(new FileInputStream(propertyFile));
+            
+        } catch (IOException e) {
+            throw new InvalidConfigurationException(e);
+        }
+        
+        if (properties.containsKey(AgentProperties.BACKENDS.name())) {
+            // this is a command separated list of backends
+            String backends = properties.getProperty(AgentProperties.BACKENDS.name());
+            configuration.parseBackends(backends.split(","));
+            
+        } else {
+            throw new InvalidConfigurationException(AgentProperties.BACKENDS + " property missing");
+        }
+        
+        if (properties.containsKey(AgentProperties.DB_URL.name())) {
+            String db = properties.getProperty(AgentProperties.DB_URL.name());
+            configuration.setDatabaseURL(db);
+        }
+        
+        configuration.setPurge(true);
+        if (properties.containsKey(AgentProperties.SAVE_ON_EXIT.name())) {
+            String purge = (String) properties.get(AgentProperties.SAVE_ON_EXIT.name());
+            configuration.setPurge(!Boolean.parseBoolean(purge));
+        }
+    }
+    
+}

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/agent/core/src/main/java/com/redhat/thermostat/agent/config/AgentOptionParser.java	Tue Jun 12 14:02:16 2012 -0400
@@ -0,0 +1,110 @@
+/*
+ * Copyright 2012 Red Hat, Inc.
+ *
+ * This file is part of Thermostat.
+ *
+ * Thermostat is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published
+ * by the Free Software Foundation; either version 2, or (at your
+ * option) any later version.
+ *
+ * Thermostat is distributed in the hope that it will be useful, but
+ * WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with Thermostat; see the file COPYING.  If not see
+ * <http://www.gnu.org/licenses/>.
+ *
+ * Linking this code with other modules is making a combined work
+ * based on this code.  Thus, the terms and conditions of the GNU
+ * General Public License cover the whole combination.
+ *
+ * As a special exception, the copyright holders of this code give
+ * you permission to link this code with independent modules to
+ * produce an executable, regardless of the license terms of these
+ * independent modules, and to copy and distribute the resulting
+ * executable under terms of your choice, provided that you also
+ * meet, for each linked independent module, the terms and conditions
+ * of the license of that module.  An independent module is a module
+ * which is not derived from or based on this code.  If you modify
+ * this code, you may extend this exception to your version of the
+ * library, but you are not obligated to do so.  If you do not wish
+ * to do so, delete this exception statement from your version.
+ */
+
+package com.redhat.thermostat.agent.config;
+
+import java.util.Arrays;
+import java.util.Collection;
+
+import com.redhat.thermostat.common.cli.ArgumentSpec;
+import com.redhat.thermostat.common.cli.Arguments;
+import com.redhat.thermostat.common.cli.SimpleArgumentSpec;
+import com.redhat.thermostat.common.config.InvalidConfigurationException;
+import com.redhat.thermostat.common.config.ThermostatOptionParser;
+
+public class AgentOptionParser implements ThermostatOptionParser {
+
+    private AgentStartupConfiguration configuration;
+    private Arguments args;
+    
+    private boolean isHelp;
+    
+    public AgentOptionParser(AgentStartupConfiguration configuration, Arguments args) {
+        this.configuration = configuration;
+        this.args = args;
+        isHelp = false;
+    }
+    
+    @Override
+    public void parse() throws InvalidConfigurationException {
+
+        if (args.hasArgument(Args.SAVE_ON_EXIT.option)) {
+            configuration.setPurge(false);
+        }
+
+        configuration.setDebugConsole(args.hasArgument(Args.DEBUG.option));
+        
+        if (args.hasArgument(Args.DB.option)) {
+            String url = args.getArgument(Args.DB.option);
+            configuration.setDatabaseURL(url);
+        } else {
+            if (configuration.getDBConnectionString() == null) {
+                System.err.println("database url not specified... must be " +
+                                   "either set in config or passed on " +
+                                   "the command line");
+                isHelp = true;
+            }
+        }
+    }
+    
+    public boolean isHelp() {
+        return isHelp;
+    }
+    
+    private static enum Args {
+        
+        // TODO: localize
+        SAVE_ON_EXIT("saveOnExit", "save the data on exit"),
+        DB("dbUrl", "connect to the given url"),
+        DEBUG("debug", "launch with debug console enabled"),
+        HELP("help", "print this help and exit");
+        
+        private String option;
+        private String description;
+        
+        Args(String option, String description) {
+            this.option = option;
+            this.description = description;
+        }
+    }
+
+    public static Collection<ArgumentSpec> getAcceptedArguments() {
+        ArgumentSpec saveOnExit = new SimpleArgumentSpec(Args.SAVE_ON_EXIT.option, "s", Args.SAVE_ON_EXIT.description, false, false);
+        ArgumentSpec db = new SimpleArgumentSpec(Args.DB.option, "d",  Args.DB.description, true, true);
+        ArgumentSpec debug = new SimpleArgumentSpec(Args.DEBUG.option, Args.DEBUG.description);
+        return Arrays.asList(saveOnExit, db, debug);
+    }
+}

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/agent/core/src/main/java/com/redhat/thermostat/agent/config/AgentProperties.java	Tue Jun 12 14:02:16 2012 -0400
@@ -0,0 +1,46 @@
+/*
+ * Copyright 2012 Red Hat, Inc.
+ *
+ * This file is part of Thermostat.
+ *
+ * Thermostat is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published
+ * by the Free Software Foundation; either version 2, or (at your
+ * option) any later version.
+ *
+ * Thermostat is distributed in the hope that it will be useful, but
+ * WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with Thermostat; see the file COPYING.  If not see
+ * <http://www.gnu.org/licenses/>.
+ *
+ * Linking this code with other modules is making a combined work
+ * based on this code.  Thus, the terms and conditions of the GNU
+ * General Public License cover the whole combination.
+ *
+ * As a special exception, the copyright holders of this code give
+ * you permission to link this code with independent modules to
+ * produce an executable, regardless of the license terms of these
+ * independent modules, and to copy and distribute the resulting
+ * executable under terms of your choice, provided that you also
+ * meet, for each linked independent module, the terms and conditions
+ * of the license of that module.  An independent module is a module
+ * which is not derived from or based on this code.  If you modify
+ * this code, you may extend this exception to your version of the
+ * library, but you are not obligated to do so.  If you do not wish
+ * to do so, delete this exception statement from your version.
+ */
+
+package com.redhat.thermostat.agent.config;
+
+public enum AgentProperties {
+
+    // backend list, comma separated
+    BACKENDS,
+    DEBUG_CONSOLE,
+    DB_URL,
+    SAVE_ON_EXIT
+}