Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

merge PR #9 Renaming packages

This commit is contained in:
Andy Taylor 2014-11-17 14:45:28 +00:00 committed by Andy Taylor
parent f7e225d28f 9a587c5633
commit 97bbe8cd12
2696 changed files with 25142 additions and 26095 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
README.md
View File

@ -116,7 +116,7 @@ do this with Eclipse Juno (4.2).
The current recommended solution for Eclipse Kepler is to mark
`javacc-maven-plugin` as ignored by Eclipse, run Maven from the
command line and then modify the project `activemq6-core-client` adding
command line and then modify the project `activemq-core-client` adding
the folder `target/generated-sources/javacc` to its build path.
[m2e connector for javacc-maven-plugin]: https://github.com/objectledge/maven-extensions
@ -189,7 +189,7 @@ To setup repositories for reviewing and pushing:
# Clone the GitHub Mirror of ActiveMQ6 Repo:
git clone git@github.com:apache/activemq-6.git
# Add the following section to your <activemq6 repo>/.git/config statement to fetch all pull requests sent to the GitHub mirror. Note that the remote name for git@github.com:apache/activemq-6.git may be different. Be sure to edit all references to the remote name. In this case "activemq".
# Add the following section to your <activemq repo>/.git/config statement to fetch all pull requests sent to the GitHub mirror. Note that the remote name for git@github.com:apache/activemq-6.git may be different. Be sure to edit all references to the remote name. In this case "activemq".
[remote "origin"]
url = git@github.com:apache/activemq-6.git
fetch = +refs/heads/*:refs/remotes/origin/*
@ -206,7 +206,7 @@ To setup repositories for reviewing and pushing:
To push commits from a pull request to the apache repository:
```
cd <activemq6 repo>
cd <activemq repo>
# Download all the remote branches etc... including all the pull requests.
git fetch --all

18
activemq6-bootstrap/pom.xml → activemq-bootstrap/pom.xml
View File

@ -3,12 +3,12 @@
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.activemq6</groupId>
<artifactId>activemq6-pom</artifactId>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-pom</artifactId>
<version>6.0.0-SNAPSHOT</version>
</parent>
<artifactId>activemq6-bootstrap</artifactId>
<artifactId>activemq-bootstrap</artifactId>
<packaging>jar</packaging>
<name>ActiveMQ6 Bootstrap</name>
@ -18,18 +18,18 @@
<dependencies>
<dependency>
<groupId>org.apache.activemq6</groupId>
<artifactId>activemq6-server</artifactId>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-server</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>org.apache.activemq6</groupId>
<artifactId>activemq6-jms-server</artifactId>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-jms-server</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>org.apache.activemq6</groupId>
<artifactId>activemq6-dto</artifactId>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-dto</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>

0
activemq6-bootstrap/src/main/filtered-resources/org/apache/activemq6/cli/banner.txt → activemq-bootstrap/src/main/filtered-resources/org/apache/activemq/cli/banner.txt
View File

2
activemq6-bootstrap/src/main/java/org/apache/activemq6/cli/ConfigurationException.java → activemq-bootstrap/src/main/java/org/apache/activemq/cli/ConfigurationException.java
View File

@ -10,7 +10,7 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.cli;
package org.apache.activemq.cli;
public class ConfigurationException extends Exception
{

12
activemq6-bootstrap/src/main/java/org/apache/activemq6/cli/HornetQ.java → activemq-bootstrap/src/main/java/org/apache/activemq/cli/HornetQ.java
View File

@ -10,15 +10,15 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.cli;
package org.apache.activemq.cli;
import io.airlift.command.Cli;
import io.airlift.command.ParseArgumentsUnexpectedException;
import org.apache.activemq6.cli.commands.Action;
import org.apache.activemq6.cli.commands.ActionContext;
import org.apache.activemq6.cli.commands.HelpAction;
import org.apache.activemq6.cli.commands.Run;
import org.apache.activemq6.cli.commands.Stop;
import org.apache.activemq.cli.commands.Action;
import org.apache.activemq.cli.commands.ActionContext;
import org.apache.activemq.cli.commands.HelpAction;
import org.apache.activemq.cli.commands.Run;
import org.apache.activemq.cli.commands.Stop;
import java.io.InputStream;
import java.io.OutputStream;

2
activemq6-bootstrap/src/main/java/org/apache/activemq6/cli/commands/Action.java → activemq-bootstrap/src/main/java/org/apache/activemq/cli/commands/Action.java
View File

@ -10,7 +10,7 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.cli.commands;
package org.apache.activemq.cli.commands;
public interface Action
{

2
activemq6-bootstrap/src/main/java/org/apache/activemq6/cli/commands/ActionContext.java → activemq-bootstrap/src/main/java/org/apache/activemq/cli/commands/ActionContext.java
View File

@ -10,7 +10,7 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.cli.commands;
package org.apache.activemq.cli.commands;
import java.io.InputStream;
import java.io.PrintStream;

2
activemq6-bootstrap/src/main/java/org/apache/activemq6/cli/commands/HelpAction.java → activemq-bootstrap/src/main/java/org/apache/activemq/cli/commands/HelpAction.java
View File

@ -10,7 +10,7 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.cli.commands;
package org.apache.activemq.cli.commands;
import io.airlift.command.Help;

30
activemq6-bootstrap/src/main/java/org/apache/activemq6/cli/commands/Run.java → activemq-bootstrap/src/main/java/org/apache/activemq/cli/commands/Run.java
View File

@ -10,25 +10,25 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.cli.commands;
package org.apache.activemq.cli.commands;
import io.airlift.command.Arguments;
import io.airlift.command.Command;
import org.apache.activemq6.cli.HornetQ;
import org.apache.activemq6.core.config.Configuration;
import org.apache.activemq6.core.server.impl.HornetQServerImpl;
import org.apache.activemq6.dto.BrokerDTO;
import org.apache.activemq6.factory.BrokerFactory;
import org.apache.activemq6.factory.CoreFactory;
import org.apache.activemq6.factory.JmsFactory;
import org.apache.activemq6.factory.SecurityManagerFactory;
import org.apache.activemq6.integration.bootstrap.HornetQBootstrapLogger;
import org.apache.activemq6.jms.server.JMSServerManager;
import org.apache.activemq6.jms.server.config.JMSConfiguration;
import org.apache.activemq6.jms.server.impl.JMSServerManagerImpl;
import org.apache.activemq6.jms.server.impl.StandaloneNamingServer;
import org.apache.activemq6.spi.core.security.HornetQSecurityManager;
import org.apache.activemq.cli.HornetQ;
import org.apache.activemq.core.config.Configuration;
import org.apache.activemq.core.server.impl.HornetQServerImpl;
import org.apache.activemq.dto.BrokerDTO;
import org.apache.activemq.factory.BrokerFactory;
import org.apache.activemq.factory.CoreFactory;
import org.apache.activemq.factory.JmsFactory;
import org.apache.activemq.factory.SecurityManagerFactory;
import org.apache.activemq.integration.bootstrap.HornetQBootstrapLogger;
import org.apache.activemq.jms.server.JMSServerManager;
import org.apache.activemq.jms.server.config.JMSConfiguration;
import org.apache.activemq.jms.server.impl.JMSServerManagerImpl;
import org.apache.activemq.jms.server.impl.StandaloneNamingServer;
import org.apache.activemq.spi.core.security.HornetQSecurityManager;
import javax.management.MBeanServer;

6
activemq6-bootstrap/src/main/java/org/apache/activemq6/cli/commands/Stop.java → activemq-bootstrap/src/main/java/org/apache/activemq/cli/commands/Stop.java
View File

@ -10,12 +10,12 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.cli.commands;
package org.apache.activemq.cli.commands;
import io.airlift.command.Arguments;
import io.airlift.command.Command;
import org.apache.activemq6.dto.BrokerDTO;
import org.apache.activemq6.factory.BrokerFactory;
import org.apache.activemq.dto.BrokerDTO;
import org.apache.activemq.factory.BrokerFactory;
import java.io.File;

10
activemq6-bootstrap/src/main/java/org/apache/activemq6/factory/BrokerFactory.java → activemq-bootstrap/src/main/java/org/apache/activemq/factory/BrokerFactory.java
View File

@ -10,11 +10,11 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.factory;
package org.apache.activemq.factory;
import org.apache.activemq6.cli.ConfigurationException;
import org.apache.activemq6.dto.BrokerDTO;
import org.apache.activemq6.utils.FactoryFinder;
import org.apache.activemq.cli.ConfigurationException;
import org.apache.activemq.dto.BrokerDTO;
import org.apache.activemq.utils.FactoryFinder;
import java.io.IOException;
import java.net.URI;
@ -32,7 +32,7 @@ public class BrokerFactory
BrokerFactoryHandler factory = null;
try
{
FactoryFinder finder = new FactoryFinder("META-INF/services/org.apache.activemq6/broker/");
FactoryFinder finder = new FactoryFinder("META-INF/services/org.apache.activemq/broker/");
factory = (BrokerFactoryHandler)finder.newInstance(configURI.getScheme());
}
catch (IOException ioe )

4
activemq6-bootstrap/src/main/java/org/apache/activemq6/factory/BrokerFactoryHandler.java → activemq-bootstrap/src/main/java/org/apache/activemq/factory/BrokerFactoryHandler.java
View File

@ -10,9 +10,9 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.factory;
package org.apache.activemq.factory;
import org.apache.activemq6.dto.BrokerDTO;
import org.apache.activemq.dto.BrokerDTO;
import java.net.URI;

14
activemq6-bootstrap/src/main/java/org/apache/activemq6/factory/CoreFactory.java → activemq-bootstrap/src/main/java/org/apache/activemq/factory/CoreFactory.java
View File

@ -10,13 +10,13 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.factory;
package org.apache.activemq.factory;
import org.apache.activemq6.cli.ConfigurationException;
import org.apache.activemq6.core.config.Configuration;
import org.apache.activemq6.core.config.impl.ConfigurationImpl;
import org.apache.activemq6.dto.CoreDTO;
import org.apache.activemq6.utils.FactoryFinder;
import org.apache.activemq.cli.ConfigurationException;
import org.apache.activemq.core.config.Configuration;
import org.apache.activemq.core.config.impl.ConfigurationImpl;
import org.apache.activemq.dto.CoreDTO;
import org.apache.activemq.utils.FactoryFinder;
import java.io.IOException;
import java.net.URI;
@ -31,7 +31,7 @@ public class CoreFactory
URI configURI = new URI(core.configuration.replace("\\", "/"));
try
{
FactoryFinder finder = new FactoryFinder("META-INF/services/org.apache.activemq6/broker/core/");
FactoryFinder finder = new FactoryFinder("META-INF/services/org.apache.activemq/broker/core/");
factory = (CoreFactoryHandler)finder.newInstance(configURI.getScheme());
}
catch (IOException ioe )

4
activemq6-bootstrap/src/main/java/org/apache/activemq6/factory/CoreFactoryHandler.java → activemq-bootstrap/src/main/java/org/apache/activemq/factory/CoreFactoryHandler.java
View File

@ -10,9 +10,9 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.factory;
package org.apache.activemq.factory;
import org.apache.activemq6.core.config.Configuration;
import org.apache.activemq.core.config.Configuration;
import java.net.URI;

6
activemq6-bootstrap/src/main/java/org/apache/activemq6/factory/FileCoreFactoryHandler.java → activemq-bootstrap/src/main/java/org/apache/activemq/factory/FileCoreFactoryHandler.java
View File

@ -10,10 +10,10 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.factory;
package org.apache.activemq.factory;
import org.apache.activemq6.core.config.Configuration;
import org.apache.activemq6.core.config.impl.FileConfiguration;
import org.apache.activemq.core.config.Configuration;
import org.apache.activemq.core.config.impl.FileConfiguration;
import java.net.URI;

6
activemq6-bootstrap/src/main/java/org/apache/activemq6/factory/FileJmsFactoryHandler.java → activemq-bootstrap/src/main/java/org/apache/activemq/factory/FileJmsFactoryHandler.java
View File

@ -10,10 +10,10 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.factory;
package org.apache.activemq.factory;
import org.apache.activemq6.jms.server.config.JMSConfiguration;
import org.apache.activemq6.jms.server.impl.JMSServerConfigParserImpl;
import org.apache.activemq.jms.server.config.JMSConfiguration;
import org.apache.activemq.jms.server.impl.JMSServerConfigParserImpl;
import java.io.FileInputStream;
import java.io.InputStream;

12
activemq6-bootstrap/src/main/java/org/apache/activemq6/factory/JmsFactory.java → activemq-bootstrap/src/main/java/org/apache/activemq/factory/JmsFactory.java
View File

@ -10,15 +10,15 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.factory;
package org.apache.activemq.factory;
import java.io.IOException;
import java.net.URI;
import org.apache.activemq6.cli.ConfigurationException;
import org.apache.activemq6.dto.JmsDTO;
import org.apache.activemq6.jms.server.config.JMSConfiguration;
import org.apache.activemq6.utils.FactoryFinder;
import org.apache.activemq.cli.ConfigurationException;
import org.apache.activemq.dto.JmsDTO;
import org.apache.activemq.jms.server.config.JMSConfiguration;
import org.apache.activemq.utils.FactoryFinder;
public class JmsFactory
{
@ -30,7 +30,7 @@ public class JmsFactory
URI configURI = new URI(jms.configuration.replace("\\", "/"));
try
{
FactoryFinder finder = new FactoryFinder("META-INF/services/org.apache.activemq6/broker/jms/");
FactoryFinder finder = new FactoryFinder("META-INF/services/org.apache.activemq/broker/jms/");
factory = (JmsFactoryHandler)finder.newInstance(configURI.getScheme());
}
catch (IOException ioe )

4
activemq6-bootstrap/src/main/java/org/apache/activemq6/factory/JmsFactoryHandler.java → activemq-bootstrap/src/main/java/org/apache/activemq/factory/JmsFactoryHandler.java
View File

@ -10,9 +10,9 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.factory;
package org.apache.activemq.factory;
import org.apache.activemq6.jms.server.config.JMSConfiguration;
import org.apache.activemq.jms.server.config.JMSConfiguration;
import java.net.URI;

10
activemq6-bootstrap/src/main/java/org/apache/activemq6/factory/SecurityManagerFactory.java → activemq-bootstrap/src/main/java/org/apache/activemq/factory/SecurityManagerFactory.java
View File

@ -10,11 +10,11 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.factory;
package org.apache.activemq.factory;
import org.apache.activemq6.dto.SecurityDTO;
import org.apache.activemq6.spi.core.security.HornetQSecurityManager;
import org.apache.activemq6.utils.FactoryFinder;
import org.apache.activemq.dto.SecurityDTO;
import org.apache.activemq.spi.core.security.HornetQSecurityManager;
import org.apache.activemq.utils.FactoryFinder;
import javax.xml.bind.annotation.XmlRootElement;
@ -25,7 +25,7 @@ public class SecurityManagerFactory
{
if (config != null)
{
FactoryFinder finder = new FactoryFinder("META-INF/services/org.apache.activemq6/security/");
FactoryFinder finder = new FactoryFinder("META-INF/services/org.apache.activemq/security/");
HornetQSecurityManager manager = (HornetQSecurityManager)finder.newInstance(config.getClass().getAnnotation(XmlRootElement.class).name());
return manager;
}

8
activemq6-bootstrap/src/main/java/org/apache/activemq6/factory/XmlBrokerFactoryHandler.java → activemq-bootstrap/src/main/java/org/apache/activemq/factory/XmlBrokerFactoryHandler.java
View File

@ -10,11 +10,11 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.factory;
package org.apache.activemq.factory;
import org.apache.activemq6.cli.ConfigurationException;
import org.apache.activemq6.dto.BrokerDTO;
import org.apache.activemq6.dto.XmlUtil;
import org.apache.activemq.cli.ConfigurationException;
import org.apache.activemq.dto.BrokerDTO;
import org.apache.activemq.dto.XmlUtil;
import java.io.File;
import java.net.URI;

2
activemq6-bootstrap/src/main/java/org/apache/activemq6/integration/bootstrap/HornetQBootstrapBundle.java → activemq-bootstrap/src/main/java/org/apache/activemq/integration/bootstrap/HornetQBootstrapBundle.java
View File

@ -10,7 +10,7 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.integration.bootstrap;
package org.apache.activemq.integration.bootstrap;
import org.jboss.logging.annotations.MessageBundle;

2
activemq6-bootstrap/src/main/java/org/apache/activemq6/integration/bootstrap/HornetQBootstrapLogger.java → activemq-bootstrap/src/main/java/org/apache/activemq/integration/bootstrap/HornetQBootstrapLogger.java
View File

@ -11,7 +11,7 @@
* permissions and limitations under the License.
*/
package org.apache.activemq6.integration.bootstrap;
package org.apache.activemq.integration.bootstrap;
import org.jboss.logging.BasicLogger;
import org.jboss.logging.Logger;

