diff --git a/ChangeLog.txt b/ChangeLog.txt index e66a167e..67319dc9 100644 --- a/ChangeLog.txt +++ b/ChangeLog.txt @@ -8,6 +8,7 @@ Version 0.7: Added packetIdentifier storage and generation Fixed issue #16, bad packetId for will messages with qos > 0 Added store path variable "persistent_store" to configuration file (picked from Steven Warwick fork) + Removed OSGi bundle, developer time burner Version 0.6: Fix issue #42, bad password file path composition diff --git a/broker/src/test/resources/log4j.properties b/broker/src/test/resources/log4j.properties index c9fea13d..62fec888 100644 --- a/broker/src/test/resources/log4j.properties +++ b/broker/src/test/resources/log4j.properties @@ -2,19 +2,21 @@ #log4j.rootLogger=ERROR, A1 log4j.rootLogger=ERROR, stdout, file +#log4j.logger.org.eclipse.moquette=WARN log4j.logger.org.eclipse.moquette=DEBUG #log4j.logger.org.eclipse.moquette.server.ServerIntegrationFuseTest=DEBUG #log4j.logger.org.eclipse.moquette.server.ServerLowlevelMessagesIntegrationTests=DEBUG log4j.logger.org.eclipse.moquette.server.ServerIntegrationQoSValidationTest=INFO -#log4j.logger.org.eclipse.moquette.spi.impl.ProtocolProcessor=INFO + +#log4j.logger.org.eclipse.moquette.spi.impl.ProtocolProcessor=WARN log4j.logger.org.eclipse.moquette.spi.impl.ProtocolProcessor=DEBUG -#log4j.logger.org.eclipse.moquette.spi.impl.ProtocolProcessor=TRACE log4j.logger.org.eclipse.moquette.spi.impl.SimpleMessaging=WARN #Protocol parsing log4j.logger.org.eclipse.moquette.server.netty.NettyMQTTHandler=WARN #log4j.logger.org.eclipse.moquette.server.netty.NettyMQTTHandler=DEBUG -log4j.logger.org.eclipse.moquette.parser.netty=WARN +log4j.logger.org.eclipse.moquette.parser.netty=DEBUG + #Storage service #log4j.logger.org.eclipse.moquette.spi.impl.subscriptions.SubscriptionsStore=DEBUG log4j.logger.org.eclipse.moquette.spi.persistence.MapDBPersistentStore=WARN diff --git a/bundle/howto.txt b/bundle/howto.txt deleted file mode 100644 index 9ab0f079..00000000 --- a/bundle/howto.txt +++ /dev/null @@ -1,8 +0,0 @@ -Simple guide on how to use the bundle in a testable OSGi container: -- mvn pax:provision //to create and download the required bundles -- osgi>exit -- cp target/moquette-bundle-0.5.jar runner/bundles/ //to move the broker bundle -- mvn pax:provision //restart the OSGi container -- osgi> install file:bundles/moquette-bundle-0.5.jar -- osgi> ss -- osgi> start diff --git a/bundle/pom.xml b/bundle/pom.xml deleted file mode 100644 index 1ee17d21..00000000 --- a/bundle/pom.xml +++ /dev/null @@ -1,240 +0,0 @@ - - - 4.0.0 - - ../ - - moquette-parent - org.eclipse.moquette - 0.7-SNAPSHOT - - - moquette-bundle - bundle - - Moquette - OSGi bundle - - - UTF-8 - - - - - ${project.groupId} - moquette-parser-commons - ${project.version} - - - - ${project.groupId} - moquette-netty-parser - ${project.version} - - - - ${project.groupId} - moquette-broker - ${project.version} - - - - com.lmax - disruptor - 3.3.2 - provided - - - - org.slf4j - slf4j-api - 1.7.5 - provided - - - - org.slf4j - slf4j-log4j12 - 1.7.5 - - - - - org.apache.felix - org.osgi.core - 1.0.0 - - - - org.apache.felix - org.osgi.compendium - 1.0.0 - - - - - - - io.netty - netty-common - ${netty.version} - provided - - - - io.netty - netty-buffer - ${netty.version} - provided - - - - io.netty - netty-transport - ${netty.version} - provided - - - - io.netty - netty-handler - ${netty.version} - provided - - - - io.netty - netty-codec - ${netty.version} - provided - - - - io.netty - netty-codec-http - ${netty.version} - provided - - - - org.mapdb - mapdb - 2.0.0-SNAPSHOT - - - - - junit - junit - 4.8.2 - test - - - - - org.mockito - mockito-core - 1.9.0 - test - - - - org.fusesource.mqtt-client - mqtt-client - 1.5 - test - - - - org.eclipse.paho - org.eclipse.paho.client.mqttv3 - 1.0.1 - test - - - - - - - org.apache.maven.plugins - maven-surefire-plugin - - - **/*Test.java - - - - - - org.apache.felix - maven-bundle-plugin - 2.1.0 - true - - - - - - - - org.eclipse.moquette.proto.messages.*, - org.eclipse.moquette.server.netty.metrics - - - org.eclipse.moquette.bundle, - ${project.groupId}.* - - - - - - - - - - - - - ${project.groupId}.bundle.Activator - - file://${basedir}/target/localobr/ - - - - - - org.ops4j - maven-pax-plugin - 1.5 - - - - 1.8.6 - - - felix - - - --bootDelegation=sun.*,com.sun.* - - - --autoWrap - mvn:org.hdrhistogram/HdrHistogram/2.1.4 - - - - - - - - - - Paho Releases - https://repo.eclipse.org/content/repositories/paho-releases/ - - - diff --git a/bundle/src/main/java/org/eclipse/moquette/bundle/Activator.java b/bundle/src/main/java/org/eclipse/moquette/bundle/Activator.java deleted file mode 100644 index 6df34ff0..00000000 --- a/bundle/src/main/java/org/eclipse/moquette/bundle/Activator.java +++ /dev/null @@ -1,45 +0,0 @@ -/* - * Copyright (c) 2012-2014 The original author or authors - * ------------------------------------------------------ - * All rights reserved. This program and the accompanying materials - * are made available under the terms of the Eclipse Public License v1.0 - * and Apache License v2.0 which accompanies this distribution. - * - * The Eclipse Public License is available at - * http://www.eclipse.org/legal/epl-v10.html - * - * The Apache License v2.0 is available at - * http://www.opensource.org/licenses/apache2.0.php - * - * You may elect to redistribute this code under either of these licenses. - */ -package org.eclipse.moquette.bundle; - -import org.eclipse.moquette.server.Server; -import org.osgi.framework.BundleActivator; -import org.osgi.framework.BundleContext; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -/** - * Start and stop a configured version of the MQTT broker server. - * - * @author Didier Donsez - * @todo add config admin for port (in NettyAcceptor) - */ -public class Activator implements BundleActivator { - - private static final Logger LOG = LoggerFactory.getLogger(Server.class); - private Server server = null; - - public void start(BundleContext bundleContext) throws Exception { - server = new Server(); - server.startServer(); - LOG.info("Moquette MQTT broker started, version 0.7-SNAPSHOT"); - } - - public void stop(BundleContext bundleContext) throws Exception { - server.stopServer(); - LOG.info("Moquette MQTT broker stopped, version 0.7-SNAPSHOT"); - } -} diff --git a/pom.xml b/pom.xml index 5970bcb8..22b48755 100644 --- a/pom.xml +++ b/pom.xml @@ -23,7 +23,6 @@ netty_parser broker distribution - bundle