forked from wildfly/jboss-ejb-client
-
Notifications
You must be signed in to change notification settings - Fork 1
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
* [EJBCLIENT-356] Add ability to set a short timeout for additional nodes * [EJBCLIENT-356] Eagerly return node information in discovery Return information eagerly, so that if one node is badly behaved additional information can still be returned. Includes a 'black hole' test, where a socket is opened that does nothing, to emulate a network where the packets are just going missing. Co-authored-by: Stuart Douglas <stuart.w.douglas@gmail.com>
- Loading branch information
1 parent
92b11c3
commit b1db702
Showing
5 changed files
with
261 additions
and
18 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
135 changes: 135 additions & 0 deletions
135
src/test/java/org/jboss/ejb/client/test/NetworkBlackHoleInvocationTestCase.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,135 @@ | ||
| /* | ||
| * JBoss, Home of Professional Open Source. | ||
| * Copyright 2019 Red Hat, Inc., and individual contributors | ||
| * as indicated by the @author tags. | ||
| * | ||
| * 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.jboss.ejb.client.test; | ||
|
|
||
| import org.jboss.ejb.client.EJBClient; | ||
| import org.jboss.ejb.client.StatelessEJBLocator; | ||
| import org.jboss.ejb.client.legacy.JBossEJBProperties; | ||
| import org.jboss.ejb.client.test.common.DummyServer; | ||
| import org.jboss.ejb.client.test.common.Echo; | ||
| import org.jboss.ejb.client.test.common.EchoBean; | ||
| import org.jboss.logging.Logger; | ||
| import org.junit.After; | ||
| import org.junit.Assert; | ||
| import org.junit.Before; | ||
| import org.junit.BeforeClass; | ||
| import org.junit.Test; | ||
|
|
||
| import java.net.InetAddress; | ||
| import java.net.ServerSocket; | ||
|
|
||
| /** | ||
| * @author <a href="ingo@redhat.com">Ingo Weiss</a> | ||
| */ | ||
| public class NetworkBlackHoleInvocationTestCase { | ||
| private static final Logger logger = Logger.getLogger(NetworkBlackHoleInvocationTestCase.class); | ||
| private static final String PROPERTIES_FILE = "jboss-ejb-client.properties"; | ||
|
|
||
| private DummyServer server; | ||
| private boolean serverStarted = false; | ||
|
|
||
| // module | ||
| private static final String APP_NAME = "my-foo-app"; | ||
| private static final String MODULE_NAME = "my-bar-module"; | ||
| private static final String DISTINCT_NAME = ""; | ||
|
|
||
| private static final String SERVER_NAME = "test-server"; | ||
|
|
||
| /** | ||
| * Do any general setup here | ||
| * | ||
| * @throws Exception | ||
| */ | ||
| @BeforeClass | ||
| public static void beforeClass() throws Exception { | ||
| // trigger the static init of the correct properties file - this also depends on running in forkMode=always | ||
| JBossEJBProperties ejbProperties = JBossEJBProperties.fromClassPath(NetworkBlackHoleInvocationTestCase.class.getClassLoader(), PROPERTIES_FILE); | ||
| JBossEJBProperties.getContextManager().setGlobalDefault(ejbProperties); | ||
| } | ||
|
|
||
| /** | ||
| * Do any test specific setup here | ||
| */ | ||
| @Before | ||
| public void beforeTest() throws Exception { | ||
| // start a server | ||
| server = new DummyServer("localhost", 6999, SERVER_NAME); | ||
| server.start(); | ||
| serverStarted = true; | ||
| logger.info("Started server ..."); | ||
| serverStarted = true; | ||
|
|
||
| server.register(APP_NAME, MODULE_NAME, DISTINCT_NAME, Echo.class.getSimpleName(), new EchoBean()); | ||
| logger.info("Registered module ..."); | ||
| } | ||
|
|
||
| /** | ||
| * Do any test-specific tear down here. | ||
| */ | ||
| @After | ||
| public void afterTest() { | ||
| server.unregister(APP_NAME, MODULE_NAME, DISTINCT_NAME, Echo.class.getName()); | ||
| logger.info("Unregistered module ..."); | ||
|
|
||
| if (serverStarted) { | ||
| try { | ||
| this.server.stop(); | ||
| } catch (Throwable t) { | ||
| logger.info("Could not stop server", t); | ||
| } | ||
| } | ||
| logger.info("Stopped server ..."); | ||
| } | ||
|
|
||
| /** | ||
| * Test a failed client discovery | ||
| */ | ||
| @Test | ||
| public void testTakingDownServerDoesNotBreakClients() throws Exception { | ||
| System.setProperty("org.jboss.ejb.client.discovery.timeout", "10"); | ||
| System.setProperty("org.jboss.ejb.client.discovery.additional-node-timeout","2"); | ||
|
|
||
| try (DummyServer server2 = new DummyServer("localhost", 7099, "test2")) { | ||
| server2.start(); | ||
| server2.register(APP_NAME, MODULE_NAME, DISTINCT_NAME, Echo.class.getSimpleName(), new EchoBean()); | ||
|
|
||
| // create a proxy for invocation | ||
| final StatelessEJBLocator<Echo> statelessEJBLocator = new StatelessEJBLocator<> | ||
| (Echo.class, APP_NAME, MODULE_NAME, Echo.class.getSimpleName(), DISTINCT_NAME); | ||
| final Echo proxy = EJBClient.createProxy(statelessEJBLocator); | ||
| Assert.assertNotNull("Received a null proxy", proxy); | ||
| logger.info("Created proxy for Echo: " + proxy.toString()); | ||
|
|
||
| logger.info("Invoking on proxy..."); | ||
| // Invoke on the proxy. This should fail in 10 seconds or else it'll hang. | ||
| final String message = "hello!"; | ||
| String echo = proxy.echo(message); | ||
| Assert.assertEquals(message, echo); | ||
| server2.hardKill(); | ||
| //this is a network black hole | ||
| //it emulates what happens if the server just disappears, and connect attempts hang | ||
| //instead of being immediately rejected (e.g. a firewall dropping packets) | ||
| try (ServerSocket s = new ServerSocket(7099, 100, InetAddress.getByName("localhost"))) { | ||
| echo = proxy.echo(message); | ||
| Assert.assertEquals(message, echo); | ||
|
|
||
| } | ||
|
|
||
| } | ||
| } | ||
| } |
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
33 changes: 33 additions & 0 deletions
33
src/test/resources/broken-server-jboss-ejb-client.properties
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,33 @@ | ||
| # | ||
| # JBoss, Home of Professional Open Source. | ||
| # Copyright 2019 Red Hat, Inc., and individual contributors | ||
| # as indicated by the @author tags. | ||
| # | ||
| # 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. | ||
| # | ||
|
|
||
| remote.connectionprovider.create.options.org.xnio.Options.SSL_ENABLED=false | ||
|
|
||
| remote.connections=one | ||
|
|
||
| # connection to a node at protocol://host:port | ||
| remote.connection.one.host=localhost | ||
| remote.connection.one.port=6999 | ||
| remote.connection.one.connect.options.org.xnio.Options.SASL_POLICY_NOANONYMOUS=false | ||
| remote.connection.one.username=test | ||
| remote.connection.one.password=test | ||
| remote.connection.two.host=localhost | ||
| remote.connection.two.port=6998 | ||
| remote.connection.two.connect.options.org.xnio.Options.SASL_POLICY_NOANONYMOUS=false | ||
| remote.connection.two.username=test | ||
| remote.connection.two.password=test |