2
activemq6-bootstrap/src/main/resources/META-INF/services/org/apache/activemq6/broker/jms/file → activemq-bootstrap/src/main/resources/META-INF/services/org/apache/activemq/broker/core/file
View File

@ -10,4 +10,4 @@
## implied. See the License for the specific language governing
## permissions and limitations under the License.
## ---------------------------------------------------------------------------
class=org.apache.activemq6.factory.FileJmsFactoryHandler
class=org.apache.activemq.factory.FileCoreFactoryHandler

2
activemq6-bootstrap/src/main/resources/META-INF/services/org/apache/activemq6/broker/core/file → activemq-bootstrap/src/main/resources/META-INF/services/org/apache/activemq/broker/jms/file
View File

@ -10,4 +10,4 @@
## implied. See the License for the specific language governing
## permissions and limitations under the License.
## ---------------------------------------------------------------------------
class=org.apache.activemq6.factory.FileCoreFactoryHandler
class=org.apache.activemq.factory.FileJmsFactoryHandler

2
activemq6-bootstrap/src/main/resources/META-INF/services/org/apache/activemq6/broker/xml → activemq-bootstrap/src/main/resources/META-INF/services/org/apache/activemq/broker/xml
View File

@ -10,4 +10,4 @@
## implied. See the License for the specific language governing
## permissions and limitations under the License.
## ---------------------------------------------------------------------------
class=org.apache.activemq6.factory.XmlBrokerFactoryHandler
class=org.apache.activemq.factory.XmlBrokerFactoryHandler

