[jboss-cvs] JBoss Messaging SVN: r3632 - in trunk/src/main/org/jboss: jms/client/api and 4 other directories.

jboss-cvs-commits at lists.jboss.org jboss-cvs-commits at lists.jboss.org
Sat Jan 26 10:06:30 EST 2008


Author: timfox
Date: 2008-01-26 10:06:30 -0500 (Sat, 26 Jan 2008)
New Revision: 3632

Added:
   trunk/src/main/org/jboss/jms/client/JMSMessageListenerWrapper.java
   trunk/src/main/org/jboss/jms/client/api/ClientConnectionFactory.java
   trunk/src/main/org/jboss/jms/client/api/MessageHandler.java
   trunk/src/main/org/jboss/messaging/core/Delivery.java
   trunk/src/main/org/jboss/messaging/core/impl/DeliveryImpl.java
   trunk/src/main/org/jboss/messaging/core/remoting/codec/SessionAcknowledgeMessageCodec.java
   trunk/src/main/org/jboss/messaging/core/remoting/codec/SessionCancelMessageCodec.java
   trunk/src/main/org/jboss/messaging/core/remoting/wireformat/SessionAcknowledgeMessage.java
   trunk/src/main/org/jboss/messaging/core/remoting/wireformat/SessionCancelMessage.java
   trunk/src/main/org/jboss/messaging/core/remoting/wireformat/SessionCommitMessage.java
   trunk/src/main/org/jboss/messaging/core/remoting/wireformat/SessionRecoverMessage.java
   trunk/src/main/org/jboss/messaging/core/remoting/wireformat/SessionRollbackMessage.java
Log:
Added missing files


Added: trunk/src/main/org/jboss/jms/client/JMSMessageListenerWrapper.java
===================================================================
--- trunk/src/main/org/jboss/jms/client/JMSMessageListenerWrapper.java	                        (rev 0)
+++ trunk/src/main/org/jboss/jms/client/JMSMessageListenerWrapper.java	2008-01-26 15:06:30 UTC (rev 3632)
@@ -0,0 +1,138 @@
+/*
+   * JBoss, Home of Professional Open Source
+   * Copyright 2005, JBoss Inc., and individual contributors as indicated
+   * by the @authors tag. See the copyright.txt 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.jms.client;
+
+import javax.jms.JMSException;
+import javax.jms.MessageListener;
+import javax.jms.Session;
+
+import org.jboss.jms.client.api.ClientSession;
+import org.jboss.jms.client.api.MessageHandler;
+import org.jboss.jms.message.JBossMessage;
+import org.jboss.messaging.core.Message;
+import org.jboss.messaging.util.Logger;
+
+/**
+ * 
+ * A JMSMessageListenerWrapper
+ * 
+ * @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
+ *
+ */
+public class JMSMessageListenerWrapper implements MessageHandler
+{
+   private static final Logger log = Logger.getLogger(JMSMessageListenerWrapper.class);
+      
+   private JBossSession session;
+   
+   private MessageListener listener;
+   
+   private int ackMode;
+   
+   private boolean transactedOrClientAck;
+   
+   public JMSMessageListenerWrapper(JBossSession session, MessageListener listener, int ackMode)
+   {
+      this.session = session;
+      
+      this.listener = listener;
+      
+      this.transactedOrClientAck = ackMode == Session.SESSION_TRANSACTED || ackMode == Session.CLIENT_ACKNOWLEDGE;
+   }
+
+   /**
+    * In this method we apply the JMS acknowledgement and redelivery semantics
+    * as per JMS spec
+    */
+   public void onMessage(Message message)
+   {
+      JBossMessage jbm = JBossMessage.createMessage(message, session.getCoreSession());
+      
+      try
+      {
+         jbm.doBeforeReceive();
+      }
+      catch (Exception e)
+      {
+         log.error("Failed to prepare message", e);
+         
+         return;
+      }
+      
+      if (transactedOrClientAck)
+      {
+         try
+         {
+            session.getCoreSession().delivered();
+         }
+         catch (JMSException e)
+         {
+            log.error("Failed to deliver message", e);
+         }
+      }
+      
+      try
+      {         
+         listener.onMessage(jbm);
+      }
+      catch (RuntimeException e)
+      {
+         //See JMS 1.1 spec, section 4.5.2
+         
+         log.warn("Unhandled exception thrown from onMessage", e);
+         
+         if (!transactedOrClientAck)
+         {            
+            try
+            {
+               session.getCoreSession().rollback();
+               
+               session.setRecoverCalled(true);
+            }
+            catch (Exception e2)
+            {
+               log.error("Failed to recover session", e2);
+            }
+         }
+      }            
+      
+      if (!session.isRecoverCalled() && !transactedOrClientAck)
+      {
+         try
+         {
+            //We don't want to call this if the connection/session was closed from inside onMessage
+            if (!session.getCoreSession().isClosed())
+            {
+               session.getCoreSession().delivered();
+            }
+         }
+         catch (JMSException e)
+         {
+            log.error("Failed to deliver message", e);
+         }
+      }
+      
+      session.setRecoverCalled(false);
+      
+   }
+
+}

