org.jboss.messaging.core.plugin.postoffice.cluster
Class PullMessagesRequest
java.lang.Object
org.jboss.messaging.core.plugin.postoffice.cluster.ClusterRequest
org.jboss.messaging.core.plugin.postoffice.cluster.TransactionRequest
org.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
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 |
nodeId
protected int nodeId
txId
protected long txId
hold
protected boolean hold
checkChannelID
protected long checkChannelID
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.