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

ACTIVEMQ6-10 Remove JBoss 4 integration

This commit is contained in:
jbertram 2014-11-17 15:40:07 -06:00
parent 886180293f
commit 079e4b2438
12 changed files with 0 additions and 494 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

49
activemq-service-sar/pom.xml
View File

@ -1,49 +0,0 @@
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-pom</artifactId>
<version>6.0.0-SNAPSHOT</version>
</parent>
<artifactId>activemq-service-sar</artifactId>
<packaging>jar</packaging>
<name>ActiveMQ6 JBoss AS4 Integration</name>
<properties>
<hornetq.basedir>${project.basedir}/..</hornetq.basedir>
</properties>
<dependencies>
<dependency>
<groupId>org.jboss.logging</groupId>
<artifactId>jboss-logging-processor</artifactId>
</dependency>
<!--
JBoss Logging
-->
<dependency>
<groupId>org.jboss.logging</groupId>
<artifactId>jboss-logging</artifactId>
</dependency>
<dependency>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-server</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-jms-server</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-jboss-as-integration</artifactId>
<version>${project.version}</version>
</dependency>
</dependencies>
</project>

50
activemq-service-sar/src/main/java/org/apache/activemq/service/HornetQFileConfigurationService.java
View File

@ -1,50 +0,0 @@
/*
* 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.service;
import org.apache.activemq.core.config.Configuration;
import org.apache.activemq.core.config.impl.FileConfiguration;
/**
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a>
* Created Oct 21, 2009
*/
public class HornetQFileConfigurationService implements HornetQFileConfigurationServiceMBean
{
private FileConfiguration configuration;
public void create() throws Exception
{
configuration = new FileConfiguration();
}
public void start() throws Exception
{
configuration.start();
}
public void stop() throws Exception
{
configuration.stop();
}
public void setConfigurationUrl(final String configurationUrl)
{
configuration.setConfigurationUrl(configurationUrl);
}
public Configuration getConfiguration()
{
return configuration;
}
}

32
activemq-service-sar/src/main/java/org/apache/activemq/service/HornetQFileConfigurationServiceMBean.java
View File

@ -1,32 +0,0 @@
/*
* 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.service;
import org.apache.activemq.core.config.Configuration;
/**
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a>
* Created Oct 21, 2009
*/
public interface HornetQFileConfigurationServiceMBean
{
void create() throws Exception;
void start() throws Exception;
void stop() throws Exception;
void setConfigurationUrl(String configurationUrl);
Configuration getConfiguration();
}

46
activemq-service-sar/src/main/java/org/apache/activemq/service/HornetQJMSStarterService.java
View File

@ -1,46 +0,0 @@
/*
* 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.service;
import org.apache.activemq.jms.server.impl.JMSServerManagerImpl;
/**
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a>
* Created Oct 19, 2009
*/
public class HornetQJMSStarterService implements HornetQJMSStarterServiceMBean
{
HornetQStarterServiceMBean service;
private JMSServerManagerImpl jmsServerManager;
public void create() throws Exception
{
jmsServerManager = new JMSServerManagerImpl(service.getServer());
}
public void start() throws Exception
{
jmsServerManager.start();
}
public void stop() throws Exception
{
jmsServerManager.stop();
}
public void setHornetQServer(final HornetQStarterServiceMBean service)
{
this.service = service;
}
}

27
activemq-service-sar/src/main/java/org/apache/activemq/service/HornetQJMSStarterServiceMBean.java
View File

@ -1,27 +0,0 @@
/*
* 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.service;
/**
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a>
*/
public interface HornetQJMSStarterServiceMBean
{
void create() throws Exception;
void start() throws Exception;
void stop() throws Exception;
void setHornetQServer(HornetQStarterServiceMBean server);
}

31
activemq-service-sar/src/main/java/org/apache/activemq/service/HornetQServiceBundle.java
View File

@ -1,31 +0,0 @@
/*
* 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.service;
import org.jboss.logging.annotations.MessageBundle;
/**
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a>
* 3/12/12
*
* Logger Code 16
*
* each message id must be 6 digits long starting with 16, the 3rd digit should be 9
*
* so 169000 to 169999
*/
@MessageBundle(projectCode = "HQ")
public class HornetQServiceBundle
{
}

38
activemq-service-sar/src/main/java/org/apache/activemq/service/HornetQServiceLogger.java
View File

@ -1,38 +0,0 @@
/*
* 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.service;
import org.jboss.logging.annotations.MessageLogger;
/**
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a>
* 3/15/12
*
* Logger Code 16
*
* each message id must be 6 digits long starting with 16, the 3rd digit donates the level so
*
* INF0 1
* WARN 2
* DEBUG 3
* ERROR 4
* TRACE 5
* FATAL 6
*
* so an INFO message would be 161000 to 161999
*/
@MessageLogger(projectCode = "HQ")
public class HornetQServiceLogger
{
}

118
activemq-service-sar/src/main/java/org/apache/activemq/service/HornetQStarterService.java
View File

