User: dmaplesden
Date: 01/11/13 17:53:40
Modified: src/main/org/jboss/mq/cluster/jms ClusterTopicSession.java
Log:
Added message object pool and changed file PM message log to use generic
SpyMessage.writeMessage and readMessage methods.
Revision Changes Path
1.5 +9 -9
jbossmq/src/main/org/jboss/mq/cluster/jms/ClusterTopicSession.java
Index: ClusterTopicSession.java
===================================================================
RCS file:
/cvsroot/jboss/jbossmq/src/main/org/jboss/mq/cluster/jms/ClusterTopicSession.java,v
retrieving revision 1.4
retrieving revision 1.5
diff -u -r1.4 -r1.5
--- ClusterTopicSession.java 2001/10/28 04:07:34 1.4
+++ ClusterTopicSession.java 2001/11/14 01:53:40 1.5
@@ -42,7 +42,7 @@
*
* @author Hiram Chirino ([EMAIL PROTECTED])
* @created August 16, 2001
- * @version $Revision: 1.4 $
+ * @version $Revision: 1.5 $
*/
public class ClusterTopicSession
implements TopicSession
@@ -192,7 +192,7 @@
throw new IllegalStateException( "The session is closed" );
}
- SpyBytesMessage message = new SpyBytesMessage();
+ SpyBytesMessage message = org.jboss.mq.MessagePool.getBytesMessage();
message.header.producerClientId = connection.getClientID();
return message;
}
@@ -203,7 +203,7 @@
throw new IllegalStateException( "The session is closed" );
}
- SpyMapMessage message = new SpyMapMessage();
+ SpyMapMessage message = org.jboss.mq.MessagePool.getMapMessage();
message.header.producerClientId = connection.getClientID();
return message;
}
@@ -214,7 +214,7 @@
throw new IllegalStateException( "The session is closed" );
}
- SpyMessage message = new SpyMessage();
+ SpyMessage message = org.jboss.mq.MessagePool.getMessage();
message.header.producerClientId = connection.getClientID();
return message;
}
@@ -225,7 +225,7 @@
throw new IllegalStateException( "The session is closed" );
}
- SpyObjectMessage message = new SpyObjectMessage();
+ SpyObjectMessage message = org.jboss.mq.MessagePool.getObjectMessage();
message.header.producerClientId = connection.getClientID();
return message;
}
@@ -236,7 +236,7 @@
throw new IllegalStateException( "The session is closed" );
}
- SpyObjectMessage message = new SpyObjectMessage();
+ SpyObjectMessage message = org.jboss.mq.MessagePool.getObjectMessage();
message.setObject( object );
message.header.producerClientId = connection.getClientID();
return message;
@@ -248,7 +248,7 @@
throw new IllegalStateException( "The session is closed" );
}
- SpyStreamMessage message = new SpyStreamMessage();
+ SpyStreamMessage message = org.jboss.mq.MessagePool.getStreamMessage();
message.header.producerClientId = connection.getClientID();
return message;
}
@@ -259,7 +259,7 @@
throw new IllegalStateException( "The session is closed" );
}
- SpyTextMessage message = new SpyTextMessage();
+ SpyTextMessage message = org.jboss.mq.MessagePool.getTextMessage();
message.header.producerClientId = connection.getClientID();
return message;
}
@@ -270,7 +270,7 @@
throw new IllegalStateException( "The session is closed" );
}
- SpyTextMessage message = new SpyTextMessage();
+ SpyTextMessage message = org.jboss.mq.MessagePool.getTextMessage();
message.setText( string );
message.header.producerClientId = connection.getClientID();
return message;
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
https://lists.sourceforge.net/lists/listinfo/jboss-development
