You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by jb...@apache.org on 2016/10/21 16:27:56 UTC
[1/2] activemq-artemis git commit: Fix formatting
Repository: activemq-artemis
Updated Branches:
refs/heads/ARTEMIS-780 c2f0f4d49 -> 60bbb3fbd
Fix formatting
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/60bbb3fb
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/60bbb3fb
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/60bbb3fb
Branch: refs/heads/ARTEMIS-780
Commit: 60bbb3fbd074b192d80fbc842894abd04e2c1b4e
Parents: 1a6f17f
Author: jbertram <jb...@apache.com>
Authored: Fri Oct 21 11:25:07 2016 -0500
Committer: jbertram <jb...@apache.com>
Committed: Fri Oct 21 11:26:27 2016 -0500
----------------------------------------------------------------------
.../core/persistence/impl/RoutingType.java | 43 --------------------
.../config/XMLConfigurationMigration.java | 26 ++++--------
2 files changed, 8 insertions(+), 61 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/60bbb3fb/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/RoutingType.java
----------------------------------------------------------------------
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/RoutingType.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/RoutingType.java
deleted file mode 100644
index 329d8e9..0000000
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/RoutingType.java
+++ /dev/null
@@ -1,43 +0,0 @@
-/*
- * 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
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.activemq.artemis.core.persistence.impl;
-
-public enum RoutingType {
- Multicast, Anycast;
-
- public byte getType() {
- switch (this) {
- case Multicast:
- return 0;
- case Anycast:
- return 1;
- default:
- return -1;
- }
- }
-
- public static RoutingType getType(byte type) {
- switch (type) {
- case 0:
- return Multicast;
- case 1:
- return Anycast;
- default:
- return null;
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/60bbb3fb/artemis-tools/src/main/java/org/apache/activemq/artemis/tools/migrate/config/XMLConfigurationMigration.java
----------------------------------------------------------------------
diff --git a/artemis-tools/src/main/java/org/apache/activemq/artemis/tools/migrate/config/XMLConfigurationMigration.java b/artemis-tools/src/main/java/org/apache/activemq/artemis/tools/migrate/config/XMLConfigurationMigration.java
index 56833ea..90be53c 100644
--- a/artemis-tools/src/main/java/org/apache/activemq/artemis/tools/migrate/config/XMLConfigurationMigration.java
+++ b/artemis-tools/src/main/java/org/apache/activemq/artemis/tools/migrate/config/XMLConfigurationMigration.java
@@ -50,19 +50,16 @@ public class XMLConfigurationMigration {
if (args.length == 0) {
System.err.println("Invalid args");
printUsage();
- }
- else {
+ } else {
File input = new File(args[0]);
if (input.isDirectory()) {
System.out.println("Scanning directory: " + input.getAbsolutePath());
recursiveTransform(input);
- }
- else {
+ } else {
if (args.length != 2) {
System.err.println("Invalid args");
printUsage();
- }
- else {
+ } else {
transform(input, new File(args[1]));
}
}
@@ -70,13 +67,11 @@ public class XMLConfigurationMigration {
}
private static void recursiveTransform(File root) throws Exception {
- for ( File file : root.listFiles())
- {
+ for (File file : root.listFiles()) {
scanAndTransform(file);
}
}
-
public static void scanAndTransform(File pFile) throws Exception {
try {
for (File f : pFile.listFiles()) {
@@ -93,14 +88,12 @@ public class XMLConfigurationMigration {
file.renameTo(r);
}
}
- }
- catch (Exception e) {
+ } catch (Exception e) {
//continue
}
}
}
- }
- catch (NullPointerException e) {
+ } catch (NullPointerException e) {
System.out.println(pFile.getAbsoluteFile());
}
}
@@ -125,9 +118,7 @@ public class XMLConfigurationMigration {
migration.write(output, properties);
return true;
}
- }
- catch (Exception e)
- {
+ } catch (Exception e) {
System.err.println("Error tranforming document");
e.printStackTrace();
}
@@ -174,8 +165,7 @@ public class XMLConfigurationMigration {
if (addresses.containsKey(addressName)) {
address = addresses.get(addressName);
- }
- else {
+ } else {
address = new Address();
address.setName(addressName);
addresses.put(addressName, address);
[2/2] activemq-artemis git commit: Consolidate RoutingType impls
Posted by jb...@apache.org.
Consolidate RoutingType impls
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/1a6f17f6
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/1a6f17f6
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/1a6f17f6
Branch: refs/heads/ARTEMIS-780
Commit: 1a6f17f60ad885832147c063d6017184b99d7275
Parents: c2f0f4d
Author: jbertram <jb...@apache.com>
Authored: Fri Oct 21 10:51:29 2016 -0500
Committer: jbertram <jb...@apache.com>
Committed: Fri Oct 21 11:26:27 2016 -0500
----------------------------------------------------------------------
.../core/config/CoreAddressConfiguration.java | 8 ++---
.../core/persistence/AddressBindingInfo.java | 4 +--
.../codec/PersistentAddressBindingEncoding.java | 10 +++---
.../artemis/core/server/impl/AddressInfo.java | 33 ++++++++++++++++----
.../core/config/impl/FileConfigurationTest.java | 7 ++---
pom.xml | 1 +
6 files changed, 41 insertions(+), 22 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/1a6f17f6/artemis-server/src/main/java/org/apache/activemq/artemis/core/config/CoreAddressConfiguration.java
----------------------------------------------------------------------
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/config/CoreAddressConfiguration.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/config/CoreAddressConfiguration.java
index e01c398..6327f79 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/config/CoreAddressConfiguration.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/config/CoreAddressConfiguration.java
@@ -21,13 +21,13 @@ import java.util.ArrayList;
import java.util.List;
import org.apache.activemq.artemis.api.config.ActiveMQDefaultConfiguration;
-import org.apache.activemq.artemis.core.server.impl.AddressInfo.RoutingType;
+import org.apache.activemq.artemis.core.server.impl.AddressInfo;
public class CoreAddressConfiguration implements Serializable {
private String name = null;
- private RoutingType routingType = null;
+ private AddressInfo.RoutingType routingType = null;
private Integer defaultMaxConsumers = ActiveMQDefaultConfiguration.getDefaultMaxQueueConsumers();
@@ -47,11 +47,11 @@ public class CoreAddressConfiguration implements Serializable {
return this;
}
- public RoutingType getRoutingType() {
+ public AddressInfo.RoutingType getRoutingType() {
return routingType;
}
- public CoreAddressConfiguration setRoutingType(RoutingType routingType) {
+ public CoreAddressConfiguration setRoutingType(AddressInfo.RoutingType routingType) {
this.routingType = routingType;
return this;
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/1a6f17f6/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/AddressBindingInfo.java
----------------------------------------------------------------------
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/AddressBindingInfo.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/AddressBindingInfo.java
index 4256774..83d37bc 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/AddressBindingInfo.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/AddressBindingInfo.java
@@ -17,7 +17,7 @@
package org.apache.activemq.artemis.core.persistence;
import org.apache.activemq.artemis.api.core.SimpleString;
-import org.apache.activemq.artemis.core.persistence.impl.RoutingType;
+import org.apache.activemq.artemis.core.server.impl.AddressInfo;
public interface AddressBindingInfo {
@@ -29,6 +29,6 @@ public interface AddressBindingInfo {
SimpleString getUser();
- RoutingType getRoutingType();
+ AddressInfo.RoutingType getRoutingType();
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/1a6f17f6/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/codec/PersistentAddressBindingEncoding.java
----------------------------------------------------------------------
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/codec/PersistentAddressBindingEncoding.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/codec/PersistentAddressBindingEncoding.java
index 8aa54e4..9f47362 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/codec/PersistentAddressBindingEncoding.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/codec/PersistentAddressBindingEncoding.java
@@ -20,7 +20,7 @@ import org.apache.activemq.artemis.api.core.ActiveMQBuffer;
import org.apache.activemq.artemis.api.core.SimpleString;
import org.apache.activemq.artemis.core.journal.EncodingSupport;
import org.apache.activemq.artemis.core.persistence.AddressBindingInfo;
-import org.apache.activemq.artemis.core.persistence.impl.RoutingType;
+import org.apache.activemq.artemis.core.server.impl.AddressInfo;
import org.apache.activemq.artemis.utils.DataConstants;
public class PersistentAddressBindingEncoding implements EncodingSupport, AddressBindingInfo {
@@ -33,7 +33,7 @@ public class PersistentAddressBindingEncoding implements EncodingSupport, Addres
public SimpleString user;
- public RoutingType routingType;
+ public AddressInfo.RoutingType routingType;
public PersistentAddressBindingEncoding() {
}
@@ -55,7 +55,7 @@ public class PersistentAddressBindingEncoding implements EncodingSupport, Addres
public PersistentAddressBindingEncoding(final SimpleString name,
final SimpleString user,
final boolean autoCreated,
- final RoutingType routingType) {
+ final AddressInfo.RoutingType routingType) {
this.name = name;
this.user = user;
this.autoCreated = autoCreated;
@@ -87,7 +87,7 @@ public class PersistentAddressBindingEncoding implements EncodingSupport, Addres
}
@Override
- public RoutingType getRoutingType() {
+ public AddressInfo.RoutingType getRoutingType() {
return routingType;
}
@@ -109,7 +109,7 @@ public class PersistentAddressBindingEncoding implements EncodingSupport, Addres
}
autoCreated = buffer.readBoolean();
- routingType = RoutingType.getType(buffer.readByte());
+ routingType = AddressInfo.RoutingType.getType(buffer.readByte());
}
@Override
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/1a6f17f6/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/AddressInfo.java
----------------------------------------------------------------------
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/AddressInfo.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/AddressInfo.java
index 03c3fa0..4c6ec1f 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/AddressInfo.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/AddressInfo.java
@@ -16,18 +16,13 @@
*/
package org.apache.activemq.artemis.core.server.impl;
-import org.apache.activemq.artemis.api.config.ActiveMQDefaultConfiguration;
import org.apache.activemq.artemis.api.core.SimpleString;
public class AddressInfo {
- public enum RoutingType {
- MULTICAST, ANYCAST
- }
-
private final SimpleString name;
- private RoutingType routingType = RoutingType.MULTICAST;
+ private RoutingType routingType = RoutingType.Multicast;
private boolean defaultDeleteOnNoConsumers;
@@ -64,4 +59,30 @@ public class AddressInfo {
public SimpleString getName() {
return name;
}
+
+ public enum RoutingType {
+ Multicast, Anycast;
+
+ public byte getType() {
+ switch (this) {
+ case Multicast:
+ return 0;
+ case Anycast:
+ return 1;
+ default:
+ return -1;
+ }
+ }
+
+ public static RoutingType getType(byte type) {
+ switch (type) {
+ case 0:
+ return Multicast;
+ case 1:
+ return Anycast;
+ default:
+ return null;
+ }
+ }
+ }
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/1a6f17f6/artemis-server/src/test/java/org/apache/activemq/artemis/core/config/impl/FileConfigurationTest.java
----------------------------------------------------------------------
diff --git a/artemis-server/src/test/java/org/apache/activemq/artemis/core/config/impl/FileConfigurationTest.java b/artemis-server/src/test/java/org/apache/activemq/artemis/core/config/impl/FileConfigurationTest.java
index ce924c0..f7a0175 100644
--- a/artemis-server/src/test/java/org/apache/activemq/artemis/core/config/impl/FileConfigurationTest.java
+++ b/artemis-server/src/test/java/org/apache/activemq/artemis/core/config/impl/FileConfigurationTest.java
@@ -52,9 +52,6 @@ import org.apache.activemq.artemis.core.settings.impl.SlowConsumerPolicy;
import org.junit.Assert;
import org.junit.Test;
-import static org.apache.activemq.artemis.core.server.impl.AddressInfo.RoutingType.ANYCAST;
-import static org.apache.activemq.artemis.core.server.impl.AddressInfo.RoutingType.MULTICAST;
-
public class FileConfigurationTest extends ConfigurationImplTest {
private final String fullConfigurationName = "ConfigurationTest-full-config.xml";
@@ -370,7 +367,7 @@ public class FileConfigurationTest extends ConfigurationImplTest {
// Addr 1
CoreAddressConfiguration addressConfiguration = conf.getAddressConfigurations().get(0);
assertEquals("addr1", addressConfiguration.getName());
- assertEquals(ANYCAST, addressConfiguration.getRoutingType());
+ assertEquals(AddressInfo.RoutingType.Anycast, addressConfiguration.getRoutingType());
assertEquals(2, addressConfiguration.getQueueConfigurations().size());
// Addr 1 Queue 1
@@ -396,7 +393,7 @@ public class FileConfigurationTest extends ConfigurationImplTest {
// Addr 2
addressConfiguration = conf.getAddressConfigurations().get(1);
assertEquals("addr2", addressConfiguration.getName());
- assertEquals(MULTICAST, addressConfiguration.getRoutingType());
+ assertEquals(AddressInfo.RoutingType.Multicast, addressConfiguration.getRoutingType());
assertEquals(2, addressConfiguration.getQueueConfigurations().size());
// Addr 2 Queue 1
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/1a6f17f6/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index bcb774c..1deccb8 100644
--- a/pom.xml
+++ b/pom.xml
@@ -1259,6 +1259,7 @@
<exclude>docs/**/_book/</exclude>
<exclude>**/target/</exclude>
<exclude>**/META-INF/services/*</exclude>
+ <exclude>**/META-INF/MANIFEST.MF</exclude>
<exclude>**/*.iml</exclude>
<exclude>**/*.jceks</exclude>
<exclude>**/*.jks</exclude>