Added: trunk/src/main/org/jboss/jms/client/api/ClientConnectionFactory.java
===================================================================
--- trunk/src/main/org/jboss/jms/client/api/ClientConnectionFactory.java	                        (rev 0)
+++ trunk/src/main/org/jboss/jms/client/api/ClientConnectionFactory.java	2008-01-26 15:06:30 UTC (rev 3632)
@@ -0,0 +1,46 @@
+/*
+ * JBoss, Home of Professional Open Source
+ * Copyright 2005, JBoss Inc., and individual contributors as indicated
+ * by the @authors tag. See the copyright.txt 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.jms.client.api;
+
+import javax.jms.JMSException;
+
+import org.jboss.messaging.util.Version;
+
+/**
+ * 
+ * A ClientConnectionFactory
+ * 
+ * @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
+ *
+ */
+public interface ClientConnectionFactory
+{      
+   String getServerLocatorURI();
+      
+   int getServerID();
+   
+   Version getServerVersion();
+   
+   ClientConnection createConnection() throws JMSException;
+   
+   ClientConnection createConnection(String username, String password) throws JMSException;      
+}

Added: trunk/src/main/org/jboss/jms/client/api/MessageHandler.java
===================================================================
--- trunk/src/main/org/jboss/jms/client/api/MessageHandler.java	                        (rev 0)
+++ trunk/src/main/org/jboss/jms/client/api/MessageHandler.java	2008-01-26 15:06:30 UTC (rev 3632)
@@ -0,0 +1,36 @@
+/*
+   * JBoss, Home of Professional Open Source
+   * Copyright 2005, JBoss Inc., and individual contributors as indicated
+   * by the @authors tag. See the copyright.txt 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.jms.client.api;
+
+import org.jboss.messaging.core.Message;
+
+/**
+ * 
+ * A MessageHandler
+ * 
+ * @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
+ *
+ */
+public interface MessageHandler
+{
+   void onMessage(Message message);
+}

Added: trunk/src/main/org/jboss/messaging/core/Delivery.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/Delivery.java	                        (rev 0)
+++ trunk/src/main/org/jboss/messaging/core/Delivery.java	2008-01-26 15:06:30 UTC (rev 3632)
@@ -0,0 +1,38 @@
+/*
+  * JBoss, Home of Professional Open Source
+  * Copyright 2005, JBoss Inc., and individual contributors as indicated
+  * by the @authors tag. See the copyright.txt 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.core;
+
+/**
+ * 
+ * A Delivery
+ * 
+ * @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
+ *
+ */
+public interface Delivery
+{
+   MessageReference getReference();
+   
+   long getDeliveryID();
+   
+   void deliver();
+}

Added: trunk/src/main/org/jboss/messaging/core/impl/DeliveryImpl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/impl/DeliveryImpl.java	                        (rev 0)
+++ trunk/src/main/org/jboss/messaging/core/impl/DeliveryImpl.java	2008-01-26 15:06:30 UTC (rev 3632)
@@ -0,0 +1,80 @@
+/*
+  * JBoss, Home of Professional Open Source
+  * Copyright 2005, JBoss Inc., and individual contributors as indicated
+  * by the @authors tag. See the copyright.txt 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.core.impl;
+
+import org.jboss.messaging.core.Delivery;
+import org.jboss.messaging.core.MessageReference;
+import org.jboss.messaging.core.remoting.PacketSender;
+import org.jboss.messaging.core.remoting.wireformat.DeliverMessage;
+import org.jboss.messaging.util.Logger;
+
+/**
+ * 
+ * A DeliveryImpl
+ * 
+ * @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
+ *
+ */
+public class DeliveryImpl implements Delivery
+{
+   private static final Logger log = Logger.getLogger(DeliveryImpl.class);
+   
+   private MessageReference reference;
+   
+   private String consumerID;
+   
+   private long deliveryID;
+   
+   private PacketSender sender;
+
+   public DeliveryImpl(MessageReference reference, String consumerID,
+                   long deliveryID, PacketSender sender)
+   {      
+      this.reference = reference;
+      this.consumerID = consumerID;
+      this.deliveryID = deliveryID;
+      this.sender = sender;
+   }
+
+   public MessageReference getReference()
+   {
+      return reference;
+   }
+
+   public long getDeliveryID()
+   {
+      return deliveryID;
+   }
+   
+   public void deliver()
+   {
+      DeliverMessage message = new DeliverMessage(reference.getMessage(),
+                                                  deliveryID,
+                                                  reference.getDeliveryCount() + 1);
+      
+      message.setTargetID(consumerID);
+                  
+      message.setVersion((byte)0);
+      
+      sender.send(message);
+   }
+}

