From do-not-reply at jboss.org Mon Jun 27 09:39:56 2011 Content-Type: multipart/mixed; boundary="===============3642098987353929734==" MIME-Version: 1.0 From: do-not-reply at jboss.org To: hornetq-commits at lists.jboss.org Subject: [hornetq-commits] JBoss hornetq SVN: r10882 - in trunk/hornetq-core/src/main/java/org/hornetq: core/replication/impl and 1 other directories. Date: Mon, 27 Jun 2011 09:39:56 -0400 Message-ID: <201106271339.p5RDdumg019209@svn01.web.mwc.hst.phx2.redhat.com> --===============3642098987353929734== Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: quoted-printable Author: borges Date: 2011-06-27 09:39:55 -0400 (Mon, 27 Jun 2011) New Revision: 10882 Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/core/CoreRemo= tingConnection.java trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/core/Packet.j= ava trunk/hornetq-core/src/main/java/org/hornetq/core/replication/impl/Repli= cationManagerImpl.java trunk/hornetq-core/src/main/java/org/hornetq/spi/core/remoting/Acceptor.= java trunk/hornetq-core/src/main/java/org/hornetq/spi/core/remoting/Connector= .java Log: Small javadoc fixes. Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/core/C= oreRemotingConnection.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 --- trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/core/CoreRem= otingConnection.java 2011-06-27 13:38:04 UTC (rev 10881) +++ trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/core/CoreRem= otingConnection.java 2011-06-27 13:39:55 UTC (rev 10882) @@ -24,7 +24,7 @@ * */ public interface CoreRemotingConnection extends RemotingConnection -{ = +{ /** * return the channel with the channel id specified. *
@@ -74,7 +74,7 @@ long getIDGeneratorSequence(); = /** - * return the current tomeout for blocking calls + * Return the current timeout for blocking calls. * * @return the timeout in milliseconds */ @@ -86,7 +86,7 @@ * @return the lock */ Object getTransferLock(); - = + /** * Called periodically to flush any data in the batch buffer */ Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/core/P= acket.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 --- trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/core/Packet.= java 2011-06-27 13:38:04 UTC (rev 10881) +++ trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/core/Packet.= java 2011-06-27 13:39:55 UTC (rev 10882) @@ -17,21 +17,22 @@ import org.hornetq.spi.core.protocol.RemotingConnection; = /** - * A Packet represents a pcaket of data transmitted over a connection. + * A Packet represents a packet of data transmitted over a connection. * * @author Tim Fox */ public interface Packet { /** - * This sets the channel id that should be used once the packet has bee= n successfully decoded it is sent to the correct channel. - * + * Sets the channel id that should be used once the packet has been suc= cessfully decoded it is + * sent to the correct channel. + * = * @param channelID the id of the channel to handle the packet */ void setChannelID(long channelID); = /** - * returns the channel id of the channel that should handle this pcaket + * Returns the channel id of the channel that should handle this packet. * * @return the id of the channel */ @@ -81,6 +82,6 @@ * @return true if confirmation is required */ boolean isRequiresConfirmations(); - = + boolean isAsyncExec(); } Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/replication/imp= l/ReplicationManagerImpl.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 --- trunk/hornetq-core/src/main/java/org/hornetq/core/replication/impl/Repl= icationManagerImpl.java 2011-06-27 13:38:04 UTC (rev 10881) +++ trunk/hornetq-core/src/main/java/org/hornetq/core/replication/impl/Repl= icationManagerImpl.java 2011-06-27 13:39:55 UTC (rev 10882) @@ -51,11 +51,9 @@ import org.hornetq.utils.ExecutorFactory; = /** - * A RepplicationManagerImpl - * + * A ReplicationManagerImpl + * = * @author