Skip to content

Instantly share code, notes, and snippets.

View dejanb's full-sized avatar

Dejan Bosanac dejanb

View GitHub Profile
## ---------------------------------------------------------------------------
## 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
##
<property name="authenticate" value="true"/>
<property name="authenticate" value="false"/>
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;
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
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
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
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;
We couldn’t find that file to show.
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)