Added: trunk/src/main/org/jboss/messaging/core/remoting/codec/SessionAcknowledgeMessageCodec.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/remoting/codec/SessionAcknowledgeMessageCodec.java	                        (rev 0)
+++ trunk/src/main/org/jboss/messaging/core/remoting/codec/SessionAcknowledgeMessageCodec.java	2008-01-26 15:06:30 UTC (rev 3632)
@@ -0,0 +1,72 @@
+/*
+ * JBoss, Home of Professional Open Source
+ *
+ * Distributable under LGPL license.
+ * See terms of license at gnu.org.
+ */
+package org.jboss.messaging.core.remoting.codec;
+
+import org.jboss.messaging.core.remoting.wireformat.PacketType;
+import org.jboss.messaging.core.remoting.wireformat.SessionAcknowledgeMessage;
+
+/**
+ * 
+ * A SessionAcknowledgeMessageCodec
+ * 
+ * @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
+ *
+ */
+public class SessionAcknowledgeMessageCodec extends AbstractPacketCodec<SessionAcknowledgeMessage>
+{
+   // Constants -----------------------------------------------------
+
+   // Attributes ----------------------------------------------------
+
+   // Static --------------------------------------------------------
+
+   // Constructors --------------------------------------------------
+
+   public SessionAcknowledgeMessageCodec()
+   {
+      super(PacketType.MSG_ACKNOWLEDGE);
+   }
+
+   // Public --------------------------------------------------------
+
+   // AbstractPacketCodec overrides ---------------------------------
+
+   @Override
+   protected void encodeBody(SessionAcknowledgeMessage message, RemotingBuffer out) throws Exception
+   {
+      int bodyLength = LONG_LENGTH + 1;
+
+      out.putInt(bodyLength);
+      out.putLong(message.getDeliveryID());
+      out.putBoolean(message.isAllUpTo());
+   }
+
+   @Override
+   protected SessionAcknowledgeMessage decodeBody(RemotingBuffer in)
+         throws Exception
+   {
+      int bodyLength = in.getInt();
+      if (in.remaining() < bodyLength)
+      {
+         return null;
+      }
+      
+      long deliveryID = in.getLong();
+      boolean isAllUpTo = in.getBoolean();
+     
+      return new SessionAcknowledgeMessage(deliveryID, isAllUpTo);
+   }
+
+   // Package protected ---------------------------------------------
+
+   // Protected -----------------------------------------------------
+
+   // Private ----------------------------------------------------
+
+   // Inner classes -------------------------------------------------
+}
+

