Permalink
Comparing changes
Open a pull request
- 20 commits
- 64 files changed
- 0 commit comments
- 10 contributors
Commits on Mar 19, 2019
https://issues.jboss.org/browse/WFLY-11866 is a regression of WFLY-2949. Exceptions are not passed-by-reference if enabled, this cause issues if the Exception is not marked as Serializable.
Commits on Apr 04, 2019
WFLY-11866 Exception can not be passed-by-reference
WFLY-11948 @ignore CoarseDatabasePersistenceWebFailoverTestCase
Commits on Apr 05, 2019
…ir when set instead of its copy in the target dir
…ifferent JVMs MisxedDomainTestSupport will trigger caller (i.e a TestSuite) being ignored if the version under test can't handle the JVMs on offer. Test jobs can be configured with different java home paths for different JVMs. If this is done MixedDomainTestSupport will try and use an appropriate one for the legacy host.
… communication with the remote maven repo
…("getSecurityDomain") as it uses it directly in this test.
…ween tests.
…passes for me locally with jdk10.
Unified
Split
Showing
with
2,213 additions
and 234 deletions.
- +8 −4 ...rc/main/java/org/jboss/as/connector/deployers/datasource/DataSourceDefinitionInjectionSource.java
- +8 −4 ...src/main/java/org/jboss/as/connector/deployers/ds/processors/DsXmlDeploymentInstallProcessor.java
- +5 −1 ...rc/main/java/org/jboss/as/connector/deployers/ra/AdministeredObjectDefinitionInjectionSource.java
- +15 −4 ...s/as/connector/services/resourceadapters/deployment/AbstractResourceAdapterDeploymentService.java
- +8 −4 connector/src/main/java/org/jboss/as/connector/subsystems/datasources/AbstractDataSourceAdd.java
- +2 −7 docs/src/main/asciidoc/_developer-guide/JPA_Reference_Guide.adoc
- +2 −2 docs/src/main/asciidoc/_extending-wildfly/Example_subsystem.adoc
- +7 −5 ejb3/src/main/java/org/jboss/as/ejb3/remote/LocalEjbReceiver.java
- +0 −1 ejb3/src/main/resources/subsystem-templates/ejb3.xml
- +0 −4 feature-pack/src/main/resources/modules/system/layers/base/org/apache/openjpa/main/module.xml
- +0 −5 galleon-pack/src/main/resources/feature_groups/ejb3.xml
- +6 −1 mail/src/main/java/org/jboss/as/mail/extension/MailSessionAdd.java
- +5 −1 mail/src/main/java/org/jboss/as/mail/extension/MailSessionDefinitionInjectionSource.java
- +5 −1 messaging-activemq/src/main/java/org/wildfly/extension/messaging/activemq/BinderServiceUtil.java
- +5 −1 .../org/wildfly/extension/messaging/activemq/deployment/JMSDestinationDefinitionInjectionSource.java
- +25 −6 pom.xml
- +0 −2 ...ompat/src/test/java/org/jboss/as/test/compat/jpa/openjpa/OpenJPASharedModuleProviderTestCase.java
- +0 −4 testsuite/compat/src/test/scripts/build-jars.xml
- +88 −0 ...tegration/basic/src/test/java/org/jboss/as/test/integration/ejb/remote/byreference/HelloBean.java
- +39 −0 ...gration/basic/src/test/java/org/jboss/as/test/integration/ejb/remote/byreference/HelloRemote.java
- +47 −0 ...sic/src/test/java/org/jboss/as/test/integration/ejb/remote/byreference/NonSerializableObject.java
- +39 −0 ...rc/test/java/org/jboss/as/test/integration/ejb/remote/byreference/RemoteByReferenceException.java
- +1 −1 ...ion/basic/src/test/java/org/jboss/as/test/integration/ejb/remote/byreference/RemoteInterface.java
- +77 −2 ...ava/org/jboss/as/test/integration/ejb/remote/byreference/RemoteInvocationByReferenceTestCase.java
- +49 −0 .../basic/src/test/java/org/jboss/as/test/integration/ejb/remote/byreference/SerializableObject.java
- +1 −1 ...basic/src/test/java/org/jboss/as/test/integration/ejb/remote/byreference/StatelessRemoteBean.java
- +50 −0 ...n/basic/src/test/java/org/jboss/as/test/integration/ejb/remote/byreference/TransferParameter.java
- +49 −0 ...basic/src/test/java/org/jboss/as/test/integration/ejb/remote/byreference/TransferReturnValue.java
- +0 −2 ...java/org/jboss/as/test/integration/ejb/timerservice/tx/timeout/TxTimeoutTimerServiceTestCase.java
- +0 −4 .../org/jboss/as/test/integration/ejb/transaction/cmt/timeout/DefaultTransactionTimeoutTestCase.java
- +0 −4 ...st/java/org/jboss/as/test/integration/ejb/transaction/cmt/timeout/TransactionTimeoutTestCase.java
- +1 −1 ...est/java/org/jboss/as/test/integration/management/deploy/runtime/TimerEJBRuntimeNameTestCase.java
- +0 −3 ...va/org/jboss/as/test/integration/management/deploy/runtime/ejb/singleton/timer/PointLessBean.java
- +8 −8 ...ss/as/test/clustering/cluster/ejb2/stateful/failover/RemoteEJBClientStatefulFailoverTestBase.java
- +7 −7 ...va/org/jboss/as/test/clustering/cluster/ejb2/stateful/passivation/ClusterPassivationTestBase.java
- +14 −8 ...est/java/org/jboss/as/test/clustering/cluster/ejb2/stateless/RemoteStatelessFailoverTestCase.java
- +1 −0 ...boss/as/test/clustering/cluster/web/persistence/CoarseDatabasePersistenceWebFailoverTestCase.java
- +6 −0 ...ite/integration/clustering/src/test/java/org/jboss/as/test/clustering/ejb/RemoteEJBDirectory.java
- +144 −90 testsuite/integration/elytron/pom.xml
- +303 −0 ...tegration/elytron/src/test/java/org/wildfly/test/integration/elytron/realm/JdbcRealmTestCase.java
- +74 −0 ...integration/elytron/src/test/java/org/wildfly/test/integration/elytron/realm/JdbcTestServlet.java
- +25 −0 ...e/integration/elytron/src/test/java/org/wildfly/test/integration/elytron/realm/jdbc-realm-web.xml
- +40 −19 testsuite/integration/rts/src/test/java/org/wildfly/test/extension/rts/InboundBridgeTestCase.java
- +6 −0 testsuite/integration/xts/pom.xml
- +140 −0 ...suite/integration/xts/src/test/java/org/jboss/as/test/txbridge/fromjta/BridgeFromJTATestCase.java
- +45 −0 testsuite/integration/xts/src/test/java/org/jboss/as/test/txbridge/fromjta/FirstClient.java
- +68 −0 .../integration/xts/src/test/java/org/jboss/as/test/txbridge/fromjta/service/FirstCounterEntity.java
- +56 −0 ...uite/integration/xts/src/test/java/org/jboss/as/test/txbridge/fromjta/service/FirstServiceAT.java
- +88 −0 .../integration/xts/src/test/java/org/jboss/as/test/txbridge/fromjta/service/FirstServiceATImpl.java
- +84 −0 ...tegration/xts/src/test/java/org/jboss/as/test/txbridge/fromjta/service/FirstServiceATService.java
- +22 −2 testsuite/mixed-domain/pom.xml
- +0 −3 testsuite/mixed-domain/src/test/java/org/jboss/as/test/integration/domain/mixed/DomainAdjuster.java
- +0 −3 ...e/mixed-domain/src/test/java/org/jboss/as/test/integration/domain/mixed/LegacyConfigAdjuster.java
- +5 −2 ...e/mixed-domain/src/test/java/org/jboss/as/test/integration/domain/mixed/MixedDomainTestSuite.java
- +31 −0 ...mixed-domain/src/test/java/org/jboss/as/test/integration/domain/mixed/MixedDomainTestSupport.java
- +1 −7 .../mixed-domain/src/test/java/org/jboss/as/test/integration/domain/mixed/SimpleMixedDomainTest.java
- +40 −8 testsuite/mixed-domain/src/test/java/org/jboss/as/test/integration/domain/mixed/Version.java
- +1 −0 ...rc/test/java/org/jboss/as/test/integration/domain/mixed/eap640/ElytronOnlyMaster640TestSuite.java
- +1 −1 testsuite/shared/src/main/java/org/jboss/as/test/integration/security/common/Utils.java
- +67 −0 testsuite/shared/src/main/java/org/wildfly/test/security/common/elytron/ConstantRealmMapper.java
- +166 −0 testsuite/shared/src/main/java/org/wildfly/test/security/common/elytron/JdbcSecurityRealm.java
- +117 −0 testsuite/shared/src/main/java/org/wildfly/test/security/common/elytron/MappedRegexRealmMapper.java
- +108 −0 ...uite/shared/src/main/java/org/wildfly/test/security/common/elytron/RegexPrincipalTransformer.java
- +3 −1 testsuite/shared/src/main/java/org/wildfly/test/security/common/elytron/SimpleSecurityDomain.java
| @@ -261,6 +261,7 @@ private void startDataSource(final AbstractDataSourceService dataSourceService, | ||
| .addService(bindInfo.getBinderServiceName(), binderService) | ||
| .addDependency(referenceFactoryServiceName, ManagedReferenceFactory.class, binderService.getManagedObjectInjector()) | ||
| .addDependency(bindInfo.getParentContextServiceName(), ServiceBasedNamingStore.class, binderService.getNamingStoreInjector()).addListener(new LifecycleListener() { | ||
| private volatile boolean bound; | ||
| public void handleEvent(final ServiceController<?> controller, final LifecycleEvent event) { | ||
| switch (event) { | ||
| case UP: { | ||
| @@ -269,13 +270,16 @@ public void handleEvent(final ServiceController<?> controller, final LifecycleEv | ||
| } else { | ||
| SUBSYSTEM_DATASOURCES_LOGGER.boundNonJTADataSource(jndiName); | ||
| } | ||
| bound = true; | ||
| break; | ||
| } | ||
| case DOWN: { | ||
| if (isTransactional()) { | ||
| SUBSYSTEM_DATASOURCES_LOGGER.unboundDataSource(jndiName); | ||
| } else { | ||
| SUBSYSTEM_DATASOURCES_LOGGER.unBoundNonJTADataSource(jndiName); | ||
| if (bound) { | ||
| if (isTransactional()) { | ||
| SUBSYSTEM_DATASOURCES_LOGGER.unboundDataSource(jndiName); | ||
| } else { | ||
| SUBSYSTEM_DATASOURCES_LOGGER.unBoundNonJTADataSource(jndiName); | ||
| } | ||
| } | ||
| break; | ||
| } | ||
| @@ -363,6 +363,7 @@ private void startDataSource(final AbstractDataSourceService dataSourceService, | ||
| .addService(bindInfo.getBinderServiceName(), binderService) | ||
| .addDependency(referenceFactoryServiceName, ManagedReferenceFactory.class, binderService.getManagedObjectInjector()) | ||
| .addDependency(bindInfo.getParentContextServiceName(), ServiceBasedNamingStore.class, binderService.getNamingStoreInjector()).addListener(new LifecycleListener() { | ||
| private volatile boolean bound; | ||
| public void handleEvent(final ServiceController<?> controller, final LifecycleEvent event) { | ||
| switch (event) { | ||
| case UP: { | ||
| @@ -371,13 +372,16 @@ public void handleEvent(final ServiceController<?> controller, final LifecycleEv | ||
| } else { | ||
| SUBSYSTEM_DATASOURCES_LOGGER.boundNonJTADataSource(jndiName); | ||
| } | ||
| bound = true; | ||
| break; | ||
| } | ||
| case DOWN: { | ||
| if (isTransactional) { | ||
| SUBSYSTEM_DATASOURCES_LOGGER.unboundDataSource(jndiName); | ||
| } else { | ||
| SUBSYSTEM_DATASOURCES_LOGGER.unBoundNonJTADataSource(jndiName); | ||
| if (bound) { | ||
| if (isTransactional) { | ||
| SUBSYSTEM_DATASOURCES_LOGGER.unboundDataSource(jndiName); | ||
| } else { | ||
| SUBSYSTEM_DATASOURCES_LOGGER.unBoundNonJTADataSource(jndiName); | ||
| } | ||
| } | ||
| break; | ||
| } | ||
| @@ -100,14 +100,18 @@ public void getResourceValue(final ResolutionContext context, final ServiceBuild | ||
|
|
||
| serviceBuilder.addDependency(AdminObjectReferenceFactoryService.SERVICE_NAME_BASE.append(bindInfo.getBinderServiceName()), ManagedReferenceFactory.class, injector); | ||
| serviceBuilder.addListener(new LifecycleListener() { | ||
| private volatile boolean bound; | ||
| public void handleEvent(final ServiceController<?> controller, final LifecycleEvent event) { | ||
| switch (event) { | ||
| case UP: { | ||
| DEPLOYMENT_CONNECTOR_LOGGER.adminObjectAnnotation(jndiName); | ||
| bound = true; | ||
| break; | ||
| } | ||
| case DOWN: { | ||
| DEPLOYMENT_CONNECTOR_LOGGER.unboundJca("AdminObject", jndiName); | ||
| if (bound) { | ||
| DEPLOYMENT_CONNECTOR_LOGGER.unboundJca("AdminObject", jndiName); | ||
| } | ||
| break; | ||
| } | ||
| case REMOVED: { | ||
| @@ -442,14 +442,18 @@ protected AbstractWildFlyRaDeployer(ServiceTarget serviceTarget, URL url, String | ||
| .addDependency(bindInfo.getParentContextServiceName(), ServiceBasedNamingStore.class, | ||
| binderService.getNamingStoreInjector()) | ||
| .addListener(new LifecycleListener() { | ||
| private volatile boolean bound; | ||
| public void handleEvent(final ServiceController<? extends Object> controller, final LifecycleEvent event) { | ||
| switch (event) { | ||
| case UP: { | ||
| DEPLOYMENT_CONNECTOR_LOGGER.boundJca("ConnectionFactory", jndi); | ||
| bound = true; | ||
| break; | ||
| } | ||
| case DOWN: { | ||
| DEPLOYMENT_CONNECTOR_LOGGER.unboundJca("ConnectionFactory", jndi); | ||
| if (bound) { | ||
| DEPLOYMENT_CONNECTOR_LOGGER.unboundJca("ConnectionFactory", jndi); | ||
| } | ||
| break; | ||
| } | ||
| case REMOVED: { | ||
| @@ -479,15 +483,19 @@ private void installJNDIAliases(final ContextNames.BindInfo bindInfo, final Serv | ||
| sb.addDependency(bindInfo.getParentContextServiceName(), ServiceBasedNamingStore.class, aliasBinderService.getNamingStoreInjector()); | ||
| sb.requires(bindInfo.getBinderServiceName()); | ||
| sb.addListener(new LifecycleListener() { | ||
| private volatile boolean bound; | ||
| @Override | ||
| public void handleEvent(ServiceController<?> controller, LifecycleEvent event) { | ||
| switch (event) { | ||
| case UP: { | ||
| DEPLOYMENT_CONNECTOR_LOGGER.bindingAlias(bindInfo.getAbsoluteJndiName(), alias); | ||
| bound = true; | ||
| break; | ||
| } | ||
| case DOWN: { | ||
| DEPLOYMENT_CONNECTOR_LOGGER.unbindingAlias(bindInfo.getAbsoluteJndiName(), alias); | ||
| if (bound) { | ||
| DEPLOYMENT_CONNECTOR_LOGGER.unbindingAlias(bindInfo.getAbsoluteJndiName(), alias); | ||
| } | ||
| break; | ||
| } | ||
| case REMOVED: { | ||
| @@ -539,15 +547,18 @@ public void handleEvent(ServiceController<?> controller, LifecycleEvent event) { | ||
| binderService.getManagedObjectInjector()) | ||
| .addDependency(bindInfo.getParentContextServiceName(), ServiceBasedNamingStore.class, | ||
| binderService.getNamingStoreInjector()).addListener(new LifecycleListener() { | ||
|
|
||
| private volatile boolean bound; | ||
| public void handleEvent(final ServiceController<?> controller, final LifecycleEvent event) { | ||
| switch (event) { | ||
| case UP: { | ||
| DEPLOYMENT_CONNECTOR_LOGGER.boundJca("AdminObject", jndi); | ||
| bound = true; | ||
| break; | ||
| } | ||
| case DOWN: { | ||
| DEPLOYMENT_CONNECTOR_LOGGER.unboundJca("AdminObject", jndi); | ||
| if (bound) { | ||
| DEPLOYMENT_CONNECTOR_LOGGER.unboundJca("AdminObject", jndi); | ||
| } | ||
| break; | ||
| } | ||
| case REMOVED: { | ||
| @@ -418,6 +418,7 @@ static void secondRuntimeStep(OperationContext context, ModelNode operation, Man | ||
| .addService(bindInfo.getBinderServiceName(), binderService) | ||
| .addDependency(referenceFactoryServiceName, ManagedReferenceFactory.class, binderService.getManagedObjectInjector()) | ||
| .addDependency(bindInfo.getParentContextServiceName(), ServiceBasedNamingStore.class, binderService.getNamingStoreInjector()).addListener(new LifecycleListener() { | ||
| private volatile boolean bound; | ||
| public void handleEvent(final ServiceController<? extends Object> controller, final LifecycleEvent event) { | ||
| switch (event) { | ||
| case UP: { | ||
| @@ -426,13 +427,16 @@ public void handleEvent(final ServiceController<? extends Object> controller, fi | ||
| } else { | ||
| SUBSYSTEM_DATASOURCES_LOGGER.boundNonJTADataSource(jndiName); | ||
| } | ||
| bound = true; | ||
| break; | ||
| } | ||
| case DOWN: { | ||
| if (jta) { | ||
| SUBSYSTEM_DATASOURCES_LOGGER.unboundDataSource(jndiName); | ||
| } else { | ||
| SUBSYSTEM_DATASOURCES_LOGGER.unBoundNonJTADataSource(jndiName); | ||
| if (bound) { | ||
| if (jta) { | ||
| SUBSYSTEM_DATASOURCES_LOGGER.unboundDataSource(jndiName); | ||
| } else { | ||
| SUBSYSTEM_DATASOURCES_LOGGER.unBoundNonJTADataSource(jndiName); | ||
| } | ||
| } | ||
| break; | ||
| } | ||
| @@ -515,10 +515,10 @@ version="1.0"> + | ||
| [[migrating-from-openjpa]] | ||
| == Migrating from OpenJPA | ||
|
|
||
| You need to copy the OpenJPA jars (e.g. openjpa-all.jar serp.jar) into | ||
| You need to copy the OpenJPA jar (e.g. openjpa-all.jar) into | ||
| the WildFly modules/org/apache/openjpa/main folder and update | ||
| modules/org/apache/openjpa/main/module.xml to include the same jar file | ||
| names that you copied in. This will help you get your application that | ||
| name that you copied in. This will help you get your application that | ||
| depends on OpenJPA, to deploy on WildFly. | ||
|
|
||
| [source,java,options="nowrap"] | ||
| @@ -531,22 +531,17 @@ depends on OpenJPA, to deploy on WildFly. | ||
| <exclude path="javax/**" /> | ||
| </filter> | ||
| </resource-root> | ||
| <resource-root path="serp.jar"/> | ||
| </resources> | ||
| <dependencies> | ||
| <module name="javax.api"/> | ||
| <module name="javax.annotation.api"/> | ||
| <module name="javax.enterprise.api"/> | ||
| <module name="javax.persistence.api"/> | ||
| <module name="javax.transaction.api"/> | ||
| <module name="javax.validation.api"/> | ||
| <module name="javax.xml.bind.api"/> | ||
| <module name="org.apache.commons.collections"/> | ||
| <module name="org.apache.commons.lang"/> | ||
| <module name="org.jboss.as.jpa.spi"/> | ||
| <module name="org.jboss.logging"/> | ||
| <module name="org.jboss.vfs"/> | ||
| <module name="org.jboss.jandex"/> | ||
| </dependencies> | ||
| </module> | ||
| @@ -17,7 +17,7 @@ mvn archetype:generate \ | ||
| -DarchetypeArtifactId=wildfly-subsystem \ | ||
| -DarchetypeGroupId=org.wildfly.archetypes \ | ||
| -DarchetypeVersion=8.0.0.Final \ | ||
| -DarchetypeRepository=http://repository.jboss.org/nexus/content/groups/public | ||
| -DarchetypeRepository=https://repository.jboss.org/nexus/content/groups/public | ||
| ---- | ||
|
|
||
| Maven will download the archetype and it's dependencies, and ask you | ||
| @@ -29,7 +29,7 @@ $ mvn archetype:generate \ | ||
| -DarchetypeArtifactId=wildfly-subsystem \ | ||
| -DarchetypeGroupId=org.wildfly.archetypes \ | ||
| -DarchetypeVersion=8.0.0.Final \ | ||
| -DarchetypeRepository=http://repository.jboss.org/nexus/content/groups/public | ||
| -DarchetypeRepository=https://repository.jboss.org/nexus/content/groups/public | ||
| [INFO] Scanning for projects... | ||
| [INFO] | ||
| [INFO] ------------------------------------------------------------------------ | ||
| @@ -204,7 +204,7 @@ protected void processInvocation(final EJBReceiverInvocationContext receiverCont | ||
| result = view.invoke(interceptorContext); | ||
| } catch (Exception e) { | ||
| // WFLY-4331 - clone the exception of an async task | ||
| receiverContext.resultReady(new CloningExceptionProducer(resultCloner, e)); | ||
| receiverContext.resultReady(new CloningExceptionProducer(resultCloner, e, allowPassByReference)); | ||
| return; | ||
| } | ||
| // if the result is null, there is no cloning needed | ||
| @@ -225,7 +225,7 @@ protected void processInvocation(final EJBReceiverInvocationContext receiverCont | ||
| intr = true; | ||
| } catch (ExecutionException e) { | ||
| // WFLY-4331 - clone the exception of an async task | ||
| receiverContext.resultReady(new CloningExceptionProducer(resultCloner, e)); | ||
| receiverContext.resultReady(new CloningExceptionProducer(resultCloner, e, allowPassByReference)); | ||
| return; | ||
| } | ||
| } finally { | ||
| @@ -267,7 +267,7 @@ protected void processInvocation(final EJBReceiverInvocationContext receiverCont | ||
| } catch (Exception e) { | ||
| //we even have to clone the exception type | ||
| //to make sure it matches | ||
| receiverContext.resultReady(new CloningExceptionProducer(resultCloner, e)); | ||
| receiverContext.resultReady(new CloningExceptionProducer(resultCloner, e, allowPassByReference)); | ||
| return; | ||
| } | ||
| receiverContext.resultReady(new CloningResultProducer(invocation, resultCloner, result, allowPassByReference)); | ||
| @@ -309,14 +309,16 @@ public void discardResult() { | ||
| static final class CloningExceptionProducer implements EJBReceiverInvocationContext.ResultProducer { | ||
| private final ObjectCloner resultCloner; | ||
| private final Exception exception; | ||
| private final boolean allowPassByReference; | ||
|
|
||
| CloningExceptionProducer(final ObjectCloner resultCloner, final Exception exception) { | ||
| CloningExceptionProducer(final ObjectCloner resultCloner, final Exception exception, final boolean allowPassByReference) { | ||
| this.resultCloner = resultCloner; | ||
| this.exception = exception; | ||
| this.allowPassByReference = allowPassByReference; | ||
| } | ||
|
|
||
| public Object getResult() throws Exception { | ||
| throw (Exception) LocalEjbReceiver.clone(resultCloner, exception); | ||
| throw (Exception) LocalEjbReceiver.clone(Exception.class, resultCloner, exception, allowPassByReference); | ||
| } | ||
|
|
||
| public void discardResult() { | ||
| @@ -32,7 +32,6 @@ | ||
| </timer-service> | ||
| <remote connector-ref="http-remoting-connector" thread-pool-name="default"> | ||
| <channel-creation-options> | ||
| <option name="READ_TIMEOUT" value="${prop.remoting-connector.read.timeout:20}" type="xnio"/> | ||
| <option name="MAX_OUTBOUND_MESSAGES" value="1234" type="remoting"/> | ||
| </channel-creation-options> | ||
| </remote> | ||
| @@ -33,18 +33,14 @@ | ||
| </resources> | ||
|
|
||
| <dependencies> | ||
| <module name="javax.api"/> | ||
| <module name="javax.annotation.api"/> | ||
| <module name="javax.enterprise.api"/> | ||
| <module name="javax.persistence.api"/> | ||
| <module name="javax.transaction.api"/> | ||
| <module name="javax.validation.api"/> | ||
| <module name="javax.xml.bind.api"/> | ||
| <module name="org.apache.commons.collections"/> | ||
| <module name="org.apache.commons.lang"/> | ||
| <module name="org.jboss.as.jpa.spi"/> | ||
| <module name="org.jboss.logging"/> | ||
| <module name="org.jboss.vfs"/> | ||
| <module name="org.jboss.jandex"/> | ||
| </dependencies> | ||
| </module> | ||
| @@ -41,11 +41,6 @@ | ||
| <feature spec="subsystem.ejb3.service.remote"> | ||
| <param name="connector-ref" value="http-remoting-connector"/> | ||
| <param name="thread-pool-name" value="default"/> | ||
| <feature spec="subsystem.ejb3.service.remote.channel-creation-options"> | ||
| <param name="channel-creation-options" value="READ_TIMEOUT"/> | ||
| <param name="value" value="${prop.remoting-connector.read.timeout:20}"/> | ||
| <param name="type" value="xnio"/> | ||
| </feature> | ||
| <feature spec="subsystem.ejb3.service.remote.channel-creation-options"> | ||
| <param name="channel-creation-options" value="MAX_OUTBOUND_MESSAGES"/> | ||
| <param name="value" value="1234"/> | ||
| @@ -140,14 +140,19 @@ static void installRuntimeServices(OperationContext context, PathAddress address | ||
| final ServiceBuilder<?> binderBuilder = serviceTarget | ||
| .addService(bindInfo.getBinderServiceName(), binderService) | ||
| .addDependency(bindInfo.getParentContextServiceName(), ServiceBasedNamingStore.class, binderService.getNamingStoreInjector()).addListener(new LifecycleListener() { | ||
| private volatile boolean bound; | ||
| @Override | ||
| public void handleEvent(final ServiceController<?> controller, final LifecycleEvent event) { | ||
| switch (event) { | ||
| case UP: { | ||
| MailLogger.ROOT_LOGGER.boundMailSession(jndiName); | ||
| bound = true; | ||
| break; | ||
| } | ||
| case DOWN: { | ||
| MailLogger.ROOT_LOGGER.unboundMailSession(jndiName); | ||
| if (bound) { | ||
| MailLogger.ROOT_LOGGER.unboundMailSession(jndiName); | ||
| } | ||
| break; | ||
| } | ||
| case REMOVED: { | ||
Oops, something went wrong.