+ * If the session responsible to acknowledge this message has {@code au=
toCommitAcks} set to
+ * {@code true}, the transaction will automatically commit the current =
transaction. Otherwise,
+ * this acknowledgement will not be committed until the client commits =
the session transaction.
+ * @throws HornetQException if an error occurred while acknowledging th=
e message.
* @see ClientSession#isAutoCommitAcks()
*/
void acknowledge() throws HornetQException;
@@ -61,20 +59,20 @@
*/
int getBodySize();
=
- /** =
+ /**
* Sets the OutputStream that will receive the content of a message rec=
eived in a non blocking way.
- *
=
+ *
* This method is used when consuming large messages
- * =
+ *
* @throws HornetQException
*/
void setOutputStream(OutputStream out) throws HornetQException;
=
- /** =
+ /**
* Saves the content of the message to the OutputStream.
* It will block until the entire content is transfered to the OutputSt=
ream.
- *
=
- * =
+ *
+ *
* @throws HornetQException
*/
void saveToOutputStream(OutputStream out) throws HornetQException;
@@ -83,18 +81,18 @@
* Wait the outputStream completion of the message.
*
* This method is used when consuming large messages
- * =
+ *
* @param timeMilliseconds - 0 means wait forever
* @return true if it reached the end
* @throws HornetQException
*/
boolean waitOutputStreamCompletion(long timeMilliseconds) throws Hornet=
QException;
=
- /** =
- * Sets the body's IntputStream. =
- *
=
+ /**
+ * Sets the body's IntputStream.
+ *
* This method is used when sending large messages
- * =
+ *
* @throws HornetQException
*/
void setBodyInputStream(InputStream bodyInputStream);
Modified: branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/h=
ornetq/api/core/client/SendAcknowledgementHandler.java
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D
--- branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq=
/api/core/client/SendAcknowledgementHandler.java 2011-07-05 14:00:57 UTC (r=
ev 10916)
+++ branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq=
/api/core/client/SendAcknowledgementHandler.java 2011-07-05 14:08:46 UTC (r=
ev 10917)
@@ -16,20 +16,20 @@
import org.hornetq.api.core.Message;
=
/**
- * A SendAcknowledgementHandler notifies a client when an message sent asy=
nchronously has been received by the server.
- *
- * If the session is not blocking when sending durable or non-durable mess=
ages, the session can
- * set a SendAcknowledgementHandler to be notified later when the messages
- * has been received by the server. The method {@code sendAcknowledged} wi=
ll be called with the message that
- * was sent asynchronously.
- *
+ * A SendAcknowledgementHandler notifies a client when an message sent asy=
nchronously has been
+ * received by the server.
+ *
+ * If the session is not blocking when sending durable or non-durable mess=
ages, the session can set
+ * a SendAcknowledgementHandler to be notified later when the messages has=
been received by the
+ * server. The method {@link #sendAcknowledged(Message)} will be called wi=
th the message that was
+ * sent asynchronously.
* @author Tim Fox
*/
public interface SendAcknowledgementHandler
{
/**
* Notifies the client that a message sent asynchronously has been rece=
ived by the server.
- * =
+ *
* @param message message sent asynchronously
*/
void sendAcknowledged(Message message);
Modified: branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/h=
ornetq/api/core/client/ServerLocator.java
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D
--- branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq=
/api/core/client/ServerLocator.java 2011-07-05 14:00:57 UTC (rev 10916)
+++ branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq=
/api/core/client/ServerLocator.java 2011-07-05 14:08:46 UTC (rev 10917)
@@ -31,19 +31,19 @@
* This method will disable any checks when a GarbageCollection happens
* leaving connections open. The JMS Layer will make specific usage of th=
is
* method, since the ConnectionFactory.finalize should release this.
- * =
+ *
* Warning: You may leave resources unattended if you call this method and
* don't take care of cleaning the resources yourself.
*/
void disableFinalizeCheck();
- =
+
/**
* Create a ClientSessionFactory using whatever load balancing policy i=
s in force
* @return The ClientSessionFactory
* @throws Exception
*/
ClientSessionFactory createSessionFactory() throws Exception;
- =
+
/**
* Create a ClientSessionFactory to a specific server. The server must =
already be known about by this ServerLocator.
* This method allows the user to make a connection to a specific serve=
r bypassing any load balancing policy in force
@@ -52,39 +52,39 @@
* @throws Exception if a failure happened in creating the ClientSessio=
nFactory or the ServerLocator does not know about the passed in transportCo=
nfiguration
*/
ClientSessionFactory createSessionFactory(final TransportConfiguration =
transportConfiguration) throws Exception;
- =
+
/**
* Returns the period used to check if a client has failed to receive p=
ings from the server.
- * =
+ *
* Period is in milliseconds, default value is {@link HornetQClient#DEF=
AULT_CLIENT_FAILURE_CHECK_PERIOD}.
- * =
+ *
* @return the period used to check if a client has failed to receive p=
ings from the server
*/
long getClientFailureCheckPeriod();
=
/**
* Sets the period (in milliseconds) used to check if a client has fail=
ed to receive pings from the server.
- * =
+ *
* Value must be -1 (to disable) or greater than 0.
- * =
+ *
* @param clientFailureCheckPeriod the period to check failure
*/
void setClientFailureCheckPeriod(long clientFailureCheckPeriod);
=
/**
* When
* This annotation is used only for methods which can be invoked
* through a GUI.
* =
Modified: branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/h=
ornetq/core/client/impl/ClientConsumerImpl.java
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D
--- branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq=
/core/client/impl/ClientConsumerImpl.java 2011-07-05 14:00:57 UTC (rev 1091=
6)
+++ branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq=
/core/client/impl/ClientConsumerImpl.java 2011-07-05 14:08:46 UTC (rev 1091=
7)
@@ -17,7 +17,6 @@
import java.util.Iterator;
import java.util.concurrent.Executor;
=
-import org.hornetq.api.core.HornetQBuffers;
import org.hornetq.api.core.HornetQException;
import org.hornetq.api.core.SimpleString;
import org.hornetq.api.core.client.ClientMessage;
--===============5441471121241767313==--
true, consumers created through this factory will =
create temporary files to cache large messages.
- * =
+ *
* There is 1 temporary file created for each large message.
- * =
+ *
* Default value is {@link HornetQClient#DEFAULT_CACHE_LARGE_MESSAGE_CL=
IENT}.
- * =
+ *
* @return true if consumers created through this factory =
will cache large messages in temporary files, false else
*/
boolean isCacheLargeMessagesClient();
=
/**
* Sets whether large messages received by consumers created through th=
is factory will be cached in temporary files or not.
- * =
+ *
* @param cached true to cache large messages in temporary=
files, false else
*/
void setCacheLargeMessagesClient(boolean cached);
@@ -92,73 +92,73 @@
/**
* Returns the connection time-to-live.
* This TTL determines how long the server will keep a connection alive=
in the absence of any data arriving from the client.
- * =
+ *
* Value is in milliseconds, default value is {@link HornetQClient#DEFA=
ULT_CONNECTION_TTL}.
- * =
+ *
* @return the connection time-to-live in milliseconds
*/
long getConnectionTTL();
=
/**
* Sets this factory's connections time-to-live.
- * =
+ *
* Value must be -1 (to disable) or greater or equals to 0.
- * =
+ *
* @param connectionTTL period in milliseconds
*/
void setConnectionTTL(long connectionTTL);
=
/**
* Returns the blocking calls timeout.
- * =
+ *
* If client's blocking calls to the server take more than this timeout=
, the call will throw a {@link HornetQException} with the code {@link Horne=
tQException#CONNECTION_TIMEDOUT}.
* Value is in milliseconds, default value is {@link HornetQClient#DEFA=
ULT_CALL_TIMEOUT}.
- * =
+ *
* @return the blocking calls timeout
*/
long getCallTimeout();
=
/**
* Sets the blocking call timeout.
- * =
+ *
* Value must be greater or equals to 0
- * =
+ *
* @param callTimeout blocking call timeout in milliseconds
*/
void setCallTimeout(long callTimeout);
=
/**
* Returns the large message size threshold.
- * =
+ *
* Messages whose size is if greater than this value will be handled as=
large messages.
- * =
+ *
* Value is in bytes, default value is {@link HornetQClient#DEFAULT_MIN=
_LARGE_MESSAGE_SIZE}.
- * =
+ *
* @return the message size threshold to treat messages as large messag=
es.
*/
int getMinLargeMessageSize();
=
/**
* Sets the large message size threshold.
- * =
+ *
* Value must be greater than 0.
- * =
+ *
* @param minLargeMessageSize large message size threshold in bytes
*/
void setMinLargeMessageSize(int minLargeMessageSize);
=
/**
* Returns the window size for flow control of the consumers created th=
rough this factory.
- * =
+ *
* Value is in bytes, default value is {@link HornetQClient#DEFAULT_CON=
SUMER_WINDOW_SIZE}.
- * =
+ *
* @return the window size used for consumer flow control
*/
int getConsumerWindowSize();
=
/**
* Sets the window size for flow control of the consumers created throu=
gh this factory.
- * =
+ *
* Value must be -1 (to disable flow control), 0 (to not buffer any mes=
sages) or greater than 0 (to set the maximum size of the buffer)
*
* @param consumerWindowSize window size (in bytes) used for consumer f=
low control
@@ -167,37 +167,37 @@
=
/**
* Returns the maximum rate of message consumption for consumers create=
d through this factory.
- * =
+ *
* This value controls the rate at which a consumer can consume message=
s. A consumer will never consume messages at a rate faster than the rate sp=
ecified.
- * =
+ *
* Value is -1 (to disable) or a positive integer corresponding to the =
maximum desired message consumption rate specified in units of messages per=
second.
* Default value is {@link HornetQClient#DEFAULT_CONSUMER_MAX_RATE}.
- * =
+ *
* @return the consumer max rate
*/
int getConsumerMaxRate();
=
/**
* Sets the maximum rate of message consumption for consumers created t=
hrough this factory.
- * =
+ *
* Value must -1 (to disable) or a positive integer corresponding to th=
e maximum desired message consumption rate specified in units of messages p=
er second.
- * =
+ *
* @param consumerMaxRate maximum rate of message consumption (in messa=
ges per seconds)
*/
void setConsumerMaxRate(int consumerMaxRate);
=
/**
* Returns the size for the confirmation window of clients using this f=
actory.
- * =
+ *
* Value is in bytes or -1 (to disable the window). Default value is {@=
link HornetQClient#DEFAULT_CONFIRMATION_WINDOW_SIZE}.
- * =
+ *
* @return the size for the confirmation window of clients using this f=
actory
*/
int getConfirmationWindowSize();
=
/**
* Sets the size for the confirmation window buffer of clients using th=
is factory.
- * =
+ *
* Value must be -1 (to disable the window) or greater than 0.
=
* @param confirmationWindowSize size of the confirmation window (in by=
tes)
@@ -206,40 +206,39 @@
=
/**
* Returns the window size for flow control of the producers created th=
rough this factory.
- * =
+ *
* Value must be -1 (to disable flow control) or greater than 0 to dete=
rmine the maximum amount of bytes at any give time (to prevent overloading =
the connection).
* Default value is {@link HornetQClient#DEFAULT_PRODUCER_WINDOW_SIZE}.
- * =
+ *
* @return the window size for flow control of the producers created th=
rough this factory.
*/
int getProducerWindowSize();
=
/**
- * Returns the window size for flow control of the producers created th=
rough this factory.
- * =
- * Value must be -1 (to disable flow control) or greater than 0.
- * =
- * @param producerWindowSize window size (in bytest) for flow control o=
f the producers created through this factory.
+ * Returns the window size for flow control of the producers created th=
rough this factory. Value
+ * must be -1 (to disable flow control) or greater than 0.
+ * @param producerWindowSize window size (in bytes) for flow control of=
the producers created
+ * through this factory.
*/
void setProducerWindowSize(int producerWindowSize);
=
/**
* Returns the maximum rate of message production for producers created=
through this factory.
- * =
+ *
* This value controls the rate at which a producer can produce message=
s. A producer will never produce messages at a rate faster than the rate sp=
ecified.
- * =
+ *
* Value is -1 (to disable) or a positive integer corresponding to the =
maximum desired message production rate specified in units of messages per =
second.
* Default value is {@link HornetQClient#DEFAULT_PRODUCER_MAX_RATE}.
- * =
+ *
* @return maximum rate of message production (in messages per seconds)
*/
int getProducerMaxRate();
=
/**
* Sets the maximum rate of message production for producers created th=
rough this factory.
- * =
+ *
* Value must -1 (to disable) or a positive integer corresponding to th=
e maximum desired message production rate specified in units of messages pe=
r second.
- * =
+ *
* @param producerMaxRate maximum rate of message production (in messag=
es per seconds)
*/
void setProducerMaxRate(int producerMaxRate);
@@ -247,9 +246,9 @@
/**
* Returns whether consumers created through this factory will block while
* sending message acknowledgments or do it asynchronously.
- * =
+ *
* Default value is {@link HornetQClient#DEFAULT_BLOCK_ON_ACKNOWLEDGE}.
- * =
+ *
* @return whether consumers will block while sending message
* acknowledgments or do it asynchronously
*/
@@ -258,7 +257,7 @@
/**
* Sets whether consumers created through this factory will block while
* sending message acknowledgments or do it asynchronously.
- * =
+ *
* @param blockOnAcknowledge
* true to block when sending message
* acknowledgments or false to send them
@@ -271,7 +270,7 @@
*
* If the session is configured to send durable message asynchronously,=
the client can set a SendAcknowledgementHandler on the ClientSession
* to be notified once the message has been handled by the server.
- * =
+ *
* Default value is {@link HornetQClient#DEFAULT_BLOCK_ON_DURABLE_SEND}.
*
* @return whether producers will block while sending persistent messag=
es or do it asynchronously
@@ -280,7 +279,7 @@
=
/**
* Sets whether producers created through this factory will block while=
sending durable messages or do it asynchronously.
- * =
+ *
* @param blockOnDurableSend true to block when sending du=
rable messages or false to send them asynchronously
*/
void setBlockOnDurableSend(boolean blockOnDurableSend);
@@ -290,7 +289,7 @@
*
* If the session is configured to send non-durable message asynchronou=
sly, the client can set a SendAcknowledgementHandler on the ClientSession
* to be notified once the message has been handled by the server.
- * =
+ *
* Default value is {@link HornetQClient#DEFAULT_BLOCK_ON_NON_DURABLE_S=
END}.
*
* @return whether producers will block while sending non-durable messa=
ges or do it asynchronously
@@ -299,7 +298,7 @@
=
/**
* Sets whether producers created through this factory will block while=
sending non-durable messages or do it asynchronously.
- * =
+ *
* @param blockOnNonDurableSend true to block when sending=
non-durable messages or false to send them asynchronously
*/
void setBlockOnNonDurableSend(boolean blockOnNonDurableSend);
@@ -307,11 +306,11 @@
/**
* Returns whether producers created through this factory will automati=
cally
* assign a group ID to the messages they sent.
- * =
+ *
* if true, a random unique group ID is created and set on=
each message for the property
* {@link org.hornetq.api.core.Message#HDR_GROUP_ID}.
* Default value is {@link HornetQClient#DEFAULT_AUTO_GROUP}.
- * =
+ *
* @return whether producers will automatically assign a group ID to th=
eir messages
*/
boolean isAutoGroup();
@@ -319,23 +318,23 @@
/**
* Sets whether producers created through this factory will automatical=
ly
* assign a group ID to the messages they sent.
- * =
+ *
* @param autoGroup true to automatically assign a group I=
D to each messages sent through this factory, false else
*/
void setAutoGroup(boolean autoGroup);
=
/**
* Returns the group ID that will be eventually set on each message for=
the property {@link org.hornetq.api.core.Message#HDR_GROUP_ID}.
- * =
+ *
* Default value is is null and no group ID will be set on=
the messages.
- * =
+ *
* @return the group ID that will be eventually set on each message
*/
String getGroupID();
- =
+
/**
* Sets the group ID that will be set on each message sent through thi=
s factory.
- * =
+ *
* @param groupID the group ID to use
*/
void setGroupID(String groupID);
@@ -351,7 +350,7 @@
* Sets to true to pre-acknowledge consumed messages on the
* server before they are sent to consumers, else set to false
* to let clients acknowledge the message they consume.
- * =
+ *
* @param preAcknowledge
* true to enable pre-acknowledgment,
* false else
@@ -360,18 +359,18 @@
=
/**
* Returns the acknowledgments batch size.
- * =
+ *
* Default value is {@link HornetQClient#DEFAULT_ACK_BATCH_SIZE}.
- * =
+ *
* @return the acknowledgments batch size
*/
int getAckBatchSize();
=
/**
* Sets the acknowledgments batch size.
- * =
+ *
* Value must be equal or greater than 0.
- * =
+ *
* @param ackBatchSize
* acknowledgments batch size
*/
@@ -392,9 +391,9 @@
/**
* Returns whether this factory will use global thread pools (shared am=
ong all the factories in the same JVM)
* or its own pools.
- * =
+ *
* Default value is {@link HornetQClient#DEFAULT_USE_GLOBAL_POOLS}.
- * =
+ *
* @return true if this factory uses global thread pools, =
false else
*/
boolean isUseGlobalPools();
@@ -402,117 +401,117 @@
/**
* Sets whether this factory will use global thread pools (shared among=
all the factories in the same JVM)
* or its own pools.
- * =
+ *
* @param useGlobalPools true to let this factory uses glo=
bal thread pools, false else
*/
void setUseGlobalPools(boolean useGlobalPools);
=
/**
* Returns the maximum size of the scheduled thread pool.
- * =
+ *
* Default value is {@link HornetQClient#DEFAULT_SCHEDULED_THREAD_POOL_=
MAX_SIZE}.
- * =
+ *
* @return the maximum size of the scheduled thread pool.
*/
int getScheduledThreadPoolMaxSize();
=
/**
* Sets the maximum size of the scheduled thread pool.
- * =
+ *
* This setting is relevant only if this factory does not use global po=
ols.
* Value must be greater than 0.
- * =
+ *
* @param scheduledThreadPoolMaxSize maximum size of the scheduled thr=
ead pool.
*/
void setScheduledThreadPoolMaxSize(int scheduledThreadPoolMaxSize);
=
/**
* Returns the maximum size of the thread pool.
- * =
+ *
* Default value is {@link HornetQClient#DEFAULT_THREAD_POOL_MAX_SIZE}.
- * =
+ *
* @return the maximum size of the thread pool.
*/
int getThreadPoolMaxSize();
=
/**
* Sets the maximum size of the thread pool.
- * =
+ *
* This setting is relevant only if this factory does not use global po=
ols.
* Value must be -1 (for unlimited thread pool) or greater than 0.
- * =
+ *
* @param threadPoolMaxSize maximum size of the thread pool.
*/
void setThreadPoolMaxSize(int threadPoolMaxSize);
=
/**
- * Returns the time to retry connections created by this factory after =
failure. =
- * =
+ * Returns the time to retry connections created by this factory after =
failure.
+ *
* Value is in milliseconds, default is {@link HornetQClient#DEFAULT_RE=
TRY_INTERVAL}.
- * =
+ *
* @return the time to retry connections created by this factory after =
failure
*/
long getRetryInterval();
=
/**
* Sets the time to retry connections created by this factory after fai=
lure.
- * =
+ *
* Value must be greater than 0.
- * =
- * @param retryInterval time (in milliseconds) to retry connections cre=
ated by this factory after failure =
+ *
+ * @param retryInterval time (in milliseconds) to retry connections cre=
ated by this factory after failure
*/
void setRetryInterval(long retryInterval);
=
/**
* Returns the multiplier to apply to successive retry intervals.
- * =
+ *
* Default value is {@link HornetQClient#DEFAULT_RETRY_INTERVAL_MULTIP=
LIER}.
- * =
+ *
* @return the multiplier to apply to successive retry intervals
*/
double getRetryIntervalMultiplier();
=
/**
* Sets the multiplier to apply to successive retry intervals.
- * =
+ *
* Value must be positive.
- * =
+ *
* @param retryIntervalMultiplier multiplier to apply to successive ret=
ry intervals
*/
void setRetryIntervalMultiplier(double retryIntervalMultiplier);
=
/**
* Returns the maximum retry interval (in the case a retry interval mul=
tiplier has been specified).
- * =
+ *
* Value is in milliseconds, default value is {@link HornetQClient#DEF=
AULT_MAX_RETRY_INTERVAL}.
- * =
+ *
* @return the maximum retry interval
*/
long getMaxRetryInterval();
=
/**
* Sets the maximum retry interval.
- * =
+ *
* Value must be greater than 0.
- * =
+ *
* @param maxRetryInterval maximum retry interval to apply in the case =
a retry interval multiplier has been specified
*/
void setMaxRetryInterval(long maxRetryInterval);
=
/**
* Returns the maximum number of attempts to retry connection in case o=
f failure.
- * =
+ *
* Default value is {@link HornetQClient#DEFAULT_RECONNECT_ATTEMPTS}.
- * =
+ *
* @return the maximum number of attempts to retry connection in case o=
f failure.
*/
int getReconnectAttempts();
=
/**
* Sets the maximum number of attempts to retry connection in case of f=
ailure.
- * =
+ *
* Value must be -1 (to retry infinitely), 0 (to never retry connection=
) or greater than 0.
- * =
+ *
* @param reconnectAttempts maximum number of attempts to retry connect=
ion in case of failure
*/
void setReconnectAttempts(int reconnectAttempts);
@@ -523,66 +522,66 @@
/**
* Returns true if the client will automatically attempt to connect to =
the backup server if the initial
* connection to the live server fails
- * =
+ *
* Default value is {@link HornetQClient#DEFAULT_FAILOVER_ON_INITIAL_CO=
NNECTION}.
*/
boolean isFailoverOnInitialConnection();
- =
+
/**
* Sets the value for FailoverOnInitialReconnection
- * =
+ *
* @param failover
*/
void setFailoverOnInitialConnection(boolean failover);
=
/**
* Returns the class name of the connection load balancing policy.
- * =
+ *
* Default value is "org.hornetq.api.core.client.loadbalance.RoundRobin=
ConnectionLoadBalancingPolicy".
- * =
+ *
* @return the class name of the connection load balancing policy
*/
String getConnectionLoadBalancingPolicyClassName();
=
/**
* Sets the class name of the connection load balancing policy.
- * =
+ *
* Value must be the name of a class implementing {@link ConnectionLoad=
BalancingPolicy}.
- * =
+ *
* @param loadBalancingPolicyClassName class name of the connection loa=
d balancing policy
*/
void setConnectionLoadBalancingPolicyClassName(String loadBalancingPoli=
cyClassName);
=
/**
* Returns the initial size of messages created through this factory.
- * =
+ *
* Value is in bytes, default value is {@link HornetQClient#DEFAULT_IN=
ITIAL_MESSAGE_PACKET_SIZE}.
- * =
+ *
* @return the initial size of messages created through this factory
*/
int getInitialMessagePacketSize();
=
/**
* Sets the initial size of messages created through this factory.
- * =
+ *
* Value must be greater than 0.
- * =
+ *
* @param size initial size of messages created through this factory.
*/
void setInitialMessagePacketSize(int size);
- =
+
/**
* Adds an interceptor which will be executed after packets are rec=
eived from the server.
- * =
+ *
* @param interceptor an Interceptor
*/
void addInterceptor(Interceptor interceptor);
=
/**
* Removes an interceptor.
- * =
+ *
* @param interceptor interceptor to remove
- * =
+ *
* @return true if the interceptor is removed from this fa=
ctory, false else
*/
boolean removeInterceptor(Interceptor interceptor);
@@ -593,9 +592,9 @@
void close();
=
boolean isHA();
- =
+
boolean isCompressLargeMessage();
- =
+
void setCompressLargeMessage(boolean compress);
=
void addClusterTopologyListener(ClusterTopologyListener listener);
Modified: branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/h=
ornetq/api/core/management/BridgeControl.java
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D
--- branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq=
/api/core/management/BridgeControl.java 2011-07-05 14:00:57 UTC (rev 10916)
+++ branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq=
/api/core/management/BridgeControl.java 2011-07-05 14:08:46 UTC (rev 10917)
@@ -13,12 +13,13 @@
=
package org.hornetq.api.core.management;
=
+import org.hornetq.core.server.cluster.Bridge;
=
+
/**
* A BridgeControl is used to manage a Bridge.
- *
+ * @see Bridge
* @author Jeff Mesnil
- *
*/
public interface BridgeControl extends HornetQComponentControl
{
@@ -76,9 +77,9 @@
* Returns whether this bridge is using duplicate detection.
*/
boolean isUseDuplicateDetection();
- =
+
/**
- * Returns whether this bridge is using high availability =
+ * Returns whether this bridge is using high availability
*/
boolean isHA();
}
Modified: branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/h=
ornetq/api/core/management/DivertControl.java
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D
--- branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq=
/api/core/management/DivertControl.java 2011-07-05 14:00:57 UTC (rev 10916)
+++ branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq=
/api/core/management/DivertControl.java 2011-07-05 14:08:46 UTC (rev 10917)
@@ -13,9 +13,10 @@
=
package org.hornetq.api.core.management;
=
+import org.hornetq.core.server.Divert;
+
/**
- * A DivertControl is used to manage a divert.
- * =
+ * A DivertControl is used to manage a {@link Divert}.
* @author Jeff Mesnil
*/
public interface DivertControl
Modified: branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/h=
ornetq/api/core/management/NotificationType.java
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D
--- branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq=
/api/core/management/NotificationType.java 2011-07-05 14:00:57 UTC (rev 109=
16)
+++ branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq=
/api/core/management/NotificationType.java 2011-07-05 14:08:46 UTC (rev 109=
17)
@@ -14,8 +14,7 @@
package org.hornetq.api.core.management;
=
/**
- * Types of notification emmitted by HornetQ servers.
- * =
+ * Types of notification emitted by HornetQ servers.
* @author Jeff Mesnil
*/
public enum NotificationType
Modified: branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/h=
ornetq/api/core/management/Operation.java
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D
--- branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq=
/api/core/management/Operation.java 2011-07-05 14:00:57 UTC (rev 10916)
+++ branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq=
/api/core/management/Operation.java 2011-07-05 14:08:46 UTC (rev 10917)
@@ -23,7 +23,7 @@
=
/**
* Info for a MBean Operation.
- *
+ *