[jboss-cvs] JBoss Messaging SVN: r3670 - in branches/Branch_Hibernate_Persistence/src/main/org/jboss/messaging/jdbc/hb/pm: src and 6 other directories.
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Wed Feb 6 09:07:10 EST 2008
Author: bershath27
Date: 2008-02-06 09:07:10 -0500 (Wed, 06 Feb 2008)
New Revision: 3670
Added:
branches/Branch_Hibernate_Persistence/src/main/org/jboss/messaging/jdbc/hb/pm/src/
branches/Branch_Hibernate_Persistence/src/main/org/jboss/messaging/jdbc/hb/pm/src/org/
branches/Branch_Hibernate_Persistence/src/main/org/jboss/messaging/jdbc/hb/pm/src/org/jboss/
branches/Branch_Hibernate_Persistence/src/main/org/jboss/messaging/jdbc/hb/pm/src/org/jboss/messaging/
branches/Branch_Hibernate_Persistence/src/main/org/jboss/messaging/jdbc/hb/pm/src/org/jboss/messaging/jdbc/
branches/Branch_Hibernate_Persistence/src/main/org/jboss/messaging/jdbc/hb/pm/src/org/jboss/messaging/jdbc/hb/
branches/Branch_Hibernate_Persistence/src/main/org/jboss/messaging/jdbc/hb/pm/src/org/jboss/messaging/jdbc/hb/dto/
branches/Branch_Hibernate_Persistence/src/main/org/jboss/messaging/jdbc/hb/pm/src/org/jboss/messaging/jdbc/hb/dto/JBMMessagePOJO.java
branches/Branch_Hibernate_Persistence/src/main/org/jboss/messaging/jdbc/hb/pm/src/org/jboss/messaging/jdbc/hb/dto/JBMMessageReferencePK.java
branches/Branch_Hibernate_Persistence/src/main/org/jboss/messaging/jdbc/hb/pm/src/org/jboss/messaging/jdbc/hb/dto/JBMMessageReferencePOJO.java
branches/Branch_Hibernate_Persistence/src/main/org/jboss/messaging/jdbc/hb/pm/src/org/jboss/messaging/jdbc/hb/dto/JBMTransactionPOJO.java
branches/Branch_Hibernate_Persistence/src/main/org/jboss/messaging/jdbc/hb/pm/src/org/jboss/messaging/jdbc/hb/factory/
Log:
Initial import.
Added: branches/Branch_Hibernate_Persistence/src/main/org/jboss/messaging/jdbc/hb/pm/src/org/jboss/messaging/jdbc/hb/dto/JBMMessagePOJO.java
===================================================================
--- branches/Branch_Hibernate_Persistence/src/main/org/jboss/messaging/jdbc/hb/pm/src/org/jboss/messaging/jdbc/hb/dto/JBMMessagePOJO.java (rev 0)
+++ branches/Branch_Hibernate_Persistence/src/main/org/jboss/messaging/jdbc/hb/pm/src/org/jboss/messaging/jdbc/hb/dto/JBMMessagePOJO.java 2008-02-06 14:07:10 UTC (rev 3670)
@@ -0,0 +1,176 @@
+/*
+ * JBoss, Home of Professional Open Source.
+ * Copyright 2006, Red Hat Middleware LLC, and individual contributors
+ * as indicated by the @author tags. See the copyright.txt file in the
+ * distribution for a full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+
+package org.jboss.messaging.jdbc.hb.dto;
+
+import java.io.Serializable;
+import java.math.BigInteger;
+import javax.persistence.Column;
+import javax.persistence.Entity;
+import javax.persistence.Id;
+import javax.persistence.Lob;
+import javax.persistence.Table;
+
+/**
+ * JBMMessagePOJO to map to JBM_MSG table
+ *
+ * @author <a href="mailto:bershath at gmail.com">Tyronne Wickramarathne</a>
+ * @version $Revision: 1 $
+ */
+
+
+ at Entity
+ at Table( name = "JBM_MSG" )
+public class JBMMessagePOJO implements Serializable
+{
+
+
+ private static final long serialVersionUID = -754566647626471534L;
+
+ private BigInteger messageID;
+ private char[] reliable;
+ private BigInteger expiration;
+ private BigInteger timestamp;
+ private int priority;
+ private int type;
+ private BigInteger time;
+ private String headers;
+ private String payload;
+
+
+ public JBMMessagePOJO()
+ {
+
+ }
+
+ @Id
+ @Column( name = "MESSAGE_ID" , nullable = false , precision = 0 )
+ public BigInteger getMessageID()
+ {
+ return messageID;
+ }
+
+ @Lob
+ @Column( name = "RELIABLE" , length = 1 )
+ public char[] getReliable()
+ {
+ return reliable;
+ }
+
+ @Column( name = "EXPIRATION" , length = 20 )
+ public BigInteger getExpiration()
+ {
+ return expiration;
+ }
+
+ @Column( name = "TIMESTAMP", length = 20 )
+ public BigInteger getTimestamp()
+ {
+ return timestamp;
+ }
+
+ @Column( name = "PRIORITY", length = 4 )
+ public int getPriority()
+ {
+ return priority;
+ }
+
+ @Column( name = "TYPE" , length = 4 )
+ public int getType()
+ {
+ return type;
+ }
+
+ @Column( name="INS_TIME", length = 20 )
+ public BigInteger getTime()
+ {
+ return time;
+ }
+
+ @Lob
+ @Column( name="HEADERS")
+ public String getHeaders()
+ {
+ return headers;
+ }
+
+ @Lob
+ @Column( name="PAYLOAD")
+ public String getPayload()
+ {
+ return payload;
+ }
+
+
+ public void setMessageID(BigInteger messageID)
+ {
+ this.messageID = messageID;
+ }
+
+
+ public void setReliable(char[] reliable)
+ {
+ this.reliable = reliable;
+ }
+
+
+ public void setExpiration(BigInteger expiration)
+ {
+ this.expiration = expiration;
+ }
+
+
+ public void setTimestamp(BigInteger timestamp)
+ {
+ this.timestamp = timestamp;
+ }
+
+
+ public void setPriority(int priority)
+ {
+ this.priority = priority;
+ }
+
+
+ public void setType(int type)
+ {
+ this.type = type;
+ }
+
+
+ public void setTime(BigInteger time)
+ {
+ this.time = time;
+ }
+
+
+ public void setHeaders(String headers) {
+ this.headers = headers;
+ }
+
+
+ public void setPayload(String payload) {
+ this.payload = payload;
+ }
+
+
+}
Added: branches/Branch_Hibernate_Persistence/src/main/org/jboss/messaging/jdbc/hb/pm/src/org/jboss/messaging/jdbc/hb/dto/JBMMessageReferencePK.java
===================================================================
--- branches/Branch_Hibernate_Persistence/src/main/org/jboss/messaging/jdbc/hb/pm/src/org/jboss/messaging/jdbc/hb/dto/JBMMessageReferencePK.java (rev 0)
+++ branches/Branch_Hibernate_Persistence/src/main/org/jboss/messaging/jdbc/hb/pm/src/org/jboss/messaging/jdbc/hb/dto/JBMMessageReferencePK.java 2008-02-06 14:07:10 UTC (rev 3670)
@@ -0,0 +1,119 @@
+/*
+ * JBoss, Home of Professional Open Source.
+ * Copyright 2006, Red Hat Middleware LLC, and individual contributors
+ * as indicated by the @author tags. See the copyright.txt file in the
+ * distribution for a full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+
+package org.jboss.messaging.jdbc.hb.dto;
+
+
+
+import java.io.Serializable;
+import java.math.BigInteger;
+
+import javax.persistence.Column;
+import javax.persistence.Embeddable;
+
+
+/**
+ * JBMMessageReferencePK , a composite primary key implementation for JBM_MSG_REF table
+ *
+ * @author <a href="mailto:bershath at gmail.com">Tyronne Wickramarathne</a>
+ * @version $Revision: 1 $
+ */
+
+
+ at Embeddable
+public class JBMMessageReferencePK implements Serializable
+{
+
+ private static final long serialVersionUID = 8186484857739990716L;
+
+ private BigInteger channelId;
+ private BigInteger messageId;
+
+
+
+ public JBMMessageReferencePK()
+ {
+
+ }
+
+ @Column( name = "CHANNEL_ID", length = 20 , nullable = false , precision = 0 )
+ public BigInteger getChannelId()
+ {
+ return channelId;
+ }
+
+
+ @Column( name = "MESSAGE_ID", length = 20 , nullable = false , precision = 0 )
+ public BigInteger getMessageId()
+ {
+ return messageId;
+ }
+
+ public void setChannelId(BigInteger channelId)
+ {
+ this.channelId = channelId;
+ }
+
+
+ public void setMessageId(BigInteger messageId)
+ {
+ this.messageId = messageId;
+ }
+
+ @Override
+ public int hashCode()
+ {
+ final int prime = 31;
+ int result = 1;
+ result = prime * result
+ + ((channelId == null) ? 0 : channelId.hashCode());
+ result = prime * result
+ + ((messageId == null) ? 0 : messageId.hashCode());
+ return result;
+ }
+
+ @Override
+ public boolean equals(Object obj)
+ {
+ if (this == obj)
+ return true;
+ if (obj == null)
+ return false;
+ if (getClass() != obj.getClass())
+ return false;
+ final JBMMessageReferencePK other = (JBMMessageReferencePK) obj;
+ if (channelId == null)
+ {
+ if (other.channelId != null)
+ return false;
+ } else if (!channelId.equals(other.channelId))
+ return false;
+ if (messageId == null)
+ {
+ if (other.messageId != null)
+ return false;
+ } else if (!messageId.equals(other.messageId))
+ return false;
+ return true;
+ }
+
+}
Added: branches/Branch_Hibernate_Persistence/src/main/org/jboss/messaging/jdbc/hb/pm/src/org/jboss/messaging/jdbc/hb/dto/JBMMessageReferencePOJO.java
===================================================================
--- branches/Branch_Hibernate_Persistence/src/main/org/jboss/messaging/jdbc/hb/pm/src/org/jboss/messaging/jdbc/hb/dto/JBMMessageReferencePOJO.java (rev 0)
+++ branches/Branch_Hibernate_Persistence/src/main/org/jboss/messaging/jdbc/hb/pm/src/org/jboss/messaging/jdbc/hb/dto/JBMMessageReferencePOJO.java 2008-02-06 14:07:10 UTC (rev 3670)
@@ -0,0 +1,150 @@
+/*
+ * JBoss, Home of Professional Open Source.
+ * Copyright 2006, Red Hat Middleware LLC, and individual contributors
+ * as indicated by the @author tags. See the copyright.txt file in the
+ * distribution for a full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+package org.jboss.messaging.jdbc.hb.dto;
+
+import java.io.Serializable;
+import java.math.BigInteger;
+
+import javax.persistence.Column;
+import javax.persistence.Entity;
+import javax.persistence.Id;
+import javax.persistence.Lob;
+import javax.persistence.Table;
+
+
+/**
+ * JBMMessageReferencePOJO a mapping POJO class for JBM_MSG_REF table
+ *
+ * @author <a href="mailto:bershath at gmail.com">Tyronne Wickramarathne</a>
+ * @version $Revision: 1 $
+ */
+
+
+ at Entity
+ at Table( name = "JBM_MSG_REF" )
+public class JBMMessageReferencePOJO implements Serializable
+{
+
+
+ private static final long serialVersionUID = 5857373425228346565L;
+
+
+ @Id private JBMMessageReferencePK jbMessageReferencePK;
+ private BigInteger transactionId;
+ private char[] state;
+ private BigInteger ordering;
+ private BigInteger pageOrdering;
+ private int deliveryCount;
+ private BigInteger scheduledDelivery;
+
+
+
+ public JBMMessageReferencePOJO()
+ {
+
+ }
+
+
+ public JBMMessageReferencePK getJbMessageReferencePK()
+ {
+ return jbMessageReferencePK;
+ }
+
+ public void setJbMessageReferencePK(JBMMessageReferencePK jbMessageReferencePK)
+ {
+ this.jbMessageReferencePK = jbMessageReferencePK;
+ }
+
+
+
+ @Column( name = "TRANSACTION_ID", length = 20 )
+ public BigInteger getTransactionId()
+ {
+ return transactionId;
+ }
+
+ @Lob
+ @Column( name = "STATE", length = 1 )
+ public char[] getState()
+ {
+ return state;
+ }
+
+ @Column( name = "ORD", length = 20 )
+ public BigInteger getOrdering()
+ {
+ return ordering;
+ }
+
+ @Column( name = "PAGE_ORD", length = 20 )
+ public BigInteger getPageOrdering()
+ {
+ return pageOrdering;
+ }
+
+ @Column( name = "DELIVERY_COUNT", length = 11 )
+ public int getDeliveryCount()
+ {
+ return deliveryCount;
+ }
+
+ @Column( name = "SCHED_DELIVERY", length = 20 )
+ public BigInteger getScheduledDelivery()
+ {
+ return scheduledDelivery;
+ }
+
+ public void setTransactionId(BigInteger transactionId)
+ {
+ this.transactionId = transactionId;
+ }
+
+ public void setState(char[] state)
+ {
+ this.state = state;
+ }
+
+ public void setOrdering(BigInteger ordering)
+ {
+ this.ordering = ordering;
+ }
+
+ public void setPageOrdering(BigInteger pageOrdering)
+ {
+ this.pageOrdering = pageOrdering;
+ }
+
+ public void setDeliveryCount(int deliveryCount)
+ {
+ this.deliveryCount = deliveryCount;
+ }
+
+ public void setScheduledDelivery(BigInteger scheduledDelivery)
+ {
+ this.scheduledDelivery = scheduledDelivery;
+ }
+
+
+
+
+
+}
Added: branches/Branch_Hibernate_Persistence/src/main/org/jboss/messaging/jdbc/hb/pm/src/org/jboss/messaging/jdbc/hb/dto/JBMTransactionPOJO.java
===================================================================
--- branches/Branch_Hibernate_Persistence/src/main/org/jboss/messaging/jdbc/hb/pm/src/org/jboss/messaging/jdbc/hb/dto/JBMTransactionPOJO.java (rev 0)
+++ branches/Branch_Hibernate_Persistence/src/main/org/jboss/messaging/jdbc/hb/pm/src/org/jboss/messaging/jdbc/hb/dto/JBMTransactionPOJO.java 2008-02-06 14:07:10 UTC (rev 3670)
@@ -0,0 +1,123 @@
+/*
+ * JBoss, Home of Professional Open Source.
+ * Copyright 2006, Red Hat Middleware LLC, and individual contributors
+ * as indicated by the @author tags. See the copyright.txt file in the
+ * distribution for a full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+
+package org.jboss.messaging.jdbc.hb.dto;
+
+import java.io.Serializable;
+import java.math.BigInteger;
+
+import javax.persistence.Column;
+import javax.persistence.Entity;
+import javax.persistence.Id;
+import javax.persistence.Lob;
+import javax.persistence.Table;
+
+
+/**
+ * JBMTransactionPOJO a mapping POJO class for JBM_TX table
+ *
+ * @author <a href="mailto:bershath at gmail.com">Tyronne Wickramarathne</a>
+ * @version $Revision: 1 $
+ */
+
+
+ at Entity
+ at Table( name = "JBM_TX" )
+public class JBMTransactionPOJO implements Serializable
+{
+
+
+ private static final long serialVersionUID = -6875604807491686323L;
+
+ private BigInteger transactionId;
+ private int nodeId;
+ private String branchQual;
+ private int formatId;
+ private String globalTXID;
+
+
+ public JBMTransactionPOJO()
+ {
+
+ }
+
+ @Id
+ @Column( name = "TRANSACTION_ID", length = 20 , nullable = false , precision = 0 )
+ public BigInteger getTransactionId()
+ {
+ return transactionId;
+ }
+
+ @Column( name = "NODE_ID", length = 11 )
+ public int getNodeId()
+ {
+ return nodeId;
+ }
+
+ @Lob
+ @Column( name = "BRANCH_QUAL", length = 254 )
+ public String getBranchQual()
+ {
+ return branchQual;
+ }
+
+
+ @Column( name = "FORMAT_ID", length = 11 )
+ public int getFormatId()
+ {
+ return formatId;
+ }
+
+ @Lob
+ @Column( name = "GLOBAL_TXID", length = 20 )
+ public String getGlobalTXID()
+ {
+ return globalTXID;
+ }
+
+ public void setTransactionId(BigInteger transactionId)
+ {
+ this.transactionId = transactionId;
+ }
+
+ public void setNodeId(int nodeId)
+ {
+ this.nodeId = nodeId;
+ }
+
+ public void setBranchQual(String branchQual)
+ {
+ this.branchQual = branchQual;
+ }
+
+ public void setFormatId(int formatId)
+ {
+ this.formatId = formatId;
+ }
+
+ public void setGlobalTXID(String globalTXID)
+ {
+ this.globalTXID = globalTXID;
+ }
+
+
+}
More information about the jboss-cvs-commits
mailing list