org.jboss.messaging.core.plugin.postoffice.cluster
Class PullMessagesRequest

java.lang.Object
  extended byorg.jboss.messaging.core.plugin.postoffice.cluster.ClusterRequest
      extended byorg.jboss.messaging.core.plugin.postoffice.cluster.TransactionRequest
          extended byorg.jboss.messaging.core.plugin.postoffice.cluster.PullMessagesRequest
All Implemented Interfaces:
org.jboss.messaging.core.plugin.postoffice.cluster.ClusterTransaction, Streamable

public class PullMessagesRequest
extends org.jboss.messaging.core.plugin.postoffice.cluster.TransactionRequest
implements org.jboss.messaging.core.plugin.postoffice.cluster.ClusterTransaction

A PullMessagesRequest

Version:
$Revision: 2204 $ $Id: PullMessagesRequest.java 2204 2007-02-08 14:21:08Z timfox $
Author:
Tim Fox

Field Summary
protected  long checkChannelID
           
protected  boolean hold
           
protected  int nodeId
           
protected  long txId
           
 
Method Summary
 boolean check(org.jboss.messaging.core.plugin.postoffice.cluster.PostOfficeInternal office)
           
 void commit(org.jboss.messaging.core.plugin.postoffice.cluster.PostOfficeInternal office)
           
 void read(java.io.DataInputStream in)
           
 void rollback(org.jboss.messaging.core.plugin.postoffice.cluster.PostOfficeInternal office)
           
 void write(java.io.DataOutputStream out)
           
static void writeToStream(java.io.DataOutputStream daos, org.jboss.messaging.core.plugin.postoffice.cluster.ClusterRequest request)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

nodeId

protected int nodeId

txId

protected long txId

hold

protected boolean hold

checkChannelID

protected long checkChannelID
Method Detail

check

public boolean check(org.jboss.messaging.core.plugin.postoffice.cluster.PostOfficeInternal office)
              throws java.lang.Exception
Specified by:
check in interface org.jboss.messaging.core.plugin.postoffice.cluster.ClusterTransaction
Throws:
java.lang.Exception

commit

public void commit(org.jboss.messaging.core.plugin.postoffice.cluster.PostOfficeInternal office)
            throws java.lang.Throwable
Specified by:
commit in interface org.jboss.messaging.core.plugin.postoffice.cluster.ClusterTransaction
Throws:
java.lang.Throwable

rollback

public void rollback(org.jboss.messaging.core.plugin.postoffice.cluster.PostOfficeInternal office)
              throws java.lang.Throwable
Specified by:
rollback in interface org.jboss.messaging.core.plugin.postoffice.cluster.ClusterTransaction
Throws:
java.lang.Throwable

read

public void read(java.io.DataInputStream in)
          throws java.lang.Exception
Specified by:
read in interface Streamable
Throws:
java.lang.Exception

write

public void write(java.io.DataOutputStream out)
           throws java.lang.Exception
Specified by:
write in interface Streamable
Throws:
java.lang.Exception

writeToStream

public static void writeToStream(java.io.DataOutputStream daos,
                                 org.jboss.messaging.core.plugin.postoffice.cluster.ClusterRequest request)
                          throws java.lang.Exception
Throws:
java.lang.Exception


Copyright © 2006 JBoss Inc. All Rights Reserved.