org.codehaus.activemq.service.impl
Class PacketTransactionTask
java.lang.Object
org.codehaus.activemq.service.impl.PacketTransactionTask
- All Implemented Interfaces:
- Externalizable, Serializable, TransactionTask
- Direct Known Subclasses:
- MessageAckTransactionTask, RedeliverMessageTransactionTask, SendMessageTransactionTask
- public abstract class PacketTransactionTask
- extends Object
- implements TransactionTask, Externalizable
- Version:
- $Revision: 1.2 $
- See Also:
- Serialized Form
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
PacketTransactionTask
protected PacketTransactionTask(BrokerClient brokerClient,
Packet packet)
fromBytes
public static TransactionTask fromBytes(byte[] data)
throws IOException
- Throws:
IOException
toBytes
public byte[] toBytes()
throws JMSException,
IOException
- Throws:
JMSException
IOException
readTask
public static TransactionTask readTask(ObjectInput in)
throws IOException
- Throws:
IOException
createTask
public static TransactionTask createTask(Packet packet)
throws IOException
- Throws:
IOException
writeTask
public static void writeTask(TransactionTask task,
ObjectOutput out)
throws IOException
- Throws:
IOException
getPacket
public Packet getPacket()
writeExternal
public void writeExternal(ObjectOutput out)
throws IOException
- Specified by:
writeExternal
in interface Externalizable
- Throws:
IOException
readExternal
public void readExternal(ObjectInput in)
throws IOException,
ClassNotFoundException
- Specified by:
readExternal
in interface Externalizable
- Throws:
IOException
ClassNotFoundException
createBrokerClient
protected BrokerClient createBrokerClient(String consumerId)
throws JMSException
- Throws:
JMSException
getBrokerClient
protected BrokerClient getBrokerClient(String consumerId)
throws JMSException
- Throws:
JMSException
writePacket
protected static void writePacket(Packet packet,
ObjectOutput out)
throws IOException
- Throws:
IOException
readPacket
protected static Packet readPacket(ObjectInput in)
throws IOException
- Throws:
IOException
Copyright © 2004-2005 Protique, Ltd.. All Rights Reserved.