dejanb

## ---------------------------------------------------------------------------
## Licensed to the Apache Software Foundation (ASF) under one or more
## contributor license agreements.  See the NOTICE file distributed with
## this work for additional information regarding copyright ownership.
## The ASF licenses this file to You 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
## 

dejanb

<property name="authenticate" value="true"/>

dejanb

<property name="authenticate" value="false"/>

dejanb

diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/Broker.java b/activemq-core/src/main/java/org/apache/activemq/broker/Broker.java
index 9db3fa0..94dfbd0 100755
--- a/activemq-core/src/main/java/org/apache/activemq/broker/Broker.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/Broker.java
@@ -17,6 +17,7 @@
 package org.apache.activemq.broker;
 
 import java.net.URI;
+import java.util.Map;
 import java.util.Set;

dejanb

16:00:20,111 | INFO  | 0.0/0.0.0.0:2181 | NIOServerCnxn                    | e.zookeeper.server.NIOServerCnxn 1434 | 42 - org.fusesource.fabric.fabric-zookeeper - 1.0.0.SNAPSHOT | Closed socket connection for client /192.168.1.107:60437 (no session established for client)
16:00:20,892 | INFO  | 0.0/0.0.0.0:2181 | NIOServerCnxn                    | per.server.NIOServerCnxn$Factory  250 | 42 - org.fusesource.fabric.fabric-zookeeper - 1.0.0.SNAPSHOT | Accepted socket connection from /192.168.1.107:60438
16:00:20,895 | INFO  | 0.0/0.0.0.0:2181 | NIOServerCnxn                    | e.zookeeper.server.NIOServerCnxn  751 | 42 - org.fusesource.fabric.fabric-zookeeper - 1.0.0.SNAPSHOT | Refusing session request for client /192.168.1.107:60438 as it has seen zxid 0x76 our last zxid is 0x5e client must try another server
16:00:20,896 | INFO  | 0.0/0.0.0.0:2181 | NIOServerCnxn                    | e.zookeeper.server.NIOServerCnxn 1434 | 42 - org.fusesource.fabric.fabric-zookeeper - 1.0.0.SNAPSHOT | Closed socket connectio

dejanb

shell:source mvn:org.fusesource.fon/fon-distro/1.0-SNAPSHOT/karaf/installer

fabric:create-profile --parents default broker

zk:create -r /fabric/configs/versions/base/profiles/broker/org.fusesource.fabric.agent/repository.activemq mvn:org.apache.activemq/activemq-karaf/5.5.0/xml/features
zk:create -r /fabric/configs/versions/base/profiles/broker/org.fusesource.fabric.agent/repository.karaf mvn:org.apache.karaf.assemblies.features/standard/2.2.1-SNAPSHOT/xml/features
zk:create -r /fabric/configs/versions/base/profiles/broker/org.fusesource.fabric.agent/feature.amq activemq-blueprint/5.5.0
zk:create -r /fabric/configs/versions/base/profiles/broker/org.fusesource.fabric.agent/bundle.config blueprint:file:/workspace/forge/activemq.xml

dejanb

shell:source mvn:org.fusesource.fon/fon-distro/1.0-SNAPSHOT/karaf/installer
shell:source mvn:org.fusesource.fon/fon-distro/1.0-SNAPSHOT/karaf/activemq 5.5.0

fabric:create-agent --profile activemq --parent root broker

fabric:connect broker

dejanb

diff --git a/activemq-core/src/test/java/org/apache/activemq/usecases/DurableUnsubscribeTest.java b/activemq-core/src/test/java/org/apache/activemq/usecases/DurableUnsubscribeTest.java
index 6a83016..8a39703 100644
--- a/activemq-core/src/test/java/org/apache/activemq/usecases/DurableUnsubscribeTest.java
+++ b/activemq-core/src/test/java/org/apache/activemq/usecases/DurableUnsubscribeTest.java
@@ -19,6 +19,7 @@ package org.apache.activemq.usecases;
 import java.lang.management.ManagementFactory;
 
 import javax.jms.Connection;
+import javax.jms.MessageProducer;
 import javax.jms.Session;

dejanb

We couldn’t find that file to show.

dejanb

scala: Error: object scala not found.
scala.tools.nsc.MissingRequirementError: object scala not found.
  at scala.tools.nsc.symtab.Definitions$definitions$.getModuleOrClass(Definitions.scala:655)
	at scala.tools.nsc.symtab.Definitions$definitions$.getModule(Definitions.scala:605)
	at scala.tools.nsc.symtab.Definitions$definitions$.ScalaPackage(Definitions.scala:145)
	at scala.tools.nsc.symtab.Definitions$definitions$.ScalaPackageClass(Definitions.scala:146)
	at scala.tools.nsc.symtab.Definitions$definitions$.AnyClass(Definitions.scala:176)
	at scala.tools.nsc.symtab.Definitions$definitions$.init(Definitions.scala:814)
	at scala.tools.nsc.Global$Run.<init>(Global.scala:697)
	at xsbt.CachedCompiler0$$anon$2.<init>(CompilerInterface.scala:104)