Skip to content

Commit

Permalink
use non test default client in examples
Browse files Browse the repository at this point in the history
  • Loading branch information
lucidd committed Oct 2, 2018
1 parent 90cda1b commit 5924c87
Show file tree
Hide file tree
Showing 7 changed files with 14 additions and 7 deletions.
3 changes: 2 additions & 1 deletion src/test/java/com/suse/salt/netapi/examples/Async.java
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@
import com.suse.salt.netapi.AuthModule;
import com.suse.salt.netapi.client.SaltClient;
import com.suse.salt.netapi.client.impl.HttpAsyncClientImpl;
import com.suse.salt.netapi.utils.HttpClientUtils;
import com.suse.salt.netapi.utils.TestUtils;
import org.apache.http.impl.nio.client.CloseableHttpAsyncClient;

Expand All @@ -18,7 +19,7 @@ public class Async {
private static final String PASSWORD = "saltdev";

public static void main(String[] args) {
CloseableHttpAsyncClient httpClient = TestUtils.defaultClient();
CloseableHttpAsyncClient httpClient = HttpClientUtils.defaultClient();
// Init the client
SaltClient client = new SaltClient(URI.create(SALT_API_URL), new HttpAsyncClientImpl(httpClient));

Expand Down
3 changes: 2 additions & 1 deletion src/test/java/com/suse/salt/netapi/examples/Calls.java
Original file line number Diff line number Diff line change
Expand Up @@ -11,6 +11,7 @@
import com.suse.salt.netapi.datatypes.target.MinionList;
import com.suse.salt.netapi.datatypes.target.Target;
import com.suse.salt.netapi.results.Result;
import com.suse.salt.netapi.utils.HttpClientUtils;
import com.suse.salt.netapi.utils.TestUtils;

import java.net.URI;
Expand All @@ -31,7 +32,7 @@ public class Calls {
public static void main(String[] args) {
// Init the client
SaltClient client = new SaltClient(URI.create(SALT_API_URL),
new HttpAsyncClientImpl(TestUtils.defaultClient()));
new HttpAsyncClientImpl(HttpClientUtils.defaultClient()));

// Ping all minions using a glob matcher
Target<String> globTarget = new Glob("*");
Expand Down
3 changes: 2 additions & 1 deletion src/test/java/com/suse/salt/netapi/examples/Events.java
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,7 @@
import com.suse.salt.netapi.datatypes.Event;
import com.suse.salt.netapi.datatypes.Token;
import com.suse.salt.netapi.event.EventListener;
import com.suse.salt.netapi.utils.HttpClientUtils;
import com.suse.salt.netapi.utils.TestUtils;
import org.apache.http.client.config.CookieSpecs;
import org.apache.http.client.config.RequestConfig;
Expand All @@ -28,7 +29,7 @@ public class Events {
public static void main(String[] args) {
// Init client and set the timeout to infinite
SaltClient client = new SaltClient(URI.create(SALT_API_URL),
new HttpAsyncClientImpl(TestUtils.defaultClient()));
new HttpAsyncClientImpl(HttpClientUtils.defaultClient()));

RequestConfig requestConfig = RequestConfig.custom()
.setConnectionRequestTimeout(0)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -10,6 +10,7 @@
import com.suse.salt.netapi.datatypes.target.Glob;
import com.suse.salt.netapi.datatypes.target.Target;
import com.suse.salt.netapi.results.Result;
import com.suse.salt.netapi.utils.HttpClientUtils;
import com.suse.salt.netapi.utils.TestUtils;

import java.net.URI;
Expand All @@ -29,7 +30,7 @@ public class LocateModule {
public static void main(String[] args) {
// Init the client
SaltClient client = new SaltClient(URI.create(SALT_API_URL),
new HttpAsyncClientImpl(TestUtils.defaultClient()));
new HttpAsyncClientImpl(HttpClientUtils.defaultClient()));
Token token = client.login(USER, PASSWORD, AuthModule.AUTO).toCompletableFuture().join();
AuthMethod tokenAuth = new AuthMethod(token);

Expand Down
3 changes: 2 additions & 1 deletion src/test/java/com/suse/salt/netapi/examples/Runner.java
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,7 @@
import com.suse.salt.netapi.datatypes.AuthMethod;
import com.suse.salt.netapi.datatypes.PasswordAuth;
import com.suse.salt.netapi.results.Result;
import com.suse.salt.netapi.utils.HttpClientUtils;
import com.suse.salt.netapi.utils.TestUtils;

import java.net.URI;
Expand All @@ -29,7 +30,7 @@ public class Runner {
public static void main(String[] args) {
// Init the client
SaltClient client = new SaltClient(URI.create(SALT_API_URL),
new HttpAsyncClientImpl(TestUtils.defaultClient()));
new HttpAsyncClientImpl(HttpClientUtils.defaultClient()));

// Send a custom event with some data (salt.runners.event)
Map<String, Object> data = new HashMap<>();
Expand Down
3 changes: 2 additions & 1 deletion src/test/java/com/suse/salt/netapi/examples/SaltSSH.java
Original file line number Diff line number Diff line change
Expand Up @@ -12,6 +12,7 @@
import com.suse.salt.netapi.datatypes.target.SSHTarget;
import com.suse.salt.netapi.results.Result;
import com.suse.salt.netapi.results.SSHResult;
import com.suse.salt.netapi.utils.HttpClientUtils;
import com.suse.salt.netapi.utils.TestUtils;

import java.net.URI;
Expand All @@ -28,7 +29,7 @@ public class SaltSSH {
public static void main(String[] args) {
// Init the client
SaltClient client = new SaltClient(URI.create(SALT_API_URL),
new HttpAsyncClientImpl(TestUtils.defaultClient()));
new HttpAsyncClientImpl(HttpClientUtils.defaultClient()));

// Setup the configuration for Salt SSH (use defaults)
SaltSSHConfig sshConfig = new SaltSSHConfig.Builder().build();
Expand Down
3 changes: 2 additions & 1 deletion src/test/java/com/suse/salt/netapi/examples/Wheel.java
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,7 @@
import com.suse.salt.netapi.datatypes.AuthMethod;
import com.suse.salt.netapi.datatypes.PasswordAuth;
import com.suse.salt.netapi.results.Result;
import com.suse.salt.netapi.utils.HttpClientUtils;
import com.suse.salt.netapi.utils.TestUtils;

import java.net.URI;
Expand All @@ -28,7 +29,7 @@ public static void main(String[] args) {
// Init the client

SaltClient client = new SaltClient(URI.create(SALT_API_URL),
new HttpAsyncClientImpl(TestUtils.defaultClient()));
new HttpAsyncClientImpl(HttpClientUtils.defaultClient()));

// List accepted and pending minion keys
WheelResult<Result<Key.Names>> keyResults = Key.listAll().callSync(
Expand Down

0 comments on commit 5924c87

Please sign in to comment.