public class PublishRequest extends Object implements Serializable
AMQPConnectionListener
to hold all the parameters (
Basic.Publish
method, header and body) necessary to publish a
message while they are received on the socket.Modifier and Type | Field and Description |
---|---|
private byte[] |
body |
private int |
bodyRead |
int |
channel |
private AMQP.Basic.BasicProperties |
header |
private AMQP.Basic.Publish |
publish |
private static long |
serialVersionUID |
Constructor and Description |
---|
PublishRequest() |
Modifier and Type | Method and 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) |
private static final long serialVersionUID
private AMQP.Basic.Publish publish
private AMQP.Basic.BasicProperties header
private byte[] body
private int bodyRead
public int channel
public void setHeader(AMQP.Basic.BasicProperties header, long bodySize)
classId
- weight
- bodySize
- propertyFlags
- propertyList
- public AMQP.Basic.BasicProperties getHeader()
public void setPublish(AMQP.Basic.Publish publish)
public AMQP.Basic.Publish getPublish()
public byte[] getBody()
public boolean appendBody(byte[] bodyPart)
Copyright © 2015 ScalAgent D.T.. All Rights Reserved.