[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