@ -1,118 +0,0 @@
/*
* 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.service;
import javax.management.MBeanRegistration;
import javax.management.MBeanServer;
import javax.management.ObjectName;
import org.apache.activemq.core.config.Configuration;
import org.apache.activemq.core.config.impl.ConfigurationImpl;
import org.apache.activemq.core.server.HornetQServer;
import org.apache.activemq.core.server.impl.HornetQServerImpl;
import org.apache.activemq.spi.core.security.HornetQSecurityManager;
/**
* @author <a href="mailto:lucazamador@gmail.com">Lucaz Amador</a>
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a>
*/
public class HornetQStarterService implements HornetQStarterServiceMBean, MBeanRegistration
{
JBossASSecurityManagerServiceMBean securityManagerService;
HornetQFileConfigurationServiceMBean configurationService;
private MBeanServer mBeanServer;
private HornetQServer server;
private boolean start = true;
public void create() throws Exception
{
Configuration config;
HornetQSecurityManager hornetQSecurityManager = null;
if (securityManagerService != null)
{
hornetQSecurityManager = securityManagerService.getJBossASSecurityManager();
}
if (configurationService != null)
{
config = configurationService.getConfiguration();
}
else
{
config = new ConfigurationImpl();
}
server = new HornetQServerImpl(config, mBeanServer, hornetQSecurityManager);
}
public void start() throws Exception
{
if (start)
{
server.start();
}
}
public void stop() throws Exception
{
if (start)
{
server.stop();
}
}
public HornetQServer getServer()
{
return server;
}
public void setStart(final boolean start)
{
this.start = start;
}
public void setSecurityManagerService(final JBossASSecurityManagerServiceMBean securityManagerService)
{
this.securityManagerService = securityManagerService;
}
public void setConfigurationService(final HornetQFileConfigurationServiceMBean configurationService)
{
this.configurationService = configurationService;
}
public ObjectName preRegister(final MBeanServer server, final ObjectName name) throws Exception
{
mBeanServer = server;
return name;
}
public void postRegister(final Boolean registrationDone)
{
// NO - OP
}
public void preDeregister() throws Exception
{
// NO - OP
}
public void postDeregister()
{
server = null;
mBeanServer = null;
}
}

36
activemq-service-sar/src/main/java/org/apache/activemq/service/HornetQStarterServiceMBean.java
View File

@ -1,36 +0,0 @@
/*
* 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.service;
import org.apache.activemq.core.server.HornetQServer;
/**
* @author <a href="mailto:lucazamador@gmail.com">Lucaz Amador</a>
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a>
*/
public interface HornetQStarterServiceMBean
{
void create() throws Exception;
void start() throws Exception;
void stop() throws Exception;
HornetQServer getServer();
void setStart(boolean start);
void setSecurityManagerService(JBossASSecurityManagerServiceMBean securityManagerService);
void setConfigurationService(HornetQFileConfigurationServiceMBean configurationService);
}

35
activemq-service-sar/src/main/java/org/apache/activemq/service/JBossASSecurityManagerService.java
View File

@ -1,35 +0,0 @@
/*
* 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.service;
import org.apache.activemq.integration.jboss.security.JBossASSecurityManager;
/**
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a>
* Created Oct 20, 2009
*/
public class JBossASSecurityManagerService implements JBossASSecurityManagerServiceMBean
{
private JBossASSecurityManager jBossASSecurityManager;
public void create()
{
jBossASSecurityManager = new JBossASSecurityManager();
jBossASSecurityManager.setAs5(false);
}
public JBossASSecurityManager getJBossASSecurityManager()
{
return jBossASSecurityManager;
}
}

26
activemq-service-sar/src/main/java/org/apache/activemq/service/JBossASSecurityManagerServiceMBean.java
View File

@ -1,26 +0,0 @@
/*
* 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.service;
import org.apache.activemq.integration.jboss.security.JBossASSecurityManager;
/**
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a>
* Created Oct 20, 2009
*/
public interface JBossASSecurityManagerServiceMBean
{
void create();
JBossASSecurityManager getJBossASSecurityManager();
}

6
pom.xml
View File

@ -481,7 +481,6 @@
<module>activemq-native</module>
<module>activemq-ra</module>
<module>activemq-rest</module>
<module>activemq-service-sar</module>
<module>activemq-tools</module>
<!-- <module>integration/activemq-jboss-as-integration</module> -->
<module>integration/activemq-spring-integration</module>
@ -506,7 +505,6 @@
<module>activemq-native</module>
<module>activemq-ra</module>
<module>activemq-rest</module>
<module>activemq-service-sar</module>
<module>activemq-tools</module>
<module>integration/activemq-jboss-as-integration</module>
<module>integration/activemq-spring-integration</module>
@ -531,7 +529,6 @@
<module>activemq-journal</module>
<module>activemq-ra</module>
<module>activemq-rest</module>
<module>activemq-service-sar</module>
<module>activemq-tools</module>
<module>integration/activemq-jboss-as-integration</module>
<module>integration/activemq-spring-integration</module>
@ -558,7 +555,6 @@
<module>activemq-journal</module>
<module>activemq-ra</module>
<module>activemq-rest</module>
<module>activemq-service-sar</module>
<module>activemq-tools</module>
<module>integration/activemq-jboss-as-integration</module>
<module>integration/activemq-spring-integration</module>
@ -596,7 +592,6 @@
<module>activemq-journal</module>
<module>activemq-ra</module>
<module>activemq-rest</module>
<module>activemq-service-sar</module>
<module>activemq-tools</module>
<module>integration/activemq-jboss-as-integration</module>
<module>integration/activemq-spring-integration</module>
@ -630,7 +625,6 @@
<module>activemq-journal</module>
<module>activemq-ra</module>
<module>activemq-rest</module>
<module>activemq-service-sar</module>
<module>activemq-tools</module>
<module>integration/activemq-jboss-as-integration</module>
<module>integration/activemq-spring-integration</module>