Added: trunk/src/main/org/jboss/messaging/core/remoting/codec/SessionCancelMessageCodec.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/remoting/codec/SessionCancelMessageCodec.java	                        (rev 0)
+++ trunk/src/main/org/jboss/messaging/core/remoting/codec/SessionCancelMessageCodec.java	2008-01-26 15:06:30 UTC (rev 3632)
@@ -0,0 +1,72 @@
+/*
+ * JBoss, Home of Professional Open Source
+ *
+ * Distributable under LGPL license.
+ * See terms of license at gnu.org.
+ */
+package org.jboss.messaging.core.remoting.codec;
+
+import org.jboss.messaging.core.remoting.wireformat.PacketType;
+import org.jboss.messaging.core.remoting.wireformat.SessionCancelMessage;
+
+/**
+ * 
+ * A SessionCancelMessageCodec
+ * 
+ * @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
+ *
+ */
+public class SessionCancelMessageCodec extends AbstractPacketCodec<SessionCancelMessage>
+{
+   // Constants -----------------------------------------------------
+
+   // Attributes ----------------------------------------------------
+
+   // Static --------------------------------------------------------
+
+   // Constructors --------------------------------------------------
+
+   public SessionCancelMessageCodec()
+   {
+      super(PacketType.MSG_CANCEL);
+   }
+
+   // Public --------------------------------------------------------
+
+   // AbstractPacketCodec overrides ---------------------------------
+
+   @Override
+   protected void encodeBody(SessionCancelMessage message, RemotingBuffer out) throws Exception
+   {
+      int bodyLength = LONG_LENGTH + 1;
+
+      out.putInt(bodyLength);
+      out.putLong(message.getDeliveryID());
+      out.putBoolean(message.isExpired());
+   }
+
+   @Override
+   protected SessionCancelMessage decodeBody(RemotingBuffer in)
+         throws Exception
+   {
+      int bodyLength = in.getInt();
+      if (in.remaining() < bodyLength)
+      {
+         return null;
+      }
+      
+      long deliveryID = in.getLong();
+      boolean expired = in.getBoolean();
+     
+      return new SessionCancelMessage(deliveryID, expired);
+   }
+
+   // Package protected ---------------------------------------------
+
+   // Protected -----------------------------------------------------
+
+   // Private ----------------------------------------------------
+
+   // Inner classes -------------------------------------------------
+}
+

Added: trunk/src/main/org/jboss/messaging/core/remoting/wireformat/SessionAcknowledgeMessage.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/remoting/wireformat/SessionAcknowledgeMessage.java	                        (rev 0)
+++ trunk/src/main/org/jboss/messaging/core/remoting/wireformat/SessionAcknowledgeMessage.java	2008-01-26 15:06:30 UTC (rev 3632)
@@ -0,0 +1,58 @@
+/*
+ * JBoss, Home of Professional Open Source
+ *
+ * Distributable under LGPL license.
+ * See terms of license at gnu.org.
+ */
+package org.jboss.messaging.core.remoting.wireformat;
+
+
+/**
+ * @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
+ * 
+ * @version <tt>$Revision$</tt>
+ */
+public class SessionAcknowledgeMessage extends AbstractPacket
+{
+   // Constants -----------------------------------------------------
+
+   // Attributes ----------------------------------------------------
+   
+   private long deliveryID;
+   
+   private boolean allUpTo;
+
+   // Static --------------------------------------------------------
+
+   // Constructors --------------------------------------------------
+
+   public SessionAcknowledgeMessage(long deliveryID, boolean allUpTo)
+   {
+      super(PacketType.MSG_ACKNOWLEDGE);
+      
+      this.deliveryID = deliveryID;
+      
+      this.allUpTo = allUpTo;
+   }
+
+   // Public --------------------------------------------------------
+   
+   public long getDeliveryID()
+   {
+      return deliveryID;
+   }
+   
+   public boolean isAllUpTo()
+   {
+      return allUpTo;
+   }
+
+   // Package protected ---------------------------------------------
+
+   // Protected -----------------------------------------------------
+
+   // Private -------------------------------------------------------
+
+   // Inner classes -------------------------------------------------
+}
+

Added: trunk/src/main/org/jboss/messaging/core/remoting/wireformat/SessionCancelMessage.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/remoting/wireformat/SessionCancelMessage.java	                        (rev 0)
+++ trunk/src/main/org/jboss/messaging/core/remoting/wireformat/SessionCancelMessage.java	2008-01-26 15:06:30 UTC (rev 3632)
@@ -0,0 +1,58 @@
+/*
+ * JBoss, Home of Professional Open Source
+ *
+ * Distributable under LGPL license.
+ * See terms of license at gnu.org.
+ */
+package org.jboss.messaging.core.remoting.wireformat;
+
+
+/**
+ * @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
+ * 
+ * @version <tt>$Revision$</tt>
+ */
+public class SessionCancelMessage extends AbstractPacket
+{
+   // Constants -----------------------------------------------------
+
+   // Attributes ----------------------------------------------------
+   
+   private long deliveryID;
+   
+   private boolean expired;
+
+   // Static --------------------------------------------------------
+
+   // Constructors --------------------------------------------------
+
+   public SessionCancelMessage(long deliveryID, boolean expired)
+   {
+      super(PacketType.MSG_CANCEL);
+      
+      this.deliveryID = deliveryID;
+      
+      this.expired = expired;
+   }
+
+   // Public --------------------------------------------------------
+   
+   public long getDeliveryID()
+   {
+      return deliveryID;
+   }
+   
+   public boolean isExpired()
+   {
+      return expired;
+   }
+
+   // Package protected ---------------------------------------------
+
+   // Protected -----------------------------------------------------
+
+   // Private -------------------------------------------------------
+
+   // Inner classes -------------------------------------------------
+}
+

