[hornetq-commits] JBoss hornetq SVN: r12045 - in trunk: hornetq-core/src/main/java/org/hornetq/api/core and 3 other directories.

Author: borges Date: 2012-01-23 07:01:43 -0500 (Mon, 23 Jan 2012) New Revision: 12045 Modified: trunk/hornetq-commons/src/main/java/org/hornetq/api/core/PropertyConversionException.java trunk/hornetq-core/src/main/java/org/hornetq/api/core/Interceptor.java trunk/hornetq-core/src/main/java/org/hornetq/api/core/client/ClientMessage.java trunk/hornetq-core/src/main/java/org/hornetq/api/core/client/ClientProducer.java trunk/hornetq-core/src/main/java/org/hornetq/api/core/client/HornetQClient.java trunk/hornetq-core/src/main/java/org/hornetq/api/core/client/ServerLocator.java trunk/hornetq-jms/src/main/java/org/hornetq/api/jms/management/ConnectionFactoryControl.java trunk/hornetq-jms/src/main/java/org/hornetq/jms/client/HornetQConnectionFactory.java Log: HORNETQ-829 Public API javadoc fixes: broken references (and other javadoc corrections) Modified: trunk/hornetq-commons/src/main/java/org/hornetq/api/core/PropertyConversionException.java =================================================================== --- trunk/hornetq-commons/src/main/java/org/hornetq/api/core/PropertyConversionException.java 2012-01-23 12:01:08 UTC (rev 12044) +++ trunk/hornetq-commons/src/main/java/org/hornetq/api/core/PropertyConversionException.java 2012-01-23 12:01:43 UTC (rev 12045) @@ -14,13 +14,10 @@ package org.hornetq.api.core; /** - * A PropertyConversionException is thrown by Message methods - * when a property can not be converted to the expected type. - * + * A PropertyConversionException is thrown by {@link org.hornetq.api.core.Message} methods when a + * property can not be converted to the expected type. * @author <a href="mailto:jmesnil@redhat.com">Jeff Mesnil</a> - * - * @see Message - * + * @see org.hornetq.api.core.Message */ public class PropertyConversionException extends RuntimeException { Modified: trunk/hornetq-core/src/main/java/org/hornetq/api/core/Interceptor.java =================================================================== --- trunk/hornetq-core/src/main/java/org/hornetq/api/core/Interceptor.java 2012-01-23 12:01:08 UTC (rev 12044) +++ trunk/hornetq-core/src/main/java/org/hornetq/api/core/Interceptor.java 2012-01-23 12:01:43 UTC (rev 12045) @@ -13,16 +13,15 @@ package org.hornetq.api.core; -import org.hornetq.api.core.client.ClientSessionFactory; +import org.hornetq.api.core.client.ServerLocator; import org.hornetq.core.protocol.core.Packet; import org.hornetq.spi.core.protocol.RemotingConnection; /** * This is class is a simple way to intercepting calls on HornetQ client and servers. * <p/> - * To add an interceptor to HornetQ server, you have to modify hornetq-configuration.xml. - * To add it to a client, use {@link ClientSessionFactory#addInterceptor(Interceptor)} - * + * To add an interceptor to HornetQ server, you have to modify hornetq-configuration.xml. To add it + * to a client, use {@link ServerLocator#addInterceptor(Interceptor)} * @author clebert.suconic(a)jboss.com * @author <a href="mailto:tim.fox@jboss.com">Tim Fox</a> */ Modified: trunk/hornetq-core/src/main/java/org/hornetq/api/core/client/ClientMessage.java =================================================================== --- trunk/hornetq-core/src/main/java/org/hornetq/api/core/client/ClientMessage.java 2012-01-23 12:01:08 UTC (rev 12044) +++ trunk/hornetq-core/src/main/java/org/hornetq/api/core/client/ClientMessage.java 2012-01-23 12:01:43 UTC (rev 12045) @@ -92,8 +92,6 @@ * Sets the body's IntputStream. * <br> * This method is used when sending large messages - * - * @throws HornetQException */ void setBodyInputStream(InputStream bodyInputStream); Modified: trunk/hornetq-core/src/main/java/org/hornetq/api/core/client/ClientProducer.java =================================================================== --- trunk/hornetq-core/src/main/java/org/hornetq/api/core/client/ClientProducer.java 2012-01-23 12:01:08 UTC (rev 12044) +++ trunk/hornetq-core/src/main/java/org/hornetq/api/core/client/ClientProducer.java 2012-01-23 12:01:43 UTC (rev 12045) @@ -18,19 +18,21 @@ import org.hornetq.api.core.SimpleString; /** - * A ClientProducer is used to send messages to a specific address. Messages are then routed on the server to any queues - * that are bound to the address. A ClientProducer can either be created with a specific address in mind or with none. - * With the latter the address must be provided using the appropriate send() method. <br><br> - * - * The sending semantics can change depending on what blocking semantics are set via {@link ClientSessionFactory#setBlockOnDurableSend(boolean)} - * and {@link org.hornetq.api.core.client.ClientSessionFactory#setBlockOnNonDurableSend(boolean)} . If set to true - * then for each message type, durable and non durable respectively, any exceptions such as the address not existing or - * security exceptions will be thrown at the time of send. Alternatively if set to false then exceptions will only be - * logged on the server. <br><br> - * - * The send rate can also be controlled via {@link ClientSessionFactory#setProducerMaxRate(int)} - * and the {@link org.hornetq.api.core.client.ClientSessionFactory#setProducerWindowSize(int)}. <br><br> - * + * A ClientProducer is used to send messages to a specific address. Messages are then routed on the + * server to any queues that are bound to the address. A ClientProducer can either be created with a + * specific address in mind or with none. With the latter the address must be provided using the + * appropriate send() method. <br> + * <p> + * The sending semantics can change depending on what blocking semantics are set via + * {@link ServerLocator#setBlockOnDurableSend(boolean)} and + * {@link org.hornetq.api.core.client.ServerLocator#setBlockOnNonDurableSend(boolean)} . If set to + * true then for each message type, durable and non durable respectively, any exceptions such as the + * address not existing or security exceptions will be thrown at the time of send. Alternatively if + * set to false then exceptions will only be logged on the server. <br> + * <p> + * The send rate can also be controlled via {@link ServerLocator#setProducerMaxRate(int)} and the + * {@link org.hornetq.api.core.client.ServerLocator#setProducerWindowSize(int)}. <br> + * <br> * @author <a href="mailto:tim.fox@jboss.com">Tim Fox</a> * @author <a href="mailto:ataylor@redhat.com">Andy Taylor</a> */ @@ -41,33 +43,32 @@ * * <br><br>The address can be <code>null</code> if the ClientProducer * - * was creating without specifying an address, that is by using {@link ClientSession#createProducer()}. - * + * was creating without specifying an address, that is by using {@link ClientSession#createProducer()}. + * * @return the address where messages will be sent */ SimpleString getAddress(); /** - * Sends a message to an address. - * - * specified in {@link ClientSession#createProducer(String)} or similar methods. - * - * <br><br>This will block until confirmation that the message has reached the server has been received if - * {@link ClientSessionFactory#setBlockOnDurableSend(boolean)} or {@link org.hornetq.api.core.client.ClientSessionFactory#setBlockOnNonDurableSend(boolean)} - * are set to <code>true</code> for the specified message type. - * + * Sends a message to an address. specified in {@link ClientSession#createProducer(String)} or + * similar methods. <br> + * <br> + * This will block until confirmation that the message has reached the server has been received + * if {@link ServerLocator#setBlockOnDurableSend(boolean)} or + * {@link ServerLocator#setBlockOnNonDurableSend(boolean)} are set to <code>true</code> for the + * specified message type. * @param message the message to send * @throws HornetQException if an exception occurs while sending the message */ void send(Message message) throws HornetQException; /** - * Sends a message to the specified address instead of the ClientProducer's address. - * - * <br><br>This will block until confirmation that the message has reached the server has been received if - * {@link ClientSessionFactory#setBlockOnDurableSend(boolean)} or {@link org.hornetq.api.core.client.ClientSessionFactory#setBlockOnNonDurableSend(boolean)} - * are set to true for the specified message type. - * + * Sends a message to the specified address instead of the ClientProducer's address. <br> + * <br> + * This will block until confirmation that the message has reached the server has been received + * if {@link ServerLocator#setBlockOnDurableSend(boolean)} or + * {@link ServerLocator#setBlockOnNonDurableSend(boolean)} are set to true for the specified + * message type. * @param address the address where the message will be sent * @param message the message to send * @throws HornetQException if an exception occurs while sending the message @@ -75,12 +76,12 @@ void send(SimpleString address, Message message) throws HornetQException; /** - * Sends a message to the specified address instead of the ClientProducer's address. - * - * <br><br>This will block until confirmation that the message has reached the server has been received if - * {@link ClientSessionFactory#setBlockOnDurableSend(boolean)} or {@link org.hornetq.api.core.client.ClientSessionFactory#setBlockOnNonDurableSend(boolean)} - * are set to true for the specified message type. - * + * Sends a message to the specified address instead of the ClientProducer's address. <br> + * <br> + * This will block until confirmation that the message has reached the server has been received + * if {@link ServerLocator#setBlockOnDurableSend(boolean)} or + * {@link ServerLocator#setBlockOnNonDurableSend(boolean)} are set to true for the specified + * message type. * @param address the address where the message will be sent * @param message the message to send * @throws HornetQException if an exception occurs while sending the message @@ -89,35 +90,35 @@ /** * Closes the ClientProducer. If already closed nothing is done. - * + * * @throws HornetQException if an exception occurs while closing the producer */ void close() throws HornetQException; /** * Returns whether the producer is closed or not. - * + * * @return <code>true</code> if the producer is closed, <code>false</code> else */ boolean isClosed(); /** * Returns whether the producer will block when sending <em>durable</em> messages. - * + * * @return <code>true</code> if the producer blocks when sending durable, <code>false</code> else */ boolean isBlockOnDurableSend(); /** * Returns whether the producer will block when sending <em>non-durable</em> messages. - * + * * @return <code>true</code> if the producer blocks when sending non-durable, <code>false</code> else */ boolean isBlockOnNonDurableSend(); /** * Returns the maximum rate at which a ClientProducer can send messages per second. - * + * * @return the producers maximum rate */ int getMaxRate(); Modified: trunk/hornetq-core/src/main/java/org/hornetq/api/core/client/HornetQClient.java =================================================================== --- trunk/hornetq-core/src/main/java/org/hornetq/api/core/client/HornetQClient.java 2012-01-23 12:01:08 UTC (rev 12044) +++ trunk/hornetq-core/src/main/java/org/hornetq/api/core/client/HornetQClient.java 2012-01-23 12:01:43 UTC (rev 12045) @@ -19,11 +19,11 @@ /** * Utility class for creating HornetQ {@link ClientSessionFactory} objects. - * + * * Once a {@link ClientSessionFactory} has been created, it can be further configured * using its setter methods before creating the sessions. Once a session is created, * the factory can no longer be modified (its setter methods will throw a {@link IllegalStateException}. - * + * * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> */ public class HornetQClient @@ -37,9 +37,9 @@ public static final long DEFAULT_CONNECTION_TTL = 1 * 60 * 1000; // Any message beyond this size is considered a large message (to be sent in chunks) - + public static final int DEFAULT_MIN_LARGE_MESSAGE_SIZE = 100 * 1024; - + public static final boolean DEFAULT_COMPRESS_LARGE_MESSAGES = false; public static final int DEFAULT_CONSUMER_WINDOW_SIZE = 1024 * 1024; @@ -81,7 +81,7 @@ public static final int DEFAULT_RECONNECT_ATTEMPTS = 0; public static final int INITIAL_CONNECT_ATTEMPTS = 1; - + public static final boolean DEFAULT_FAILOVER_ON_INITIAL_CONNECTION = false; public static final boolean DEFAULT_IS_HA = false; @@ -97,13 +97,13 @@ public static final int DEFAULT_INITIAL_MESSAGE_PACKET_SIZE = 1500; public static final boolean DEFAULT_XA = false; - + public static final boolean DEFAULT_HA = false; - + /** * Create a ServerLocator which creates session factories using a static list of transportConfigurations, the ServerLocator is not updated automatically * as the cluster topology changes, and no HA backup information is propagated to the client - * + * * @param transportConfigurations * @return the ServerLocator */ @@ -111,12 +111,12 @@ { return new ServerLocatorImpl(false, transportConfigurations); } - + /** * Create a ServerLocator which creates session factories from a set of live servers, no HA backup information is propagated to the client - * + * * The UDP address and port are used to listen for live servers in the cluster - * + * * @param discoveryAddress The UDP group address to listen for updates * @param discoveryPort the UDP port to listen for updates * @return the ServerLocator @@ -125,27 +125,39 @@ { return new ServerLocatorImpl(false, groupConfiguration); } - + /** - * Create a ServerLocator which will receive cluster topology updates from the cluster as servers leave or join and new backups are appointed or removed. - * The initial list of servers supplied in this method is simply to make an initial connection to the cluster, once that connection is made, up to date - * cluster topology information is downloaded and automatically updated whenever the cluster topology changes. If the topology includes backup servers - * that information is also propagated to the client so that it can know which server to failover onto in case of live server failure. - * @param initialServers The initial set of servers used to make a connection to the cluster. Each one is tried in turn until a successful connection is made. Once - * a connection is made, the cluster topology is downloaded and the rest of the list is ignored. + * Create a ServerLocator which will receive cluster topology updates from the cluster as servers + * leave or join and new backups are appointed or removed. + * <p> + * The initial list of servers supplied in this method is simply to make an initial connection to + * the cluster, once that connection is made, up to date cluster topology information is + * downloaded and automatically updated whenever the cluster topology changes. + * <p> + * If the topology includes backup servers that information is also propagated to the client so + * that it can know which server to failover onto in case of live server failure. + * @param initialServers The initial set of servers used to make a connection to the cluster. + * Each one is tried in turn until a successful connection is made. Once a connection + * is made, the cluster topology is downloaded and the rest of the list is ignored. * @return the ServerLocator */ public static ServerLocator createServerLocatorWithHA(TransportConfiguration... initialServers) { return new ServerLocatorImpl(true, initialServers); } - + /** - * Create a ServerLocator which will receive cluster topology updates from the cluster as servers leave or join and new backups are appointed or removed. - * The discoveryAddress and discoveryPort parameters in this method are used to listen for UDP broadcasts which contain connection information for members of the cluster. - * The broadcasted connection information is simply used to make an initial connection to the cluster, once that connection is made, up to date - * cluster topology information is downloaded and automatically updated whenever the cluster topology changes. If the topology includes backup servers - * that information is also propagated to the client so that it can know which server to failover onto in case of live server failure. + * Create a ServerLocator which will receive cluster topology updates from the cluster as servers + * leave or join and new backups are appointed or removed. + * <p> + * The discoveryAddress and discoveryPort parameters in this method are used to listen for UDP + * broadcasts which contain connection information for members of the cluster. The broadcasted + * connection information is simply used to make an initial connection to the cluster, once that + * connection is made, up to date cluster topology information is downloaded and automatically + * updated whenever the cluster topology changes. + * <p> + * If the topology includes backup servers that information is also propagated to the client so + * that it can know which server to failover onto in case of live server failure. * @param discoveryAddress The UDP group address to listen for updates * @param discoveryPort the UDP port to listen for updates * @return the ServerLocator @@ -154,8 +166,8 @@ { return new ServerLocatorImpl(true, groupConfiguration); } - + private HornetQClient() { } Modified: trunk/hornetq-core/src/main/java/org/hornetq/api/core/client/ServerLocator.java =================================================================== --- trunk/hornetq-core/src/main/java/org/hornetq/api/core/client/ServerLocator.java 2012-01-23 12:01:08 UTC (rev 12044) +++ trunk/hornetq-core/src/main/java/org/hornetq/api/core/client/ServerLocator.java 2012-01-23 12:01:43 UTC (rev 12045) @@ -29,7 +29,7 @@ /** * Returns true if close was already called - * @return + * @return {@code true} if closed, {@code false} otherwise. */ boolean isClosed(); Modified: trunk/hornetq-jms/src/main/java/org/hornetq/api/jms/management/ConnectionFactoryControl.java =================================================================== --- trunk/hornetq-jms/src/main/java/org/hornetq/api/jms/management/ConnectionFactoryControl.java 2012-01-23 12:01:08 UTC (rev 12044) +++ trunk/hornetq-jms/src/main/java/org/hornetq/api/jms/management/ConnectionFactoryControl.java 2012-01-23 12:01:43 UTC (rev 12045) @@ -16,18 +16,17 @@ import org.hornetq.api.core.DiscoveryGroupConfiguration; import org.hornetq.api.core.TransportConfiguration; import org.hornetq.api.core.client.ClientSessionFactory; +import org.hornetq.api.core.client.ServerLocator; import org.hornetq.api.core.management.Operation; import org.hornetq.api.core.management.Parameter; /** - * A ConnectionFactoryControl is used to manage a JMS ConnectionFactory. - * <br> - * HornetQ JMS ConnectionFactory uses an underlying ClientSessionFactory to connect to HornetQ servers. - * Please refer to the ClientSessionFactory for a detailed description. - * + * A ConnectionFactoryControl is used to manage a JMS ConnectionFactory. <br> + * HornetQ JMS ConnectionFactory uses an underlying ClientSessionFactory to connect to HornetQ + * servers. Please refer to the ClientSessionFactory for a detailed description. * @author <a href="mailto:jmesnil@redhat.com">Jeff Mesnil</a> * @author <a href="mailto:fox@redhat.com">Tim Fox</a> - * + * @see ServerLocator * @see ClientSessionFactory */ public interface ConnectionFactoryControl @@ -63,290 +62,289 @@ * Sets the Client ID for this connection factory. */ void setClientID(String clientID); - + boolean isCompressLargeMessages(); - + void setCompressLargeMessages(boolean compress); /** - * @see ClientSessionFactory#getClientFailureCheckPeriod() + * @see ServerLocator#getClientFailureCheckPeriod() */ long getClientFailureCheckPeriod(); /** - * @see ClientSessionFactory#setClientFailureCheckPeriod + * @see ServerLocator#setClientFailureCheckPeriod */ void setClientFailureCheckPeriod(long clientFailureCheckPeriod); /** - * @see ClientSessionFactory#getCallTimeout() + * @see ServerLocator#getCallTimeout() */ long getCallTimeout(); /** - * @see ClientSessionFactory#setCallTimeout(long) + * @see ServerLocator#setCallTimeout(long) */ void setCallTimeout(long callTimeout); /** - * Returns the batch size (in bytes) between acknowledgements when using DUPS_OK_ACKNOWLEDGE mode. - * - * @see ClientSessionFactory#getAckBatchSize() + * Returns the batch size (in bytes) between acknowledgements when using DUPS_OK_ACKNOWLEDGE + * mode. + * @see ServerLocator#getAckBatchSize() * @see javax.jms.Session#DUPS_OK_ACKNOWLEDGE */ int getDupsOKBatchSize(); /** - * @see ClientSessionFactory#setAckBatchSize(int) + * @see ServerLocator#setAckBatchSize(int) */ void setDupsOKBatchSize(int dupsOKBatchSize); /** - * @see ClientSessionFactory#getConsumerMaxRate() + * @see ServerLocator#getConsumerMaxRate() */ int getConsumerMaxRate(); /** - * @see ClientSessionFactory#setConsumerMaxRate(int) + * @see ServerLocator#setConsumerMaxRate(int) */ void setConsumerMaxRate(int consumerMaxRate); /** - * @see ClientSessionFactory#getConsumerWindowSize() + * @see ServerLocator#getConsumerWindowSize() */ int getConsumerWindowSize(); /** - * @see ClientSessionFactory#setConfirmationWindowSize(int) + * @see ServerLocator#setConfirmationWindowSize(int) */ void setConsumerWindowSize(int consumerWindowSize); /** - * @see ClientSessionFactory#getProducerMaxRate() + * @see ServerLocator#getProducerMaxRate() */ int getProducerMaxRate(); /** - * @see ClientSessionFactory#setProducerMaxRate(int) + * @see ServerLocator#setProducerMaxRate(int) */ void setProducerMaxRate(int producerMaxRate); /** - * @see ClientSessionFactory#getConfirmationWindowSize() + * @see ServerLocator#getConfirmationWindowSize() */ int getConfirmationWindowSize(); /** - * @see ClientSessionFactory#setConfirmationWindowSize(int) + * @see ServerLocator#setConfirmationWindowSize(int) */ void setConfirmationWindowSize(int confirmationWindowSize); /** - * @see ClientSessionFactory#isBlockOnAcknowledge() + * @see ServerLocator#isBlockOnAcknowledge() */ boolean isBlockOnAcknowledge(); /** - * @see ClientSessionFactory#setBlockOnAcknowledge(boolean) + * @see ServerLocator#setBlockOnAcknowledge(boolean) */ void setBlockOnAcknowledge(boolean blockOnAcknowledge); /** - * @see ClientSessionFactory#isBlockOnDurableSend() + * @see ServerLocator#isBlockOnDurableSend() */ boolean isBlockOnDurableSend(); /** - * @see ClientSessionFactory#setBlockOnDurableSend(boolean) + * @see ServerLocator#setBlockOnDurableSend(boolean) */ void setBlockOnDurableSend(boolean blockOnDurableSend); /** - * @see ClientSessionFactory#isBlockOnNonDurableSend() + * @see ServerLocator#isBlockOnNonDurableSend() */ boolean isBlockOnNonDurableSend(); /** - * @see ClientSessionFactory#setBlockOnNonDurableSend(boolean) + * @see ServerLocator#setBlockOnNonDurableSend(boolean) */ void setBlockOnNonDurableSend(boolean blockOnNonDurableSend); /** - * @see ClientSessionFactory#isPreAcknowledge() + * @see ServerLocator#isPreAcknowledge() */ boolean isPreAcknowledge(); /** - * @see ClientSessionFactory#setPreAcknowledge(boolean) + * @see ServerLocator#setPreAcknowledge(boolean) */ void setPreAcknowledge(boolean preAcknowledge); /** - * @see ClientSessionFactory#getConnectionTTL() + * @see ServerLocator#getConnectionTTL() */ long getConnectionTTL(); /** - * @see ClientSessionFactory#setConnectionTTL(long) + * @see ServerLocator#setConnectionTTL(long) */ void setConnectionTTL(long connectionTTL); /** * Returns the batch size (in bytes) between acknowledgements when using a transacted session. - * - * @see ClientSessionFactory#getAckBatchSize() + * @see ServerLocator#getAckBatchSize() */ int getTransactionBatchSize(); /** - * @see ClientSessionFactory#setAckBatchSize(int) + * @see ServerLocator#setAckBatchSize(int) */ void setTransactionBatchSize(int transactionBatchSize); /** - * @see ClientSessionFactory#getMinLargeMessageSize() + * @see ServerLocator#getMinLargeMessageSize() */ int getMinLargeMessageSize(); /** - * @see ClientSessionFactory#setMinLargeMessageSize(int) + * @see ServerLocator#setMinLargeMessageSize(int) */ void setMinLargeMessageSize(int minLargeMessageSize); /** - * @see ClientSessionFactory#isAutoGroup() + * @see ServerLocator#isAutoGroup() */ boolean isAutoGroup(); /** - * @see ClientSessionFactory#setAutoGroup(boolean) + * @see ServerLocator#setAutoGroup(boolean) */ void setAutoGroup(boolean autoGroup); /** - * @see ClientSessionFactory#getRetryInterval() + * @see ServerLocator#getRetryInterval() */ long getRetryInterval(); /** - * @see ClientSessionFactory#setRetryInterval(long) + * @see ServerLocator#setRetryInterval(long) */ void setRetryInterval(long retryInterval); /** - * @see ClientSessionFactory#getRetryIntervalMultiplier() + * @see ServerLocator#getRetryIntervalMultiplier() */ double getRetryIntervalMultiplier(); /** - * @see ClientSessionFactory#setRetryIntervalMultiplier(double) + * @see ServerLocator#setRetryIntervalMultiplier(double) */ void setRetryIntervalMultiplier(double retryIntervalMultiplier); /** - * @see ClientSessionFactory#getReconnectAttempts() + * @see ServerLocator#getReconnectAttempts() */ int getReconnectAttempts(); /** - * @see ClientSessionFactory#setReconnectAttempts(int) + * @see ServerLocator#setReconnectAttempts(int) */ void setReconnectAttempts(int reconnectAttempts); - + /** - * @see ClientSessionFactory#isFailoverOnInitialConnection() + * @see ServerLocator#isFailoverOnInitialConnection() */ boolean isFailoverOnInitialConnection(); /** - * @see ClientSessionFactory#setFailoverOnInitialConnection(boolean) + * @see ServerLocator#setFailoverOnInitialConnection(boolean) */ void setFailoverOnInitialConnection(boolean failoverOnInitialConnection); /** - * @see org.hornetq.api.core.client.ClientSessionFactory#getProducerWindowSize() + * @see org.hornetq.api.core.client.ServerLocator#getProducerWindowSize() */ int getProducerWindowSize(); /** - * @see ClientSessionFactory#setProducerWindowSize(int) + * @see ServerLocator#setProducerWindowSize(int) */ void setProducerWindowSize(int producerWindowSize); /** - * @see ClientSessionFactory#isCacheLargeMessagesClient() + * @see ServerLocator#isCacheLargeMessagesClient() */ boolean isCacheLargeMessagesClient(); /** - * @see ClientSessionFactory#setCacheLargeMessagesClient(boolean) + * @see ServerLocator#setCacheLargeMessagesClient(boolean) */ void setCacheLargeMessagesClient(boolean cacheLargeMessagesClient); /** - * @see ClientSessionFactory#getMaxRetryInterval() + * @see ServerLocator#getMaxRetryInterval() */ long getMaxRetryInterval(); /** - * @see ClientSessionFactory#setMaxRetryInterval(long) + * @see ServerLocator#setMaxRetryInterval(long) */ void setMaxRetryInterval(long retryInterval); /** - * @see ClientSessionFactory#getScheduledThreadPoolMaxSize() + * @see ServerLocator#getScheduledThreadPoolMaxSize() */ int getScheduledThreadPoolMaxSize(); /** - * @see ClientSessionFactory#setScheduledThreadPoolMaxSize(int) + * @see ServerLocator#setScheduledThreadPoolMaxSize(int) */ void setScheduledThreadPoolMaxSize(int scheduledThreadPoolMaxSize); /** - * @see ClientSessionFactory#getThreadPoolMaxSize() + * @see ServerLocator#getThreadPoolMaxSize() */ int getThreadPoolMaxSize(); /** - * @see ClientSessionFactory#setThreadPoolMaxSize(int) + * @see ServerLocator#setThreadPoolMaxSize(int) */ void setThreadPoolMaxSize(int threadPoolMaxSize); /** - * @see ClientSessionFactory#getGroupID() + * @see ServerLocator#getGroupID() */ String getGroupID(); /** - * @see ClientSessionFactory#setGroupID(String) + * @see ServerLocator#setGroupID(String) */ void setGroupID(String groupID); /** - * @see ClientSessionFactory#getInitialMessagePacketSize() + * @see ServerLocator#getInitialMessagePacketSize() */ int getInitialMessagePacketSize(); /** - * @see ClientSessionFactory#isUseGlobalPools() + * @see ServerLocator#isUseGlobalPools() */ boolean isUseGlobalPools(); /** - * @see ClientSessionFactory#setUseGlobalPools(boolean) + * @see ServerLocator#setUseGlobalPools(boolean) */ void setUseGlobalPools(boolean useGlobalPools); /** - * @see ClientSessionFactory#getConnectionLoadBalancingPolicyClassName() + * @see ServerLocator#getConnectionLoadBalancingPolicyClassName() */ String getConnectionLoadBalancingPolicyClassName(); /** - * @see ClientSessionFactory#setConnectionLoadBalancingPolicyClassName(String) + * @see ServerLocator#setConnectionLoadBalancingPolicyClassName(String) */ void setConnectionLoadBalancingPolicyClassName(String connectionLoadBalancingPolicyClassName); Modified: trunk/hornetq-jms/src/main/java/org/hornetq/jms/client/HornetQConnectionFactory.java =================================================================== --- trunk/hornetq-jms/src/main/java/org/hornetq/jms/client/HornetQConnectionFactory.java 2012-01-23 12:01:08 UTC (rev 12044) +++ trunk/hornetq-jms/src/main/java/org/hornetq/jms/client/HornetQConnectionFactory.java 2012-01-23 12:01:43 UTC (rev 12045) @@ -552,10 +552,9 @@ { return JMSFactoryType.CF.intValue(); } + /** - * * @deprecated use {@link ServerLocator#createSessionFactory()} - * @return */ @Deprecated public ClientSessionFactory getCoreFactory() throws JMSException