Author: foconer
Date: Fri Feb 3 00:48:25 2006
New Revision: 374605
URL: http://svn.apache.org/viewcvs?rev=374605&view=rev
Log:
make Serializable to prevent NotSerializableException in weblogic (AMQ-501) -
Patrick Villacorta
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQPrefetchPolicy.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/RedeliveryPolicy.java
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQPrefetchPolicy.java
URL:
http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQPrefetchPolicy.java?rev=374605&r1=374604&r2=374605&view=diff
==============================================================================
---
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQPrefetchPolicy.java
(original)
+++
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQPrefetchPolicy.java
Fri Feb 3 00:48:25 2006
@@ -16,7 +16,7 @@
*/
package org.apache.activemq;
-
+import java.io.Serializable;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
@@ -25,7 +25,7 @@
* Defines the pretech message policies for different types of consumers
* @version $Revision: 1.3 $
*/
-public class ActiveMQPrefetchPolicy {
+public class ActiveMQPrefetchPolicy implements Serializable {
private static final Log log =
LogFactory.getLog(ActiveMQPrefetchPolicy.class);
private static final int MAX_PREFETCH_SIZE = (Short.MAX_VALUE -1);
private int queuePrefetch;
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/RedeliveryPolicy.java
URL:
http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/RedeliveryPolicy.java?rev=374605&r1=374604&r2=374605&view=diff
==============================================================================
---
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/RedeliveryPolicy.java
(original)
+++
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/RedeliveryPolicy.java
Fri Feb 3 00:48:25 2006
@@ -16,13 +16,15 @@
*/
package org.apache.activemq;
+import java.io.Serializable;
+
/**
* Configuration options used to control how messages are re-delivered when
they
* are rolled back.
*
* @version $Revision: 1.11 $
*/
-public class RedeliveryPolicy implements Cloneable {
+public class RedeliveryPolicy implements Cloneable, Serializable {
protected int maximumRedeliveries = 5;
protected long initialRedeliveryDelay = 1000L;