You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rg...@apache.org on 2007/04/09 11:37:56 UTC
svn commit: r526689 - in /incubator/qpid/trunk/qpid: ./
java/broker/bin/bdbbackup java/distribution/src/main/assembly/bin.xml
java/perftests/src/main/java/org/apache/qpid/ping/PingDurableClient.java
Author: rgreig
Date: Mon Apr 9 02:37:54 2007
New Revision: 526689
URL: http://svn.apache.org/viewvc?view=rev&rev=526689
Log:
Added shell script.
Added:
incubator/qpid/trunk/qpid/java/broker/bin/bdbbackup
- copied unchanged from r526685, incubator/qpid/branches/M2/java/broker/bin/bdbbackup
Modified:
incubator/qpid/trunk/qpid/ (props changed)
incubator/qpid/trunk/qpid/java/distribution/src/main/assembly/bin.xml
incubator/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/ping/PingDurableClient.java
Propchange: incubator/qpid/trunk/qpid/
------------------------------------------------------------------------------
Binary property 'svnmerge-integrated' - no diff available.
Modified: incubator/qpid/trunk/qpid/java/distribution/src/main/assembly/bin.xml
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/distribution/src/main/assembly/bin.xml?view=diff&rev=526689&r1=526688&r2=526689
==============================================================================
--- incubator/qpid/trunk/qpid/java/distribution/src/main/assembly/bin.xml (original)
+++ incubator/qpid/trunk/qpid/java/distribution/src/main/assembly/bin.xml Mon Apr 9 02:37:54 2007
@@ -148,6 +148,12 @@
<destName>runAll</destName>
<fileMode>493</fileMode>
</file>
+ <file>
+ <source>../broker/bin/bdbbackup</source>
+ <outputDirectory>qpid-${qpid.version}/bin</outputDirectory>
+ <destName>bdbbackup</destName>
+ <fileMode>493</fileMode>
+ </file>
</files>
<dependencySets>
<dependencySet>
Modified: incubator/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/ping/PingDurableClient.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/ping/PingDurableClient.java?view=diff&rev=526689&r1=526688&r2=526689
==============================================================================
--- incubator/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/ping/PingDurableClient.java (original)
+++ incubator/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/ping/PingDurableClient.java Mon Apr 9 02:37:54 2007
@@ -58,10 +58,11 @@
* additionally accepts the following parameters:
*
* <p/><table><caption>Parameters</caption>
- * <tr><th> Parameter <th> Default <th> Comments
- * <tr><td> numMessages <th> 100 <th> The total number of messages to send.
- * <tr><td> duration <th> 30S <th> The length of time to ping for. (Format dDhHmMsS, for d days, h hours,
- * m minutes and s seconds).
+ * <tr><th> Parameter <th> Default <th> Comments
+ * <tr><td> numMessages <td> 100 <td> The total number of messages to send.
+ * <tr><td> numMessagesToAction <td> -1 <td> The number of messages to send before taking a custom 'action'.
+ * <tr><td> duration <td> 30S <td> The length of time to ping for. (Format dDhHmMsS, for d days, h hours,
+ * m minutes and s seconds).
* </table>
*
* <p/>This ping client also overrides some of the defaults of its parent class, to provide a reasonable set up
@@ -81,12 +82,18 @@
* is reached. Reaching the limit will be interpreted as the first signal to stop sending, and the ping client will
* wait for the second signal before receiving its pings.
*
+ * <p/>This class provides a mechanism for extensions to add arbitrary actions, after a particular number of messages
+ * have been sent. When the number of messages equal the value set in the 'numMessagesToAction' property is method,
+ * the {@link #takeAction} method is called. By default this does nothing, but extensions of this class can provide
+ * custom behaviour with alternative implementations of this method (for example taking a backup).
+ *
* <p><table id="crc"><caption>CRC Card</caption>
* <tr><th> Responsibilities <th> Collaborations
* <tr><td> Send and receive pings.
* <tr><td> Accept user input to signal stop sending.
* <tr><td> Accept user input to signal start receiving.
* <tr><td> Provide feedback on pings sent versus pings received.
+ * <tr><td> Provide extension point for arbitrary action on a particular message count.
* </table>
*/
public class PingDurableClient extends PingPongProducer implements ExceptionListener
@@ -97,6 +104,8 @@
public static final String NUM_MESSAGES_DEFAULT = "100";
public static final String DURATION_PROPNAME = "duration";
public static final String DURATION_DEFAULT = "30S";
+ public static final String NUM_MESSAGES_TO_ACTION_PROPNAME = "numMessagesToAction";
+ public static final String NUM_MESSAGES_TO_ACTION_DEFAULT = "-1";
/** The maximum length of time to wait whilst receiving pings before assuming that no more are coming. */
private static final long TIME_OUT = 3000;
@@ -111,11 +120,15 @@
defaults.setProperty(TX_BATCH_SIZE_PROPNAME, "10");
defaults.setProperty(RATE_PROPNAME, "20");
defaults.setProperty(DURABLE_DESTS_PROPNAME, "true");
+ defaults.setProperty(NUM_MESSAGES_TO_ACTION_PROPNAME, NUM_MESSAGES_TO_ACTION_DEFAULT);
}
/** Specifies the number of pings to send, if larger than 0. 0 means send until told to stop. */
private int numMessages;
+ /** Holds the number of messages to send before taking triggering the action. */
+ private int numMessagesToAction;
+
/** Sepcifies how long to ping for, if larger than 0. 0 means send until told to stop. */
private long duration;
@@ -136,6 +149,7 @@
numMessages = properties.getPropertyAsInteger(NUM_MESSAGES_PROPNAME);
String durationSpec = properties.getProperty(DURATION_PROPNAME);
+ numMessagesToAction = properties.getPropertyAsInteger(NUM_MESSAGES_TO_ACTION_PROPNAME);
if (durationSpec != null)
{
@@ -180,7 +194,7 @@
/**
* Performs the main test procedure implemented by this ping client. See the class level comment for details.
*/
- public int send() throws Exception
+ protected int send() throws Exception
{
log.debug("public void sendWaitReceive(): called");
@@ -245,6 +259,14 @@
_publish = false;
}
+ // Perform the arbitrary action if the number of messages sent has reached the right number.
+ if (messagesSent == numMessagesToAction)
+ {
+ System.out.println("At action point, Messages sent = " + messagesSent + ", Messages Committed = "
+ + messagesCommitted + ", Messages not Committed = " + messagesNotCommitted);
+ takeAction();
+ }
+
// Determine if the end condition has been met, based on the number of messages, time passed, errors on
// the connection or user input.
long now = System.nanoTime();
@@ -293,7 +315,7 @@
return messagesSent;
}
- private void receive(int messagesSent) throws Exception
+ protected void receive(int messagesSent) throws Exception
{
// Re-establish the connection and the message consumer.
_queueJVMSequenceID = new AtomicInteger();
@@ -389,4 +411,11 @@
}
});
}
+
+ /**
+ * Performs an aribtrary action once the 'numMesagesToAction' count is reached on sending messages. This default
+ * implementation does nothing.
+ */
+ public void takeAction()
+ { }
}