diff --git a/examples/standalone/src/main/java/io/advantageous/qbit/example/jsend/HelloWorldJSend.java b/examples/standalone/src/main/java/io/advantageous/qbit/example/jsend/HelloWorldJSend.java index 71b31de8..5cddd9b3 100644 --- a/examples/standalone/src/main/java/io/advantageous/qbit/example/jsend/HelloWorldJSend.java +++ b/examples/standalone/src/main/java/io/advantageous/qbit/example/jsend/HelloWorldJSend.java @@ -75,7 +75,7 @@ public void helloJSend7(Callback>> callback) { public static void main(final String... args) { final ManagedServiceBuilder managedServiceBuilder = - ManagedServiceBuilder.managedServiceBuilder().setRootURI("/root"); + ManagedServiceBuilder.managedServiceBuilder().setRootURI("/"); /* Start the service. */ managedServiceBuilder.addEndpointService(new HelloWorldJSend()) diff --git a/examples/standalone/src/main/java/io/advantageous/qbit/example/websocket/service/EchoClientMain.java b/examples/standalone/src/main/java/io/advantageous/qbit/example/websocket/service/EchoClientMain.java index c3429231..23e99904 100644 --- a/examples/standalone/src/main/java/io/advantageous/qbit/example/websocket/service/EchoClientMain.java +++ b/examples/standalone/src/main/java/io/advantageous/qbit/example/websocket/service/EchoClientMain.java @@ -10,7 +10,9 @@ public class EchoClientMain { public static void main(final String... args) throws Exception { final ClientBuilder clientBuilder = ClientBuilder.clientBuilder(); - final Client client = clientBuilder.setHost("localhost").setPort(8080).setUri("/echo").build().startClient(); + final Client client = clientBuilder.setHost("localhost") + .setPort(8080).setUri("/echo") + .build().startClient(); final EchoAsync echoClient = client.createProxy(EchoAsync.class, "echo"); diff --git a/qbit/jms/src/main/java/io/advantageous/qbit/jms/JmsServiceBuilder.java b/qbit/jms/src/main/java/io/advantageous/qbit/jms/JmsServiceBuilder.java index aa7a1ec9..3d9ec8da 100644 --- a/qbit/jms/src/main/java/io/advantageous/qbit/jms/JmsServiceBuilder.java +++ b/qbit/jms/src/main/java/io/advantageous/qbit/jms/JmsServiceBuilder.java @@ -71,7 +71,7 @@ public class JmsServiceBuilder { /** Pattern to create JNDI URL connect string from host and port. Default works with ActiveMQ. * Replaces #host# with host and #port# with port. */ - private String providerURLPattern = "tcp://#host#:#port#"; + private String providerURLPattern = "failover:tcp://#host#:#port#"; /** Provider URL to JMS Broker which if not set will be constructed based on host, port and providerURLPattern. */ private String providerURL =null; diff --git a/qbit/redis/src/test/java/io/advantageous/qbit/kvstore/RedisKeyValueStoreTest.java b/qbit/redis/src/test/java/io/advantageous/qbit/kvstore/RedisKeyValueStoreTest.java index d7d3dff1..bfa0355c 100644 --- a/qbit/redis/src/test/java/io/advantageous/qbit/kvstore/RedisKeyValueStoreTest.java +++ b/qbit/redis/src/test/java/io/advantageous/qbit/kvstore/RedisKeyValueStoreTest.java @@ -195,7 +195,9 @@ public void testPutWithConfirmationWrapped() throws Exception{ - todoKVStore.putWithConfirmation(putCallbackBuilder.build(), "testPutWithConfirmationWrapped", new Todo(value)); + todoKVStore.putWithConfirmation(putCallbackBuilder.build(), + "testPutWithConfirmationWrapped", new Todo(value)); + ServiceProxyUtils.flushServiceProxy(todoKVStore); putLatch.await(3, TimeUnit.SECONDS);