You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2006/11/25 21:44:22 UTC

svn commit: r479194 - in /incubator/activemq/trunk/activemq-jpa-store/src/main/java/org/apache/activemq/store/jpa/model: StoredMessage.java StoredSubscription.java

Author: chirino
Date: Sat Nov 25 12:44:22 2006
New Revision: 479194

URL: http://svn.apache.org/viewvc?view=rev&rev=479194
Log:
Added some more annotations so that intexs and the lob is properly handled

Modified:
    incubator/activemq/trunk/activemq-jpa-store/src/main/java/org/apache/activemq/store/jpa/model/StoredMessage.java
    incubator/activemq/trunk/activemq-jpa-store/src/main/java/org/apache/activemq/store/jpa/model/StoredSubscription.java

Modified: incubator/activemq/trunk/activemq-jpa-store/src/main/java/org/apache/activemq/store/jpa/model/StoredMessage.java
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-jpa-store/src/main/java/org/apache/activemq/store/jpa/model/StoredMessage.java?view=diff&rev=479194&r1=479193&r2=479194
==============================================================================
--- incubator/activemq/trunk/activemq-jpa-store/src/main/java/org/apache/activemq/store/jpa/model/StoredMessage.java (original)
+++ incubator/activemq/trunk/activemq-jpa-store/src/main/java/org/apache/activemq/store/jpa/model/StoredMessage.java Sat Nov 25 12:44:22 2006
@@ -18,25 +18,31 @@
 import javax.persistence.Basic;
 import javax.persistence.Entity;
 import javax.persistence.Id;
+import javax.persistence.Lob;
+
+import org.apache.openjpa.persistence.jdbc.Index;
 
 /** 
  */
-@Entity
+@Entity()
 public class StoredMessage {
 	
     @Id
     private long id;
 	
-    @Basic
+    @Basic(optional=false)
+    @Index(enabled=true, unique=false)
     private String messageId;
 
-    @Basic
+    @Basic(optional=false)
+    @Index(enabled=true, unique=false)
     private String destination;
 
     @Basic
     private long exiration;
 
     @Basic
+    @Lob
     private byte[] data;
 
     public StoredMessage() {

Modified: incubator/activemq/trunk/activemq-jpa-store/src/main/java/org/apache/activemq/store/jpa/model/StoredSubscription.java
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-jpa-store/src/main/java/org/apache/activemq/store/jpa/model/StoredSubscription.java?view=diff&rev=479194&r1=479193&r2=479194
==============================================================================
--- incubator/activemq/trunk/activemq-jpa-store/src/main/java/org/apache/activemq/store/jpa/model/StoredSubscription.java (original)
+++ incubator/activemq/trunk/activemq-jpa-store/src/main/java/org/apache/activemq/store/jpa/model/StoredSubscription.java Sat Nov 25 12:44:22 2006
@@ -21,6 +21,8 @@
 import javax.persistence.GenerationType;
 import javax.persistence.Id;
 
+import org.apache.openjpa.persistence.jdbc.Index;
+
 /** 
  */
 @Entity
@@ -91,10 +93,13 @@
     private long id;
     
     @Basic
+    @Index(enabled=true, unique=false)
     private String destination;
     @Basic
+    @Index(enabled=true, unique=false)
     private String clientId;
     @Basic
+    @Index(enabled=true, unique=false)
     private String subscriptionName;
     
     @Basic