Package org.ow2.joram.mom.amqp

Class PublishRequest

java.lang.Object

org.ow2.joram.mom.amqp.PublishRequest

All Implemented Interfaces:

Serializable

public class PublishRequest
extends Object
implements Serializable

Class used by the AMQPConnectionListener to hold all the parameters ( Basic.Publish method, header and body) necessary to publish a message while they are received on the socket.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
private byte[]	body
private int	bodyRead
int	channel
private AMQP.Basic.BasicProperties	header
private AMQP.Basic.Publish	publish
private static long	serialVersionUID

Constructor Summary

Constructors

Constructor	Description
PublishRequest()

Method Summary

Modifier and Type	Method	Description
boolean	appendBody(byte[] bodyPart)
byte[]	getBody()
AMQP.Basic.BasicProperties	getHeader()
AMQP.Basic.Publish	getPublish()
void	setHeader(AMQP.Basic.BasicProperties header, long bodySize)	set the header content.
void	setPublish(AMQP.Basic.Publish publish)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

serialVersionUID

private static final long serialVersionUID

See Also:

Constant Field Values

publish

private AMQP.Basic.Publish publish

header

private AMQP.Basic.BasicProperties header

body

private byte[] body

bodyRead

private int bodyRead

channel

public int channel

Constructor Detail

PublishRequest

public PublishRequest()

Method Detail

setHeader

public void setHeader(AMQP.Basic.BasicProperties header,
                      long bodySize)

set the header content.

Parameters:

classId -

weight -

bodySize -

propertyFlags -

propertyList -

getHeader

public AMQP.Basic.BasicProperties getHeader()

setPublish

public void setPublish(AMQP.Basic.Publish publish)

getPublish

public AMQP.Basic.Publish getPublish()

getBody

public byte[] getBody()

appendBody

public boolean appendBody(byte[] bodyPart)