updated the javadoc of the connection & factory classes to match the documentation on the wiki http://incubator.apache.org/activemq/connection-configuration-uri.html

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@418970 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
James Strachan 2006-07-04 10:28:25 +00:00
parent db39e50583
commit 4b08ea5c04
2 changed files with 88 additions and 22 deletions

View File

@ -760,10 +760,8 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
} }
/** /**
* Sets whether or not timestamps on messages should be disabled or not. If you disable them it adds a small performance boost. * Sets whether or not timestamps on messages should be disabled or not. If
* * you disable them it adds a small performance boost.
* @param timeStampsDisableByDefault
* The timeStampsDisableByDefault to set.
*/ */
public void setDisableTimeStampsByDefault(boolean timeStampsDisableByDefault) { public void setDisableTimeStampsByDefault(boolean timeStampsDisableByDefault) {
this.disableTimeStampsByDefault = timeStampsDisableByDefault; this.disableTimeStampsByDefault = timeStampsDisableByDefault;
@ -778,9 +776,8 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
} }
/** /**
* * If this flag is set then an larger prefetch limit is used - only
* @param dispatchOptimizedMessage * applicable for durable topic subscribers.
* The dispatchOptimizedMessage to set.
*/ */
public void setOptimizedMessageDispatch(boolean dispatchOptimizedMessage) { public void setOptimizedMessageDispatch(boolean dispatchOptimizedMessage) {
this.optimizedMessageDispatch = dispatchOptimizedMessage; this.optimizedMessageDispatch = dispatchOptimizedMessage;
@ -799,9 +796,6 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
* close() on a connection waits for confirmation from the broker; this * close() on a connection waits for confirmation from the broker; this
* allows that operation to timeout to save the client hanging if there is * allows that operation to timeout to save the client hanging if there is
* no broker * no broker
*
* @param closeTimeout
* The closeTimeout to set.
*/ */
public void setCloseTimeout(int closeTimeout){ public void setCloseTimeout(int closeTimeout){
this.closeTimeout=closeTimeout; this.closeTimeout=closeTimeout;
@ -833,7 +827,10 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
} }
/** /**
* Enables/disables whether or not Message properties and MapMessage entries support nested Map and List objects * Enables/disables whether or not Message properties and MapMessage entries
* support <a
* href="http://incubator.apache.org/activemq/structured-message-properties-and-mapmessages.html">Nested
* Structures</a> of Map and List objects
*/ */
public void setNestedMapAndListEnabled(boolean structuredMapsEnabled) { public void setNestedMapAndListEnabled(boolean structuredMapsEnabled) {
this.nestedMapAndListEnabled = structuredMapsEnabled; this.nestedMapAndListEnabled = structuredMapsEnabled;
@ -1237,8 +1234,11 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
} }
/** /**
* @param useAsyncSend * Forces the use of <a
* The useAsyncSend to set. * href="http://incubator.apache.org/activemq/async-sends.html">Async Sends</a>
* which adds a massive performance boost; but means that the send() method
* will return immediately whether the message has been sent or not which
* could lead to message loss.
*/ */
public void setUseAsyncSend(boolean useAsyncSend) { public void setUseAsyncSend(boolean useAsyncSend) {
this.useAsyncSend = useAsyncSend; this.useAsyncSend = useAsyncSend;
@ -1363,9 +1363,6 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
* messages for each Session in the Connection. However, a separate thread * messages for each Session in the Connection. However, a separate thread
* is always used if there is more than one session, or the session isn't in * is always used if there is more than one session, or the session isn't in
* auto acknowledge or duplicates ok mode * auto acknowledge or duplicates ok mode
*
* @param alwaysSessionAsync
* The alwaysSessionAsync to set.
*/ */
public void setAlwaysSessionAsync(boolean alwaysSessionAsync) { public void setAlwaysSessionAsync(boolean alwaysSessionAsync) {
this.alwaysSessionAsync = alwaysSessionAsync; this.alwaysSessionAsync = alwaysSessionAsync;
@ -1589,8 +1586,6 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
/** /**
* Enables the use of compression of the message bodies * Enables the use of compression of the message bodies
*
* @param useCompression
*/ */
public void setUseCompression(boolean useCompression) { public void setUseCompression(boolean useCompression) {
this.useCompression = useCompression; this.useCompression = useCompression;
@ -1638,6 +1633,12 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
return objectMessageSerializationDefered; return objectMessageSerializationDefered;
} }
/**
* When an object is set on an ObjectMessage, the JMS spec requires the
* object to be serialized by that set method. Enabling this flag causes the
* object to not get serialized. The object may subsequently get serialized
* if the message needs to be sent over a socket or stored to disk.
*/
public void setObjectMessageSerializationDefered(boolean objectMessageSerializationDefered) { public void setObjectMessageSerializationDefered(boolean objectMessageSerializationDefered) {
this.objectMessageSerializationDefered = objectMessageSerializationDefered; this.objectMessageSerializationDefered = objectMessageSerializationDefered;
} }
@ -1848,8 +1849,6 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
* send() method in JMS. This is enabled by default to be compliant with the * send() method in JMS. This is enabled by default to be compliant with the
* JMS specification. You can disable it if you do not mutate JMS messages * JMS specification. You can disable it if you do not mutate JMS messages
* after they are sent for a performance boost * after they are sent for a performance boost
*
* @param copyMessageOnSend
*/ */
public void setCopyMessageOnSend(boolean copyMessageOnSend) { public void setCopyMessageOnSend(boolean copyMessageOnSend) {
this.copyMessageOnSend = copyMessageOnSend; this.copyMessageOnSend = copyMessageOnSend;

View File

@ -80,6 +80,7 @@ public class ActiveMQConnectionFactory extends JNDIBaseStorable implements Conne
private boolean optimizeAcknowledge = false; private boolean optimizeAcknowledge = false;
private int closeTimeout = 15000; private int closeTimeout = 15000;
private boolean useRetroactiveConsumer; private boolean useRetroactiveConsumer;
private boolean nestedMapAndListEnabled = true;
JMSStatsImpl factoryStats = new JMSStatsImpl(); JMSStatsImpl factoryStats = new JMSStatsImpl();
@ -263,6 +264,12 @@ public class ActiveMQConnectionFactory extends JNDIBaseStorable implements Conne
public String getBrokerURL() { public String getBrokerURL() {
return brokerURL==null?null:brokerURL.toString(); return brokerURL==null?null:brokerURL.toString();
} }
/**
* Sets the <a
* href="http://incubator.apache.org/activemq/configuring-transports.html">connection
* URL</a> used to connect to the ActiveMQ broker.
*/
public void setBrokerURL(String brokerURL) { public void setBrokerURL(String brokerURL) {
this.brokerURL = createURI(brokerURL); this.brokerURL = createURI(brokerURL);
@ -297,6 +304,10 @@ public class ActiveMQConnectionFactory extends JNDIBaseStorable implements Conne
return clientID; return clientID;
} }
/**
* Sets the JMS clientID to use for the created connection. Note that this can only be used by one connection at once so generally its a better idea
* to set the clientID on a Connection
*/
public void setClientID(String clientID) { public void setClientID(String clientID) {
this.clientID = clientID; this.clientID = clientID;
} }
@ -305,6 +316,12 @@ public class ActiveMQConnectionFactory extends JNDIBaseStorable implements Conne
return copyMessageOnSend; return copyMessageOnSend;
} }
/**
* Should a JMS message be copied to a new JMS Message object as part of the
* send() method in JMS. This is enabled by default to be compliant with the
* JMS specification. You can disable it if you do not mutate JMS messages
* after they are sent for a performance boost
*/
public void setCopyMessageOnSend(boolean copyMessageOnSend) { public void setCopyMessageOnSend(boolean copyMessageOnSend) {
this.copyMessageOnSend = copyMessageOnSend; this.copyMessageOnSend = copyMessageOnSend;
} }
@ -313,6 +330,10 @@ public class ActiveMQConnectionFactory extends JNDIBaseStorable implements Conne
return disableTimeStampsByDefault; return disableTimeStampsByDefault;
} }
/**
* Sets whether or not timestamps on messages should be disabled or not. If
* you disable them it adds a small performance boost.
*/
public void setDisableTimeStampsByDefault(boolean disableTimeStampsByDefault) { public void setDisableTimeStampsByDefault(boolean disableTimeStampsByDefault) {
this.disableTimeStampsByDefault = disableTimeStampsByDefault; this.disableTimeStampsByDefault = disableTimeStampsByDefault;
} }
@ -321,6 +342,10 @@ public class ActiveMQConnectionFactory extends JNDIBaseStorable implements Conne
return optimizedMessageDispatch; return optimizedMessageDispatch;
} }
/**
* If this flag is set then an larger prefetch limit is used - only
* applicable for durable topic subscribers.
*/
public void setOptimizedMessageDispatch(boolean optimizedMessageDispatch) { public void setOptimizedMessageDispatch(boolean optimizedMessageDispatch) {
this.optimizedMessageDispatch = optimizedMessageDispatch; this.optimizedMessageDispatch = optimizedMessageDispatch;
} }
@ -329,6 +354,9 @@ public class ActiveMQConnectionFactory extends JNDIBaseStorable implements Conne
return password; return password;
} }
/**
* Sets the JMS password used for connections created from this factory
*/
public void setPassword(String password) { public void setPassword(String password) {
this.password = password; this.password = password;
} }
@ -350,6 +378,13 @@ public class ActiveMQConnectionFactory extends JNDIBaseStorable implements Conne
return useAsyncSend; return useAsyncSend;
} }
/**
* Forces the use of <a
* href="http://incubator.apache.org/activemq/async-sends.html">Async Sends</a>
* which adds a massive performance boost; but means that the send() method
* will return immediately whether the message has been sent or not which
* could lead to message loss.
*/
public void setUseAsyncSend(boolean useAsyncSend) { public void setUseAsyncSend(boolean useAsyncSend) {
this.useAsyncSend = useAsyncSend; this.useAsyncSend = useAsyncSend;
} }
@ -358,6 +393,9 @@ public class ActiveMQConnectionFactory extends JNDIBaseStorable implements Conne
return userName; return userName;
} }
/**
* Sets the JMS userName used by connections created by this factory
*/
public void setUserName(String userName) { public void setUserName(String userName) {
this.userName = userName; this.userName = userName;
} }
@ -465,6 +503,9 @@ public class ActiveMQConnectionFactory extends JNDIBaseStorable implements Conne
return useCompression; return useCompression;
} }
/**
* Enables the use of compression of the message bodies
*/
public void setUseCompression(boolean useCompression) { public void setUseCompression(boolean useCompression) {
this.useCompression = useCompression; this.useCompression = useCompression;
} }
@ -473,6 +514,12 @@ public class ActiveMQConnectionFactory extends JNDIBaseStorable implements Conne
return objectMessageSerializationDefered; return objectMessageSerializationDefered;
} }
/**
* When an object is set on an ObjectMessage, the JMS spec requires the
* object to be serialized by that set method. Enabling this flag causes the
* object to not get serialized. The object may subsequently get serialized
* if the message needs to be sent over a socket or stored to disk.
*/
public void setObjectMessageSerializationDefered(boolean objectMessageSerializationDefered) { public void setObjectMessageSerializationDefered(boolean objectMessageSerializationDefered) {
this.objectMessageSerializationDefered = objectMessageSerializationDefered; this.objectMessageSerializationDefered = objectMessageSerializationDefered;
} }
@ -509,7 +556,10 @@ public class ActiveMQConnectionFactory extends JNDIBaseStorable implements Conne
} }
/** /**
* @param closeTimeout The closeTimeout to set. * Sets the timeout before a close is considered complete. Normally a
* close() on a connection waits for confirmation from the broker; this
* allows that operation to timeout to save the client hanging if there is
* no broker
*/ */
public void setCloseTimeout(int closeTimeout){ public void setCloseTimeout(int closeTimeout){
this.closeTimeout=closeTimeout; this.closeTimeout=closeTimeout;
@ -523,7 +573,10 @@ public class ActiveMQConnectionFactory extends JNDIBaseStorable implements Conne
} }
/** /**
* @param alwaysSessionAsync The alwaysSessionAsync to set. * If this flag is set then a separate thread is not used for dispatching
* messages for each Session in the Connection. However, a separate thread
* is always used if there is more than one session, or the session isn't in
* auto acknowledge or duplicates ok mode
*/ */
public void setAlwaysSessionAsync(boolean alwaysSessionAsync){ public void setAlwaysSessionAsync(boolean alwaysSessionAsync){
this.alwaysSessionAsync=alwaysSessionAsync; this.alwaysSessionAsync=alwaysSessionAsync;
@ -542,4 +595,18 @@ public class ActiveMQConnectionFactory extends JNDIBaseStorable implements Conne
public void setOptimizeAcknowledge(boolean optimizeAcknowledge){ public void setOptimizeAcknowledge(boolean optimizeAcknowledge){
this.optimizeAcknowledge=optimizeAcknowledge; this.optimizeAcknowledge=optimizeAcknowledge;
} }
public boolean isNestedMapAndListEnabled() {
return nestedMapAndListEnabled ;
}
/**
* Enables/disables whether or not Message properties and MapMessage entries
* support <a
* href="http://incubator.apache.org/activemq/structured-message-properties-and-mapmessages.html">Nested
* Structures</a> of Map and List objects
*/
public void setNestedMapAndListEnabled(boolean structuredMapsEnabled) {
this.nestedMapAndListEnabled = structuredMapsEnabled;
}
} }