diff --git a/activemq-core/src/main/java/org/apache/activemq/advisory/ConsumerStartedEvent.java b/activemq-core/src/main/java/org/apache/activemq/advisory/ConsumerStartedEvent.java
index 720db781a6..231cca2e97 100644
--- a/activemq-core/src/main/java/org/apache/activemq/advisory/ConsumerStartedEvent.java
+++ b/activemq-core/src/main/java/org/apache/activemq/advisory/ConsumerStartedEvent.java
@@ -29,7 +29,7 @@ public class ConsumerStartedEvent extends ConsumerEvent {
 
     private static final long serialVersionUID = 5088138839609391074L;
 
-    private final ConsumerInfo consumerInfo;
+    private transient final ConsumerInfo consumerInfo;
 
     public ConsumerStartedEvent(ConsumerEventSource source, ActiveMQDestination destination, ConsumerInfo consumerInfo, int count) {
         super(source, destination, consumerInfo.getConsumerId(), count);
diff --git a/activemq-core/src/main/java/org/apache/activemq/advisory/ProducerStartedEvent.java b/activemq-core/src/main/java/org/apache/activemq/advisory/ProducerStartedEvent.java
index f1f8ebea73..20447ce12d 100644
--- a/activemq-core/src/main/java/org/apache/activemq/advisory/ProducerStartedEvent.java
+++ b/activemq-core/src/main/java/org/apache/activemq/advisory/ProducerStartedEvent.java
@@ -29,7 +29,7 @@ public class ProducerStartedEvent extends ProducerEvent {
 
     private static final long serialVersionUID = 5088138839609391074L;
 
-    private final ProducerInfo consumerInfo;
+    private transient final ProducerInfo consumerInfo;
 
     public ProducerStartedEvent(ProducerEventSource source, ActiveMQDestination destination, ProducerInfo consumerInfo, int count) {
         super(source, destination, consumerInfo.getProducerId(), count);