Added: trunk/src/main/org/jboss/messaging/core/remoting/wireformat/SessionCommitMessage.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/remoting/wireformat/SessionCommitMessage.java	                        (rev 0)
+++ trunk/src/main/org/jboss/messaging/core/remoting/wireformat/SessionCommitMessage.java	2008-01-26 15:06:30 UTC (rev 3632)
@@ -0,0 +1,40 @@
+/*
+ * JBoss, Home of Professional Open Source
+ *
+ * Distributable under LGPL license.
+ * See terms of license at gnu.org.
+ */
+package org.jboss.messaging.core.remoting.wireformat;
+
+
+/**
+ * @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
+ * 
+ * @version <tt>$Revision$</tt>
+ */
+public class SessionCommitMessage extends AbstractPacket
+{
+   // Constants -----------------------------------------------------
+
+   // Attributes ----------------------------------------------------
+   
+   // Static --------------------------------------------------------
+
+   // Constructors --------------------------------------------------
+
+   public SessionCommitMessage()
+   {
+      super(PacketType.MSG_COMMIT);
+   }
+
+   // Public --------------------------------------------------------
+
+   // Package protected ---------------------------------------------
+
+   // Protected -----------------------------------------------------
+
+   // Private -------------------------------------------------------
+
+   // Inner classes -------------------------------------------------
+}
+

Added: trunk/src/main/org/jboss/messaging/core/remoting/wireformat/SessionRecoverMessage.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/remoting/wireformat/SessionRecoverMessage.java	                        (rev 0)
+++ trunk/src/main/org/jboss/messaging/core/remoting/wireformat/SessionRecoverMessage.java	2008-01-26 15:06:30 UTC (rev 3632)
@@ -0,0 +1,40 @@
+/*
+ * JBoss, Home of Professional Open Source
+ *
+ * Distributable under LGPL license.
+ * See terms of license at gnu.org.
+ */
+package org.jboss.messaging.core.remoting.wireformat;
+
+
+/**
+ * @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
+ * 
+ * @version <tt>$Revision$</tt>
+ */
+public class SessionRecoverMessage extends AbstractPacket
+{
+   // Constants -----------------------------------------------------
+
+   // Attributes ----------------------------------------------------
+
+   // Static --------------------------------------------------------
+
+   // Constructors --------------------------------------------------
+
+   public SessionRecoverMessage()
+   {
+      super(PacketType.MSG_RECOVER);
+   }
+
+   // Public --------------------------------------------------------
+
+   // Package protected ---------------------------------------------
+
+   // Protected -----------------------------------------------------
+
+   // Private -------------------------------------------------------
+
+   // Inner classes -------------------------------------------------
+}
+

Added: trunk/src/main/org/jboss/messaging/core/remoting/wireformat/SessionRollbackMessage.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/remoting/wireformat/SessionRollbackMessage.java	                        (rev 0)
+++ trunk/src/main/org/jboss/messaging/core/remoting/wireformat/SessionRollbackMessage.java	2008-01-26 15:06:30 UTC (rev 3632)
@@ -0,0 +1,40 @@
+/*
+ * JBoss, Home of Professional Open Source
+ *
+ * Distributable under LGPL license.
+ * See terms of license at gnu.org.
+ */
+package org.jboss.messaging.core.remoting.wireformat;
+
+
+/**
+ * @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
+ * 
+ * @version <tt>$Revision$</tt>
+ */
+public class SessionRollbackMessage extends AbstractPacket
+{
+   // Constants -----------------------------------------------------
+
+   // Attributes ----------------------------------------------------
+   
+   // Static --------------------------------------------------------
+
+   // Constructors --------------------------------------------------
+
+   public SessionRollbackMessage()
+   {
+      super(PacketType.MSG_ROLLBACK);
+   }
+
+   // Public --------------------------------------------------------
+
+   // Package protected ---------------------------------------------
+
+   // Protected -----------------------------------------------------
+
+   // Private -------------------------------------------------------
+
+   // Inner classes -------------------------------------------------
+}
+




More information about the jboss-cvs-commits mailing list