Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
[WFLY-10493]: Support JMS Java EE resources definition for remote Art…
…emis-based broker. * Creating queue / topic on deployments * Deleting queue / topic in undeployments * Looking for default ee resource adapter if none is specified. * Making @JMSConnectionFactoryDefinition work without internal broker. * Adding support for description of runtime external destinations. * Adding support for management address definition in the @JMSDestinationDefinition. * Fixing WFWIP-147: @JMSConnectionFactoryDefinition with property resourceAdapater to pooled-connection-factory defined in messaging-active subsystem does not work. * Adding support for authentication of management queue. JIRA: https://issues.jboss.org/browse/WFLY-10493
- Loading branch information
Showing
21 changed files
with
1,434 additions
and
571 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
99 changes: 99 additions & 0 deletions
99
...ain/java/org/wildfly/extension/messaging/activemq/ExternalBrokerConfigurationService.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,99 @@ | ||
| /* | ||
| * Copyright 2018 JBoss by Red Hat. | ||
| * | ||
| * Licensed 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.wildfly.extension.messaging.activemq; | ||
|
|
||
| import java.util.Map; | ||
| import org.apache.activemq.artemis.api.core.DiscoveryGroupConfiguration; | ||
| import org.apache.activemq.artemis.api.core.TransportConfiguration; | ||
| import org.jboss.msc.service.Service; | ||
| import org.jboss.msc.service.ServiceName; | ||
| import org.jboss.msc.service.StartContext; | ||
| import org.jboss.msc.service.StartException; | ||
| import org.jboss.msc.service.StopContext; | ||
|
|
||
| /** | ||
| * | ||
| * @author Emmanuel Hugonnet (c) 2018 Red Hat, inc. | ||
| */ | ||
| public class ExternalBrokerConfigurationService implements Service<ExternalBrokerConfigurationService> { | ||
| private final Map<String, TransportConfiguration> connectors; | ||
| private final Map<String, DiscoveryGroupConfiguration> discoveryGroupConfigurations; | ||
| private final Map<String, ServiceName> socketBindings; | ||
| private final Map<String, ServiceName> outboundSocketBindings; | ||
| private final Map<String, ServiceName> groupBindings; | ||
| // mapping between the {broadcast|discovery}-groups and the cluster names they use | ||
| private final Map<String, String> clusterNames; | ||
| // mapping between the {broadcast|discovery}-groups and the command dispatcher factory they use | ||
| private final Map<String, ServiceName> commandDispatcherFactories; | ||
|
|
||
| public ExternalBrokerConfigurationService(final Map<String, TransportConfiguration> connectors, | ||
| Map<String, DiscoveryGroupConfiguration> discoveryGroupConfigurations, | ||
| Map<String, ServiceName> socketBindings, | ||
| Map<String, ServiceName> outboundSocketBindings, | ||
| Map<String, ServiceName> groupBindings, | ||
| Map<String, ServiceName> commandDispatcherFactories, | ||
| Map<String, String> clusterNames) { | ||
| this.connectors = connectors; | ||
| this.discoveryGroupConfigurations = discoveryGroupConfigurations; | ||
| this.clusterNames = clusterNames; | ||
| this.commandDispatcherFactories = commandDispatcherFactories; | ||
| this.groupBindings = groupBindings; | ||
| this.outboundSocketBindings = outboundSocketBindings; | ||
| this.socketBindings = socketBindings; | ||
| } | ||
|
|
||
| @Override | ||
| public void start(StartContext context) throws StartException { | ||
| } | ||
|
|
||
| @Override | ||
| public void stop(StopContext context) { | ||
| } | ||
|
|
||
| public Map<String, TransportConfiguration> getConnectors() { | ||
| return connectors; | ||
| } | ||
|
|
||
| public Map<String, ServiceName> getSocketBindings() { | ||
| return socketBindings; | ||
| } | ||
|
|
||
| public Map<String, ServiceName> getOutboundSocketBindings() { | ||
| return outboundSocketBindings; | ||
| } | ||
|
|
||
| public Map<String, ServiceName> getGroupBindings() { | ||
| return groupBindings; | ||
| } | ||
|
|
||
| public Map<String, String> getClusterNames() { | ||
| return clusterNames; | ||
| } | ||
|
|
||
| public Map<String, ServiceName> getCommandDispatcherFactories() { | ||
| return commandDispatcherFactories; | ||
| } | ||
|
|
||
| public Map<String, DiscoveryGroupConfiguration> getDiscoveryGroupConfigurations() { | ||
| return discoveryGroupConfigurations; | ||
| } | ||
|
|
||
| @Override | ||
| public ExternalBrokerConfigurationService getValue() throws IllegalStateException, IllegalArgumentException { | ||
| return this; | ||
| } | ||
|
|
||
| } |
Oops, something went wrong.