Added consumer agent jar with dependencies to pom. (Minor bug fix.)

Author: cipriancraciun

logback-amqp-consumer/pom.xml

@@ -28,4 +28,31 @@
 			<version>2.2.0</version>
 		</dependency>
 	</dependencies>
+	<build>
+		<plugins>
+			<plugin>
+				<groupId>org.apache.maven.plugins</groupId>
+				<artifactId>maven-assembly-plugin</artifactId>
+				<version>2.2</version>
+				<configuration>
+					<descriptorRefs>
+						<descriptorRef>jar-with-dependencies</descriptorRef>
+					</descriptorRefs>
+					<archive>
+						<manifest>
+							<mainClass>ch.qos.logback.amqp.AmqpConsumerAgentMain</mainClass>
+						</manifest>
+					</archive>
+				</configuration>
+				<executions>
+					<execution>
+						<phase>package</phase>
+						<goals>
+							<goal>single</goal>
+						</goals>
+					</execution>
+				</executions>
+			</plugin>
+		</plugins>
+	</build>
 </project>

logback-amqp-consumer/src/main/java/ch/qos/logback/amqp/AmqpConsumerAgentMain.java

@@ -54,10 +54,10 @@ public static final void main (final String[] arguments)
 			agent.start ();
 
 		while (true) {
+			boolean stillRunning = false;
 			for (final AmqpConsumerAgent agent : agents)
-				if (!agent.isRunning ())
-					agents.remove (agent);
-			if (agents.isEmpty ())
+				stillRunning |= agent.isRunning ();
+			if (!stillRunning)
 				break;
 			try {
 				Thread.sleep (AmqpConsumerAgent.waitTimeout);