6
activemq6-commons/pom.xml → activemq-commons/pom.xml
View File

@ -3,12 +3,12 @@
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.activemq6</groupId>
<artifactId>activemq6-pom</artifactId>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-pom</artifactId>
<version>6.0.0-SNAPSHOT</version>
</parent>
<artifactId>activemq6-commons</artifactId>
<artifactId>activemq-commons</artifactId>
<packaging>jar</packaging>
<name>ActiveMQ6 Commons</name>

4
activemq6-commons/src/main/java/org/apache/activemq6/api/core/HornetQAddressExistsException.java → activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQAddressExistsException.java
View File

@ -11,9 +11,9 @@
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
import static org.apache.activemq6.api.core.HornetQExceptionType.ADDRESS_EXISTS;
import static org.apache.activemq.api.core.HornetQExceptionType.ADDRESS_EXISTS;
/**
* An operation failed because an address exists on the server.

4
activemq6-commons/src/main/java/org/apache/activemq6/api/core/HornetQAddressFullException.java → activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQAddressFullException.java
View File

@ -11,9 +11,9 @@
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
import static org.apache.activemq6.api.core.HornetQExceptionType.ADDRESS_FULL;
import static org.apache.activemq.api.core.HornetQExceptionType.ADDRESS_FULL;
/**
* An address is full.

4
activemq6-commons/src/main/java/org/apache/activemq6/api/core/HornetQAlreadyReplicatingException.java → activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQAlreadyReplicatingException.java
View File

@ -11,9 +11,9 @@
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
import static org.apache.activemq6.api.core.HornetQExceptionType.ALREADY_REPLICATING;
import static org.apache.activemq.api.core.HornetQExceptionType.ALREADY_REPLICATING;
/**
* The server is already paired with a replicating backup.

2
activemq6-commons/src/main/java/org/apache/activemq6/api/core/HornetQBuffer.java → activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQBuffer.java
View File

@ -11,7 +11,7 @@
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
import java.nio.ByteBuffer;

4
activemq6-commons/src/main/java/org/apache/activemq6/api/core/HornetQBuffers.java → activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQBuffers.java
View File

@ -11,12 +11,12 @@
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
import java.nio.ByteBuffer;
import io.netty.buffer.Unpooled;
import org.apache.activemq6.core.buffers.impl.ChannelBufferWrapper;
import org.apache.activemq.core.buffers.impl.ChannelBufferWrapper;
/**
* Factory class to create instances of {@link HornetQBuffer}.

2
activemq6-commons/src/main/java/org/apache/activemq6/api/core/HornetQClusterSecurityException.java → activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQClusterSecurityException.java
View File

@ -11,7 +11,7 @@
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
/**
* Security exception thrown when the cluster user fails authentication.

4
activemq6-commons/src/main/java/org/apache/activemq6/api/core/HornetQConnectionTimedOutException.java → activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQConnectionTimedOutException.java
View File

@ -11,9 +11,9 @@
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
import static org.apache.activemq6.api.core.HornetQExceptionType.CONNECTION_TIMEDOUT;
import static org.apache.activemq.api.core.HornetQExceptionType.CONNECTION_TIMEDOUT;
/**
* A client timed out will connecting to HornetQ server.

4
activemq6-commons/src/main/java/org/apache/activemq6/api/core/HornetQDisconnectedException.java → activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQDisconnectedException.java
View File

@ -11,9 +11,9 @@
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
import static org.apache.activemq6.api.core.HornetQExceptionType.DISCONNECTED;
import static org.apache.activemq.api.core.HornetQExceptionType.DISCONNECTED;
/**
* A client was disconnected from HornetQ server when the server has shut down.

4
activemq6-commons/src/main/java/org/apache/activemq6/api/core/HornetQDuplicateIdException.java → activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQDuplicateIdException.java
View File

@ -11,9 +11,9 @@
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
import static org.apache.activemq6.api.core.HornetQExceptionType.DUPLICATE_ID_REJECTED;
import static org.apache.activemq.api.core.HornetQExceptionType.DUPLICATE_ID_REJECTED;
/**
* A DuplicateID was rejected.

4
activemq6-commons/src/main/java/org/apache/activemq6/api/core/HornetQDuplicateMetaDataException.java → activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQDuplicateMetaDataException.java
View File

@ -11,9 +11,9 @@
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
import static org.apache.activemq6.api.core.HornetQExceptionType.DUPLICATE_METADATA;
import static org.apache.activemq.api.core.HornetQExceptionType.DUPLICATE_METADATA;
/**
* A Session Metadata was set in duplication

2
activemq6-commons/src/main/java/org/apache/activemq6/api/core/HornetQException.java → activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQException.java
View File

@ -10,7 +10,7 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
/**
* HornetQException is the root exception for the HornetQ API.

2
activemq6-commons/src/main/java/org/apache/activemq6/api/core/HornetQExceptionType.java → activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQExceptionType.java
View File

@ -10,7 +10,7 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
import java.util.Collections;
import java.util.EnumSet;

4
activemq6-commons/src/main/java/org/apache/activemq6/api/core/HornetQIOErrorException.java → activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQIOErrorException.java
View File

@ -11,9 +11,9 @@
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
import static org.apache.activemq6.api.core.HornetQExceptionType.IO_ERROR;
import static org.apache.activemq.api.core.HornetQExceptionType.IO_ERROR;
/**
* Unexpected I/O error occurred on the server.

4
activemq6-commons/src/main/java/org/apache/activemq6/api/core/HornetQIllegalStateException.java → activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQIllegalStateException.java
View File

@ -11,9 +11,9 @@
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
import static org.apache.activemq6.api.core.HornetQExceptionType.ILLEGAL_STATE;
import static org.apache.activemq.api.core.HornetQExceptionType.ILLEGAL_STATE;
/**
* A HornetQ resource is not in a legal state (e.g. calling ClientConsumer.receive() if a

4
activemq6-commons/src/main/java/org/apache/activemq6/api/core/HornetQIncompatibleClientServerException.java → activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQIncompatibleClientServerException.java
View File

@ -11,9 +11,9 @@
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
import static org.apache.activemq6.api.core.HornetQExceptionType.INCOMPATIBLE_CLIENT_SERVER_VERSIONS;
import static org.apache.activemq.api.core.HornetQExceptionType.INCOMPATIBLE_CLIENT_SERVER_VERSIONS;
/**
* The server version and the client version are incompatible.

6
activemq6-commons/src/main/java/org/apache/activemq6/api/core/HornetQInterceptorRejectedPacketException.java → activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQInterceptorRejectedPacketException.java
View File

@ -11,13 +11,13 @@
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
import static org.apache.activemq6.api.core.HornetQExceptionType.INTERCEPTOR_REJECTED_PACKET;
import static org.apache.activemq.api.core.HornetQExceptionType.INTERCEPTOR_REJECTED_PACKET;
/**
* An outgoing interceptor returned false.
* @see org.apache.activemq6.api.core.client.ServerLocator#addOutgoingInterceptor(org.apache.activemq6.api.core.Interceptor)
* @see org.apache.activemq.api.core.client.ServerLocator#addOutgoingInterceptor(org.apache.activemq.api.core.Interceptor)
* @author Justin Bertram
*/
// XXX I doubt any reader will make much sense of this Javadoc's text.

