clean up method names in the factories. Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/c695388b Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/c695388b Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/c695388b
Branch: refs/heads/master Commit: c695388b1bee834f5bc550c6b9a251bdedb50f78 Parents: e67f9d5 Author: Timothy Bish <tabish...@gmail.com> Authored: Tue Sep 30 18:26:29 2014 -0400 Committer: Timothy Bish <tabish...@gmail.com> Committed: Tue Sep 30 18:26:29 2014 -0400 ---------------------------------------------------------------------- .../java/org/apache/qpid/jms/provider/ProviderFactory.java | 6 +++--- .../org/apache/qpid/jms/provider/amqp/AmqpProviderFactory.java | 2 +- .../apache/qpid/jms/provider/amqp/AmqpSslProviderFactory.java | 2 +- .../qpid/jms/provider/failover/FailoverProviderFactory.java | 2 +- .../qpid/jms/provider/discovery/DiscoveryProviderFactory.java | 2 +- 5 files changed, 7 insertions(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/c695388b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/ProviderFactory.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/ProviderFactory.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/ProviderFactory.java index f1c5dbd..0b6cd7c 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/ProviderFactory.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/ProviderFactory.java @@ -45,10 +45,10 @@ public abstract class ProviderFactory { * * @throws Exception if an error occurs while creating the Provider instance. */ - public abstract Provider createAsyncProvider(URI remoteURI) throws Exception; + public abstract Provider createProvider(URI remoteURI) throws Exception; /** - * @return the name of this JMS Provider, e.g. STOMP, AMQP, MQTT...etc + * @return the name of this JMS Provider. */ public abstract String getName(); @@ -68,7 +68,7 @@ public abstract class ProviderFactory { try { ProviderFactory factory = findProviderFactory(remoteURI); - result = factory.createAsyncProvider(remoteURI); + result = factory.createProvider(remoteURI); result.connect(); } catch (Exception ex) { LOG.error("Failed to create Provider instance for {}, due to: {}", remoteURI.getScheme(), ex); http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/c695388b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpProviderFactory.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpProviderFactory.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpProviderFactory.java index b1d0782..5181d71 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpProviderFactory.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpProviderFactory.java @@ -29,7 +29,7 @@ import org.apache.qpid.jms.util.PropertyUtil; public class AmqpProviderFactory extends ProviderFactory { @Override - public Provider createAsyncProvider(URI remoteURI) throws Exception { + public Provider createProvider(URI remoteURI) throws Exception { Map<String, String> map = PropertyUtil.parseQuery(remoteURI.getQuery()); Map<String, String> providerOptions = PropertyUtil.filterProperties(map, "provider."); http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/c695388b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpSslProviderFactory.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpSslProviderFactory.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpSslProviderFactory.java index 7606792..01a4f85 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpSslProviderFactory.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpSslProviderFactory.java @@ -26,7 +26,7 @@ import org.apache.qpid.jms.provider.Provider; public class AmqpSslProviderFactory extends AmqpProviderFactory { @Override - public Provider createAsyncProvider(URI remoteURI) throws Exception { + public Provider createProvider(URI remoteURI) throws Exception { return new AmqpSslProvider(remoteURI); } } http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/c695388b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/failover/FailoverProviderFactory.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/failover/FailoverProviderFactory.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/failover/FailoverProviderFactory.java index 8c63869..a0be3ec 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/failover/FailoverProviderFactory.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/failover/FailoverProviderFactory.java @@ -31,7 +31,7 @@ import org.apache.qpid.jms.util.URISupport.CompositeData; public class FailoverProviderFactory extends ProviderFactory { @Override - public Provider createAsyncProvider(URI remoteURI) throws Exception { + public Provider createProvider(URI remoteURI) throws Exception { CompositeData composite = URISupport.parseComposite(remoteURI); Map<String, String> options = composite.getParameters(); Map<String, String> nested = PropertyUtil.filterProperties(options, "nested."); http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/c695388b/qpid-jms-discovery/src/main/java/org/apache/qpid/jms/provider/discovery/DiscoveryProviderFactory.java ---------------------------------------------------------------------- diff --git a/qpid-jms-discovery/src/main/java/org/apache/qpid/jms/provider/discovery/DiscoveryProviderFactory.java b/qpid-jms-discovery/src/main/java/org/apache/qpid/jms/provider/discovery/DiscoveryProviderFactory.java index cd2ab5a..179571e 100644 --- a/qpid-jms-discovery/src/main/java/org/apache/qpid/jms/provider/discovery/DiscoveryProviderFactory.java +++ b/qpid-jms-discovery/src/main/java/org/apache/qpid/jms/provider/discovery/DiscoveryProviderFactory.java @@ -34,7 +34,7 @@ public class DiscoveryProviderFactory extends ProviderFactory { private static final String DISCOVERED_OPTION_PREFIX = "discovered."; @Override - public Provider createAsyncProvider(URI remoteURI) throws Exception { + public Provider createProvider(URI remoteURI) throws Exception { CompositeData composite = URISupport.parseComposite(remoteURI); Map<String, String> options = composite.getParameters(); --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