4
activemq6-commons/src/main/java/org/apache/activemq6/api/core/HornetQInternalErrorException.java → activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQInternalErrorException.java
View File

@ -11,9 +11,9 @@
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
import static org.apache.activemq6.api.core.HornetQExceptionType.INTERNAL_ERROR;
import static org.apache.activemq.api.core.HornetQExceptionType.INTERNAL_ERROR;
/**
* Internal error which prevented HornetQ from performing an important operation.

2
activemq6-commons/src/main/java/org/apache/activemq6/api/core/HornetQInterruptedException.java → activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQInterruptedException.java
View File

@ -10,7 +10,7 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
/**
* When an interruption happens, we will just throw a non-checked exception.

4
activemq6-commons/src/main/java/org/apache/activemq6/api/core/HornetQInvalidFilterExpressionException.java → activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQInvalidFilterExpressionException.java
View File

@ -11,9 +11,9 @@
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
import static org.apache.activemq6.api.core.HornetQExceptionType.INVALID_FILTER_EXPRESSION;
import static org.apache.activemq.api.core.HornetQExceptionType.INVALID_FILTER_EXPRESSION;
/**
* A filter expression was found to be invalid.

4
activemq6-commons/src/main/java/org/apache/activemq6/api/core/HornetQInvalidTransientQueueUseException.java → activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQInvalidTransientQueueUseException.java
View File

@ -11,9 +11,9 @@
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
import static org.apache.activemq6.api.core.HornetQExceptionType.INVALID_TRANSIENT_QUEUE_USE;
import static org.apache.activemq.api.core.HornetQExceptionType.INVALID_TRANSIENT_QUEUE_USE;
/**
* An operation failed because a queue exists on the server.

4
activemq6-commons/src/main/java/org/apache/activemq6/api/core/HornetQLargeMessageException.java → activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQLargeMessageException.java
View File

@ -11,9 +11,9 @@
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
import static org.apache.activemq6.api.core.HornetQExceptionType.LARGE_MESSAGE_ERROR_BODY;
import static org.apache.activemq.api.core.HornetQExceptionType.LARGE_MESSAGE_ERROR_BODY;
/**
* A problem occurred while manipulating the body of a large message.

4
activemq6-commons/src/main/java/org/apache/activemq6/api/core/HornetQLargeMessageInterruptedException.java → activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQLargeMessageInterruptedException.java
View File

@ -11,10 +11,10 @@
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
import static org.apache.activemq6.api.core.HornetQExceptionType.LARGE_MESSAGE_INTERRUPTED;
import static org.apache.activemq.api.core.HornetQExceptionType.LARGE_MESSAGE_INTERRUPTED;
/**
* @author Clebert

2
activemq6-commons/src/main/java/org/apache/activemq6/api/core/HornetQNativeIOError.java → activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQNativeIOError.java
View File

@ -11,7 +11,7 @@
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
/**

4
activemq6-commons/src/main/java/org/apache/activemq6/api/core/HornetQNonExistentQueueException.java → activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQNonExistentQueueException.java
View File

@ -11,9 +11,9 @@
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
import static org.apache.activemq6.api.core.HornetQExceptionType.QUEUE_DOES_NOT_EXIST;
import static org.apache.activemq.api.core.HornetQExceptionType.QUEUE_DOES_NOT_EXIST;
/**
* An operation failed because a queue does not exist on the server.

4
activemq6-commons/src/main/java/org/apache/activemq6/api/core/HornetQNotConnectedException.java → activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQNotConnectedException.java
View File

@ -11,9 +11,9 @@
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
import static org.apache.activemq6.api.core.HornetQExceptionType.NOT_CONNECTED;
import static org.apache.activemq.api.core.HornetQExceptionType.NOT_CONNECTED;
/**
* A client is not able to connect to HornetQ server.

4
activemq6-commons/src/main/java/org/apache/activemq6/api/core/HornetQObjectClosedException.java → activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQObjectClosedException.java
View File

@ -11,9 +11,9 @@
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
import static org.apache.activemq6.api.core.HornetQExceptionType.OBJECT_CLOSED;
import static org.apache.activemq.api.core.HornetQExceptionType.OBJECT_CLOSED;
/**
* A client operation failed because the calling resource (ClientSession, ClientProducer, etc.) is

6
activemq6-commons/src/main/java/org/apache/activemq6/api/core/HornetQPropertyConversionException.java → activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQPropertyConversionException.java
View File

@ -10,13 +10,13 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
/**
* A PropertyConversionException is thrown by {@code org.apache.activemq6.api.core.Message} methods when a
* A PropertyConversionException is thrown by {@code org.apache.activemq.api.core.Message} methods when a
* property can not be converted to the expected type.
* @author <a href="mailto:jmesnil@redhat.com">Jeff Mesnil</a>
* @see org.apache.activemq6.api.core.Message
* @see org.apache.activemq.api.core.Message
*/
public final class HornetQPropertyConversionException extends RuntimeException
{

4
activemq6-commons/src/main/java/org/apache/activemq6/api/core/HornetQQueueExistsException.java → activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQQueueExistsException.java
View File

@ -11,9 +11,9 @@
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
import static org.apache.activemq6.api.core.HornetQExceptionType.QUEUE_EXISTS;
import static org.apache.activemq.api.core.HornetQExceptionType.QUEUE_EXISTS;
/**
* An operation failed because a queue exists on the server.

4
activemq6-commons/src/main/java/org/apache/activemq6/api/core/HornetQSecurityException.java → activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQSecurityException.java
View File

@ -11,9 +11,9 @@
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
import static org.apache.activemq6.api.core.HornetQExceptionType.SECURITY_EXCEPTION;
import static org.apache.activemq.api.core.HornetQExceptionType.SECURITY_EXCEPTION;
/**
* A security problem occurred (authentication issues, permission issues,...)

4
activemq6-commons/src/main/java/org/apache/activemq6/api/core/HornetQSessionCreationException.java → activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQSessionCreationException.java
View File

@ -11,9 +11,9 @@
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
import static org.apache.activemq6.api.core.HornetQExceptionType.SESSION_CREATION_REJECTED;
import static org.apache.activemq.api.core.HornetQExceptionType.SESSION_CREATION_REJECTED;
/**
* The creation of a session was rejected by the server (e.g. if the server is starting and has not

4
activemq6-commons/src/main/java/org/apache/activemq6/api/core/HornetQTransactionOutcomeUnknownException.java → activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQTransactionOutcomeUnknownException.java
View File

@ -11,9 +11,9 @@
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
import static org.apache.activemq6.api.core.HornetQExceptionType.TRANSACTION_OUTCOME_UNKNOWN;
import static org.apache.activemq.api.core.HornetQExceptionType.TRANSACTION_OUTCOME_UNKNOWN;
/**
* The outcome of a transaction is unknown.

4
activemq6-commons/src/main/java/org/apache/activemq6/api/core/HornetQTransactionRolledBackException.java → activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQTransactionRolledBackException.java
View File

@ -11,9 +11,9 @@
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
import static org.apache.activemq6.api.core.HornetQExceptionType.TRANSACTION_ROLLED_BACK;
import static org.apache.activemq.api.core.HornetQExceptionType.TRANSACTION_ROLLED_BACK;
/**
* A transaction was rolled back.

4
activemq6-commons/src/main/java/org/apache/activemq6/api/core/HornetQUnBlockedException.java → activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQUnBlockedException.java
View File

@ -11,9 +11,9 @@
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
import static org.apache.activemq6.api.core.HornetQExceptionType.UNBLOCKED;
import static org.apache.activemq.api.core.HornetQExceptionType.UNBLOCKED;
/**
* A blocking call from a client was unblocked during failover.

4
activemq6-commons/src/main/java/org/apache/activemq6/api/core/HornetQUnsupportedPacketException.java → activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQUnsupportedPacketException.java
View File

@ -11,9 +11,9 @@
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
import static org.apache.activemq6.api.core.HornetQExceptionType.UNSUPPORTED_PACKET;
import static org.apache.activemq.api.core.HornetQExceptionType.UNSUPPORTED_PACKET;
/**
* A packet of unsupported type was received by HornetQ PacketHandler.

2
activemq6-commons/src/main/java/org/apache/activemq6/api/core/Pair.java → activemq-commons/src/main/java/org/apache/activemq/api/core/Pair.java
View File

@ -11,7 +11,7 @@
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
import java.io.Serializable;

4
activemq6-commons/src/main/java/org/apache/activemq6/api/core/SimpleString.java → activemq-commons/src/main/java/org/apache/activemq/api/core/SimpleString.java
View File

@ -11,13 +11,13 @@
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
import java.io.Serializable;
import java.util.ArrayList;
import java.util.List;
import org.apache.activemq6.utils.DataConstants;
import org.apache.activemq.utils.DataConstants;
/**
* A simple String class that can store all characters, and stores as simple {@code byte[]}, this

10
activemq6-commons/src/main/java/org/apache/activemq6/core/buffers/impl/ChannelBufferWrapper.java → activemq-commons/src/main/java/org/apache/activemq/core/buffers/impl/ChannelBufferWrapper.java
View File

@ -11,16 +11,16 @@
* permissions and limitations under the License.
*/
package org.apache.activemq6.core.buffers.impl;
package org.apache.activemq.core.buffers.impl;
import java.nio.ByteBuffer;
import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import org.apache.activemq6.api.core.HornetQBuffer;
import org.apache.activemq6.api.core.SimpleString;
import org.apache.activemq6.utils.DataConstants;
import org.apache.activemq6.utils.UTF8Util;
import org.apache.activemq.api.core.HornetQBuffer;
import org.apache.activemq.api.core.SimpleString;
import org.apache.activemq.utils.DataConstants;
import org.apache.activemq.utils.UTF8Util;
/**
* A ChannelBufferWrapper

62
activemq6-commons/src/main/java/org/apache/activemq6/core/server/HornetQComponent.java → activemq-commons/src/main/java/org/apache/activemq/core/server/HornetQComponent.java
View File

@ -1,31 +1,31 @@
/*
* Copyright 2005-2014 Red Hat, Inc.
* Red Hat 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.activemq6.core.server;
/**
* A HornetQComponent
*
* @author <a href="mailto:tim.fox@jboss.com">Tim Fox</a>
* @version <tt>$Revision: 2796 $</tt>
*
*
*/
public interface HornetQComponent
{
void start() throws Exception;
void stop() throws Exception;
boolean isStarted();
}
/*
* Copyright 2005-2014 Red Hat, Inc.
* Red Hat 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.core.server;
/**
* A HornetQComponent
*
* @author <a href="mailto:tim.fox@jboss.com">Tim Fox</a>
* @version <tt>$Revision: 2796 $</tt>
*
*
*/
public interface HornetQComponent
{
void start() throws Exception;
void stop() throws Exception;
boolean isStarted();
}

2
activemq6-commons/src/main/java/org/apache/activemq6/utils/Base64.java → activemq-commons/src/main/java/org/apache/activemq/utils/Base64.java
View File

@ -10,7 +10,7 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.utils;
package org.apache.activemq.utils;
import java.nio.charset.Charset;
import java.nio.charset.StandardCharsets;

2
activemq6-commons/src/main/java/org/apache/activemq6/utils/ByteUtil.java → activemq-commons/src/main/java/org/apache/activemq/utils/ByteUtil.java
View File

@ -11,7 +11,7 @@
* permissions and limitations under the License.
*/
package org.apache.activemq6.utils;
package org.apache.activemq.utils;
import io.netty.buffer.ByteBuf;
import io.netty.buffer.UnpooledByteBufAllocator;

2
activemq6-commons/src/main/java/org/apache/activemq6/utils/ClassloadingUtil.java → activemq-commons/src/main/java/org/apache/activemq/utils/ClassloadingUtil.java
View File

@ -10,7 +10,7 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.utils;
package org.apache.activemq.utils;
import java.net.URL;

2
activemq6-commons/src/main/java/org/apache/activemq6/utils/ConcurrentHashSet.java → activemq-commons/src/main/java/org/apache/activemq/utils/ConcurrentHashSet.java
View File

@ -10,7 +10,7 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.utils;
package org.apache.activemq.utils;
import java.util.AbstractSet;
import java.util.Iterator;

2
activemq6-commons/src/main/java/org/apache/activemq6/utils/ConcurrentSet.java → activemq-commons/src/main/java/org/apache/activemq/utils/ConcurrentSet.java
View File

@ -10,7 +10,7 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.utils;
package org.apache.activemq.utils;
import java.util.Set;

2
activemq6-commons/src/main/java/org/apache/activemq6/utils/DataConstants.java → activemq-commons/src/main/java/org/apache/activemq/utils/DataConstants.java
View File

@ -10,7 +10,7 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.utils;
package org.apache.activemq.utils;
/**
*

2
activemq6-commons/src/main/java/org/apache/activemq6/utils/DefaultSensitiveStringCodec.java → activemq-commons/src/main/java/org/apache/activemq/utils/DefaultSensitiveStringCodec.java
View File

@ -10,7 +10,7 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.utils;
package org.apache.activemq.utils;
import java.math.BigInteger;
import java.security.InvalidKeyException;

4
activemq6-commons/src/main/java/org/apache/activemq6/utils/FactoryFinder.java → activemq-commons/src/main/java/org/apache/activemq/utils/FactoryFinder.java
View File

@ -10,7 +10,7 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.utils;
package org.apache.activemq.utils;
import java.io.BufferedInputStream;
import java.io.IOException;
@ -23,7 +23,7 @@ public class FactoryFinder
/**
* The strategy that the FactoryFinder uses to find load and instantiate Objects
* can be changed out by calling the
* {@link org.apache.activemq6.utils.FactoryFinder#setObjectFactory(org.apache.activemq6.utils.FactoryFinder.ObjectFactory)}
* {@link org.apache.activemq.utils.FactoryFinder#setObjectFactory(org.apache.activemq.utils.FactoryFinder.ObjectFactory)}
* method with a custom implementation of ObjectFactory.
* <p/>
* The default ObjectFactory is typically changed out when running in a specialized container

2
activemq6-commons/src/main/java/org/apache/activemq6/utils/HornetQThreadFactory.java → activemq-commons/src/main/java/org/apache/activemq/utils/HornetQThreadFactory.java
View File

@ -10,7 +10,7 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.utils;
package org.apache.activemq.utils;
import java.security.AccessController;
import java.security.PrivilegedAction;

4
activemq6-commons/src/main/java/org/apache/activemq6/utils/HornetQUtilBundle.java → activemq-commons/src/main/java/org/apache/activemq/utils/HornetQUtilBundle.java
View File

@ -10,10 +10,10 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.utils;
package org.apache.activemq.utils;
import org.apache.activemq6.api.core.HornetQIllegalStateException;
import org.apache.activemq.api.core.HornetQIllegalStateException;
import org.jboss.logging.annotations.Cause;
import org.jboss.logging.annotations.Message;
import org.jboss.logging.annotations.MessageBundle;

2
activemq6-commons/src/main/java/org/apache/activemq6/utils/HornetQUtilLogger.java → activemq-commons/src/main/java/org/apache/activemq/utils/HornetQUtilLogger.java
View File

@ -10,7 +10,7 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.utils;
package org.apache.activemq.utils;
import org.jboss.logging.BasicLogger;
import org.jboss.logging.Logger;

6
activemq6-commons/src/main/java/org/apache/activemq6/utils/PasswordMaskingUtil.java → activemq-commons/src/main/java/org/apache/activemq/utils/PasswordMaskingUtil.java
View File

@ -10,15 +10,15 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.utils;
package org.apache.activemq.utils;
import java.security.AccessController;
import java.security.PrivilegedAction;
import java.util.HashMap;
import java.util.Map;
import org.apache.activemq6.api.core.HornetQException;
import org.apache.activemq6.api.core.HornetQExceptionType;
import org.apache.activemq.api.core.HornetQException;
import org.apache.activemq.api.core.HornetQExceptionType;
/**
* A PasswordMarkingUtil

2
activemq6-commons/src/main/java/org/apache/activemq6/utils/ReferenceCounter.java → activemq-commons/src/main/java/org/apache/activemq/utils/ReferenceCounter.java
View File

@ -10,7 +10,7 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.utils;
package org.apache.activemq.utils;
/**
* @author Clebert Suconic

2
activemq6-commons/src/main/java/org/apache/activemq6/utils/ReferenceCounterUtil.java → activemq-commons/src/main/java/org/apache/activemq/utils/ReferenceCounterUtil.java
View File

@ -10,7 +10,7 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.utils;
package org.apache.activemq.utils;
import java.util.concurrent.Executor;
import java.util.concurrent.atomic.AtomicInteger;

2
activemq6-commons/src/main/java/org/apache/activemq6/utils/ReusableLatch.java → activemq-commons/src/main/java/org/apache/activemq/utils/ReusableLatch.java
View File

@ -10,7 +10,7 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.utils;
package org.apache.activemq.utils;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.AbstractQueuedSynchronizer;

2
activemq6-commons/src/main/java/org/apache/activemq6/utils/SensitiveDataCodec.java → activemq-commons/src/main/java/org/apache/activemq/utils/SensitiveDataCodec.java
View File

@ -10,7 +10,7 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.utils;
package org.apache.activemq.utils;
import java.util.Map;

30
activemq6-commons/src/main/java/org/apache/activemq6/utils/TypedProperties.java → activemq-commons/src/main/java/org/apache/activemq/utils/TypedProperties.java
View File

@ -10,7 +10,7 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.utils;
package org.apache.activemq.utils;
import java.nio.ByteBuffer;
import java.util.Collections;
@ -20,21 +20,21 @@ import java.util.Map;
import java.util.Map.Entry;
import java.util.Set;
import org.apache.activemq6.api.core.HornetQBuffer;
import org.apache.activemq6.api.core.HornetQPropertyConversionException;
import org.apache.activemq6.api.core.SimpleString;
import org.apache.activemq.api.core.HornetQBuffer;
import org.apache.activemq.api.core.HornetQPropertyConversionException;
import org.apache.activemq.api.core.SimpleString;
import static org.apache.activemq6.utils.DataConstants.BOOLEAN;
import static org.apache.activemq6.utils.DataConstants.BYTE;
import static org.apache.activemq6.utils.DataConstants.BYTES;
import static org.apache.activemq6.utils.DataConstants.CHAR;
import static org.apache.activemq6.utils.DataConstants.DOUBLE;
import static org.apache.activemq6.utils.DataConstants.FLOAT;
import static org.apache.activemq6.utils.DataConstants.INT;
import static org.apache.activemq6.utils.DataConstants.LONG;
import static org.apache.activemq6.utils.DataConstants.NULL;
import static org.apache.activemq6.utils.DataConstants.SHORT;
import static org.apache.activemq6.utils.DataConstants.STRING;
import static org.apache.activemq.utils.DataConstants.BOOLEAN;
import static org.apache.activemq.utils.DataConstants.BYTE;
import static org.apache.activemq.utils.DataConstants.BYTES;
import static org.apache.activemq.utils.DataConstants.CHAR;
import static org.apache.activemq.utils.DataConstants.DOUBLE;
import static org.apache.activemq.utils.DataConstants.FLOAT;
import static org.apache.activemq.utils.DataConstants.INT;
import static org.apache.activemq.utils.DataConstants.LONG;
import static org.apache.activemq.utils.DataConstants.NULL;
import static org.apache.activemq.utils.DataConstants.SHORT;
import static org.apache.activemq.utils.DataConstants.STRING;
/**
* Property Value Conversion.

4
activemq6-commons/src/main/java/org/apache/activemq6/utils/UTF8Util.java → activemq-commons/src/main/java/org/apache/activemq/utils/UTF8Util.java
View File

@ -10,11 +10,11 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.utils;
package org.apache.activemq.utils;
import java.lang.ref.SoftReference;
import org.apache.activemq6.api.core.HornetQBuffer;
import org.apache.activemq.api.core.HornetQBuffer;
/**
*

2
activemq6-commons/src/main/java/org/apache/activemq6/utils/UUID.java → activemq-commons/src/main/java/org/apache/activemq/utils/UUID.java
View File

@ -13,7 +13,7 @@
* limitations under the License.
*/
package org.apache.activemq6.utils;
package org.apache.activemq.utils;
/**

4
activemq6-commons/src/main/java/org/apache/activemq6/utils/UUIDGenerator.java → activemq-commons/src/main/java/org/apache/activemq/utils/UUIDGenerator.java
View File

@ -13,7 +13,7 @@
* limitations under the License.
*/
package org.apache.activemq6.utils;
package org.apache.activemq.utils;
import java.lang.reflect.Method;
import java.net.NetworkInterface;
@ -31,7 +31,7 @@ import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import org.apache.activemq6.api.core.SimpleString;
import org.apache.activemq.api.core.SimpleString;
public final class UUIDGenerator
{

2
activemq6-commons/src/main/java/org/apache/activemq6/utils/UUIDTimer.java → activemq-commons/src/main/java/org/apache/activemq/utils/UUIDTimer.java
View File

@ -13,7 +13,7 @@
* limitations under the License.
*/
package org.apache.activemq6.utils;
package org.apache.activemq.utils;
import java.util.Random;

2
activemq6-commons/src/test/java/org/apache/activemq6/utils/ByteUtilTest.java → activemq-commons/src/test/java/org/apache/activemq/utils/ByteUtilTest.java
View File

@ -11,7 +11,7 @@
* permissions and limitations under the License.
*/
package org.apache.activemq6.utils;
package org.apache.activemq.utils;
import org.junit.Assert;
import org.junit.Test;

4
activemq6-commons/src/test/java/org/apache/activemq6/utils/PairTest.java → activemq-commons/src/test/java/org/apache/activemq/utils/PairTest.java
View File

@ -10,12 +10,12 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.utils;
package org.apache.activemq.utils;
import org.junit.Test;
import org.junit.Assert;
import org.apache.activemq6.api.core.Pair;
import org.apache.activemq.api.core.Pair;
public class PairTest extends Assert

2
activemq6-commons/src/test/java/org/apache/activemq6/utils/ReferenceCounterTest.java → activemq-commons/src/test/java/org/apache/activemq/utils/ReferenceCounterTest.java
View File

@ -10,7 +10,7 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.utils;
package org.apache.activemq.utils;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.Executor;

26
activemq6-core-client/pom.xml → activemq-core-client/pom.xml
View File

@ -3,12 +3,12 @@
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.activemq6</groupId>
<artifactId>activemq6-pom</artifactId>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-pom</artifactId>
<version>6.0.0-SNAPSHOT</version>
</parent>
<artifactId>activemq6-core-client</artifactId>
<artifactId>activemq-core-client</artifactId>
<packaging>jar</packaging>
<name>ActiveMQ6 Core Client</name>
@ -26,18 +26,18 @@
<artifactId>jgroups</artifactId>
</dependency>
<dependency>
<groupId>org.apache.activemq6</groupId>
<artifactId>activemq6-commons</artifactId>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-commons</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>org.apache.activemq6</groupId>
<artifactId>activemq6-selector</artifactId>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-selector</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>org.apache.activemq6</groupId>
<artifactId>activemq6-journal</artifactId>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-journal</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
@ -73,7 +73,7 @@
<maxmemory>512m</maxmemory>
<quiet>false</quiet>
<aggregate>true</aggregate>
<excludePackageNames>org.apache.activemq6.core:org.apache.activemq6.utils</excludePackageNames>
<excludePackageNames>org.apache.activemq.core:org.apache.activemq.utils</excludePackageNames>
</configuration>
<executions>
<execution>
@ -103,7 +103,7 @@
<executions>
<!-- Adds a directory to the list of source folders to be used in this project. This is
here to let Maven know about:
target/generated-sources/xslt/org.apache.activemq6/api/config/HornetQDefaultConfiguration.java
target/generated-sources/xslt/org.apache.activemq/api/config/HornetQDefaultConfiguration.java
which is generated by ./src/main/resources/hqDefaults.xsl using the HornetQ
configuration schema. -->
<execution>
@ -136,7 +136,7 @@
<transformationSet>
<!-- Generates target/generated-sources/xslt/.../HornetQDefaultConfiguration.java
using this XSLT `./src/main/resources/hqDefaults.xsl`. -->
<dir>../activemq6-server/src/main/resources/schema</dir>
<dir>../activemq-server/src/main/resources/schema</dir>
<outputDir>${project.build.directory}/generated-sources/xslt</outputDir>
<stylesheet>./src/main/resources/hqDefaults.xsl</stylesheet>
<includes>
@ -144,7 +144,7 @@
</includes>
<fileMappers>
<fileMapper implementation="org.codehaus.plexus.components.io.filemappers.MergeFileMapper">
<targetName>./org/apache/activemq6/api/config/HornetQDefaultConfiguration.java</targetName>
<targetName>./org/apache/activemq/api/config/HornetQDefaultConfiguration.java</targetName>
</fileMapper>
</fileMappers>
</transformationSet>

2
activemq6-core-client/src/main/java/org/apache/activemq6/api/core/BroadcastEndpoint.java → activemq-core-client/src/main/java/org/apache/activemq/api/core/BroadcastEndpoint.java
View File

@ -10,7 +10,7 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
import java.util.concurrent.TimeUnit;

2
activemq6-core-client/src/main/java/org/apache/activemq6/api/core/BroadcastEndpointFactory.java → activemq-core-client/src/main/java/org/apache/activemq/api/core/BroadcastEndpointFactory.java
View File

@ -10,7 +10,7 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
import java.io.Serializable;

2
activemq6-core-client/src/main/java/org/apache/activemq6/api/core/BroadcastEndpointFactoryConfiguration.java → activemq-core-client/src/main/java/org/apache/activemq/api/core/BroadcastEndpointFactoryConfiguration.java
View File

@ -11,7 +11,7 @@
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
import java.io.Serializable;

6
activemq6-core-client/src/main/java/org/apache/activemq6/api/core/BroadcastGroupConfiguration.java → activemq-core-client/src/main/java/org/apache/activemq/api/core/BroadcastGroupConfiguration.java
View File

@ -10,17 +10,17 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
import java.io.Serializable;
import java.util.List;
import org.apache.activemq6.api.config.HornetQDefaultConfiguration;
import org.apache.activemq.api.config.HornetQDefaultConfiguration;
/**
* The basic configuration used to determine how the server will broadcast members
* This is analogous to {@link org.apache.activemq6.api.core.DiscoveryGroupConfiguration}
* This is analogous to {@link org.apache.activemq.api.core.DiscoveryGroupConfiguration}
*
* @author <a href="mailto:tim.fox@jboss.com">Tim Fox</a>
* @author <a href="mailto:hgao@redhat.com">Howard Gao</a>

6
activemq6-core-client/src/main/java/org/apache/activemq6/api/core/DiscoveryGroupConfiguration.java → activemq-core-client/src/main/java/org/apache/activemq/api/core/DiscoveryGroupConfiguration.java
View File

@ -10,15 +10,15 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.io.Serializable;
import org.apache.activemq6.api.core.client.HornetQClient;
import org.apache.activemq6.utils.UUIDGenerator;
import org.apache.activemq.api.core.client.HornetQClient;
import org.apache.activemq.utils.UUIDGenerator;
/**
* This file represents how we are using Discovery.

4
activemq6-core-client/src/main/java/org/apache/activemq6/api/core/DiscoveryGroupConfigurationCompatibilityHelper.java → activemq-core-client/src/main/java/org/apache/activemq/api/core/DiscoveryGroupConfigurationCompatibilityHelper.java
View File

@ -11,12 +11,12 @@
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
/**
* This interface is needed for making a DiscoveryGroupConfiguration backward
* compatible with version 2.2 clients. It is used to extract from new
* {@link org.apache.activemq6.api.core.BroadcastEndpointFactoryConfiguration} the four
* {@link org.apache.activemq.api.core.BroadcastEndpointFactoryConfiguration} the four
* UDP attributes in order to form a version 2.2 DiscoveryGroupConfiguration
* in time of serialization.
*

2
activemq6-core-client/src/main/java/org/apache/activemq6/api/core/FilterConstants.java → activemq-core-client/src/main/java/org/apache/activemq/api/core/FilterConstants.java
View File

@ -10,7 +10,7 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
/**
* Constants representing pre-defined message attributes that can be referenced in HornetQ core

8
activemq6-core-client/src/main/java/org/apache/activemq6/api/core/Interceptor.java → activemq-core-client/src/main/java/org/apache/activemq/api/core/Interceptor.java
View File

@ -10,17 +10,17 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
import org.apache.activemq6.core.protocol.core.Packet;
import org.apache.activemq6.spi.core.protocol.RemotingConnection;
import org.apache.activemq.core.protocol.core.Packet;
import org.apache.activemq.spi.core.protocol.RemotingConnection;
/**
* This is class is a simple way to intercepting calls on HornetQ client and servers.
* <p>
* To add an interceptor to HornetQ server, you have to modify the server configuration file
* {@literal hornetq-configuration.xml}.<br>
* To add it to a client, use {@link org.apache.activemq6.api.core.client.ServerLocator#addIncomingInterceptor(Interceptor)}
* To add it to a client, use {@link org.apache.activemq.api.core.client.ServerLocator#addIncomingInterceptor(Interceptor)}
*
* @author clebert.suconic@jboss.com
* @author <a href="mailto:tim.fox@jboss.com">Tim Fox</a>

2
activemq6-core-client/src/main/java/org/apache/activemq6/api/core/JGroupsBroadcastGroupConfiguration.java → activemq-core-client/src/main/java/org/apache/activemq/api/core/JGroupsBroadcastGroupConfiguration.java
View File

@ -10,7 +10,7 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
import java.net.URL;
import java.util.ArrayList;

4
activemq6-core-client/src/main/java/org/apache/activemq6/api/core/Message.java → activemq-core-client/src/main/java/org/apache/activemq/api/core/Message.java
View File

@ -10,12 +10,12 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
import java.util.Map;
import java.util.Set;
import org.apache.activemq6.utils.UUID;
import org.apache.activemq.utils.UUID;
/**

16
activemq6-core-client/src/main/java/org/apache/activemq6/api/core/TransportConfiguration.java → activemq-core-client/src/main/java/org/apache/activemq/api/core/TransportConfiguration.java
View File

@ -10,16 +10,16 @@
* implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package org.apache.activemq6.api.core;
package org.apache.activemq.api.core;
import java.io.Serializable;
import java.util.HashMap;
import java.util.Map;
import org.apache.activemq6.core.client.HornetQClientMessageBundle;
import org.apache.activemq6.core.remoting.impl.TransportConfigurationUtil;
import org.apache.activemq6.core.remoting.impl.netty.TransportConstants;
import org.apache.activemq6.utils.UUIDGenerator;
import org.apache.activemq.core.client.HornetQClientMessageBundle;
import org.apache.activemq.core.remoting.impl.TransportConfigurationUtil;
import org.apache.activemq.core.remoting.impl.netty.TransportConstants;
import org.apache.activemq.utils.UUIDGenerator;
/**
* A TransportConfiguration is used by a client to specify connections to a server and its backup if
@ -86,7 +86,7 @@ public class TransportConfiguration implements Serializable
}
/**
* Creates a TransportConfiguration with a specific name providing the class name of the {@link org.apache.activemq6.spi.core.remoting.ConnectorFactory}
* Creates a TransportConfiguration with a specific name providing the class name of the {@link org.apache.activemq.spi.core.remoting.ConnectorFactory}
* and any parameters needed.
*
* @param className The class name of the ConnectorFactory
@ -110,7 +110,7 @@ public class TransportConfiguration implements Serializable
}
/**
* Creates a TransportConfiguration providing the class name of the {@link org.apache.activemq6.spi.core.remoting.ConnectorFactory}
* Creates a TransportConfiguration providing the class name of the {@link org.apache.activemq.spi.core.remoting.ConnectorFactory}
* and any parameters needed.
*
* @param className The class name of the ConnectorFactory
@ -122,7 +122,7 @@ public class TransportConfiguration implements Serializable
}
/**
* Creates a TransportConfiguration providing the class name of the {@link org.apache.activemq6.spi.core.remoting.ConnectorFactory}
* Creates a TransportConfiguration providing the class name of the {@link org.apache.activemq.spi.core.remoting.ConnectorFactory}
*
* @param className The class name of the ConnectorFactory
*/

Some files were not shown because too many files have changed in this diff Show More